在气流中可以结束用户传递参数到与某些特定dag关联的键

Question

我已经搜索了很多链接，但没有找到解决我遇到的问题的任何方法。我已经看到了将密钥/ var传递给airflow UI的选项，但是最终用户使用哪个密钥与哪个dag关联是非常令人困惑的。有没有什么办法可以实现如下功能：

While running an airflow job, end user will be asked for values to some parameters and after entering those details airflow will run the job。

Answer 1

不幸的是，在Airflow UI中不能等待用户输入。 DAG是以编程方式编写的，这意味着定义为代码，并且它们不应该是动态的，因为它们在同一时间导入到Web服务器，调度程序和工作人员中，并且必须相同。

我提出了两种解决方法，我们首先在生产中使用一段时间。

1）创建一个围绕变量的小包装。对于每个DAG，然后加载变量并组成参数，然后通过default_arguments传递给运算符。

2）添加Slack操作符，可以通过编程配置等待用户输入。之后，通过XCOM将该信息传播到下一个运营商。