Airflow HTTP 操作员/传感器额外选项的文档?

Ada*_*dam 3 directed-acyclic-graphs airflow

我正在尝试读取 Airflow 的 extra_options 设置,以查看可以设置哪些属性(主要对 http 超时感兴趣)。我在任何地方都找不到此特定参数的任何支持文档:https://airflow.readthedocs.io/en/1.9.0/code.html?highlight=requests#airflow.operators.SimpleHttpOperator

有人以前处理过这个问题并且能够提供帮助吗?

vur*_*mux 5

根据源代码airflow.hooks.http_hook.HttpHook.run_and_checkextra_options使用这些参数:

\n\n
\n
        response = session.send(\n            prepped_request,\n            stream=extra_options.get("stream", False),\n            verify=extra_options.get("verify", False),\n            proxies=extra_options.get("proxies", {}),\n            cert=extra_options.get("cert"),\n            timeout=extra_options.get("timeout"),\n            allow_redirects=extra_options.get("allow_redirects", True))\n
Run Code Online (Sandbox Code Playgroud)\n
\n\n

您可以在请求库文档中阅读有关它们的更多信息:

\n\n
    \n
  • stream\xe2\x80\x93 (可选)是否立即下载响应内容。默认为 False。
  • \n
  • verify\xe2\x80\x93 (可选)要么是一个布尔值,在这种情况下它控制我们是否验证服务器\xe2\x80\x99s TLS 证书,要么是一个字符串,在这种情况下它必须是要使用的 CA 捆绑包的路径。默认为 True。
  • \n
  • proxies\xe2\x80\x93 (可选)字典将协议或协议和主机名映射到代理的 URL。
  • \n
  • cert\xe2\x80\x93 (可选)如果是字符串,则为 ssl 客户端证书文件 (.pem) 的路径。如果是元组,则 (\xe2\x80\x98cert\xe2\x80\x99, \xe2\x80\x98key\xe2\x80\x99) 对。
  • \n
  • timeout(浮点或元组)\xe2\x80\x93(可选)在放弃之前等待服务器发送数据的时间,作为浮点或(连接超时,读取超时)元组。
  • \n
  • allow_redirects(bool) \xe2\x80\x93 (可选)默认设置为 True。
  • \n
\n