airflow - 气流在远程网络服务器上使用参数运行 dag

Question

我想在远程网络服务器上启动 dags。这些 dag 需要参数才能有意义。在本地，我使用这样的命令：

airflow trigger_dag dag_id --conf '{"parameter":"~/path" }'

问题是这假设我在本地运行。如何使用参数触发远程气流服务器上的 dag？我意识到我可以使用 ui 来点击播放按钮，但这不允许你传递我知道的参数。

标签： airflow

Answer 1

示例网址：

http://localhost:8080/api/experimental/dags/<dag_id>/dag_runs

示例帖子有效负载（应用程序/json）：

{"conf":"{\"client\":\"popsicle\"}"}

请注意，嵌入的 conf 对象必须是字符串，而不是对象。