相关疑难解决方法(0)

注意：这不是重复的

• 在运行时使用气流导出环境变量
• 在运行时设置气流环境变量

我必须从我的Airflow DAG. 实现这一目标的直接方法是SSHHook.

问题在于远程系统是一个EMR集群，它本身是在运行时（由上游任务）使用EmrCreateJobFlowOperator. 因此，虽然我可以掌握job_flow_id已启动的 EMR 集群（usingXCOM），但我需要的是将 anssh_conn_id传递给每个下游任务。

查看文档和代码，很明显 Airflow 将尝试conn_id在db和环境变量中查找此连接（使用），因此现在问题归结为能够在运行时设置这两个属性中的任何一个（从内部一个operator）。

这似乎是一个相当普遍的问题，因为如果无法实现，那么 的效用EmrCreateJobFlowOperator将受到严重阻碍；但我还没有遇到任何证明它的例子。

• 是否可以从 Airflow 操作员内部创建（并销毁）其中任何一个？
  1. 连接（保留在 Airflow 的数据库中）
  2. 环境变量（应该可供所有下游任务访问，而不仅仅是此处所述的当前任务）
• 如果没有，我有什么选择？

我上线了

• Airflow v1.10
• Python 3.6.6
• emr-5.15 （如果需要可以升级）