时间戳

首页 > 解决方案 > 外部触发 Airflow DAG 时如何访问配置值？

airflow - 外部触发 Airflow DAG 时如何访问配置值？

问题描述

根据https://airflow.apache.org/api.html我可以像这样触发 Airflow DAG：

curl -X POST \
  http://localhost:8080/api/experimental/dags/<DAG_ID>/dag_runs \
  -H 'Cache-Control: no-cache' \
  -H 'Content-Type: application/json' \
  -d '{"conf":"{\"key\":\"value\"}"}'

这对我来说似乎没问题，但我不知道如何访问传入的对象中的key/value东西。conf

我试过这个：

something = dag.params.get("key", "unknown")

但这似乎不起作用。

有谁知道如何做到这一点？

标签： airflow

解决方案

推荐阅读