エアフローで--confオプションを使用するには

エアフローDAGを実行しようとしており、タスクのパラメータを渡す必要があります。エアフローで--confオプションを使用するには

Python DAGファイルのコマンドラインtrigger_dagコマンドで、--confパラメータとして渡されたJSON文字列を読み取るにはどうすればよいですか。

例：airflow trigger_dag 'dag_name' -r 'run_id' --conf '{"key":"value"}'

https://github.com/apache/incubator-airflow/blob/master/airflow/example_dags/example_trigger_target_dag.py#L62でサンプルを見つけました –

二つの方法。テンプレートフィールドまたはファイル内から：

{{ dag_run.conf['key'] }}

PythonOperatorの呼び出し可能なのpython内：

context['dag_run'].conf['key']

2017-08-31 18:32:05

答えて