CLIを介してエアフローに渡される設定パラメータへのアクセス

Question

ダグ実行をトリガしている間に、次の設定パラメータをAirflow CLIに渡そうとしています。以下は私が使用しているtrigger_dagコマンドです。

airflow trigger_dag -c '{"account_list":"[1,2,3,4,5]", "start_date":"2016-04-25"}' insights_assembly_9900 

私の問題は、dag実行時にオペレータの内部で渡されるconパラメータにどのようにアクセスできるかということです。

Answer 1

airflow trigger_dagコマンドで渡されたパラメータにアクセスするには、2通りの方法があります。 PythonOperatorで定義されている呼び出し可能な方法で

1. 、一つは、あなたがこの事を使用しているフィールドがテンプレート化フィールドであり、1は{{ dag_run.conf['account_list'] }}

を使用することができます与えられた kwargs['dag_run'].conf.get('account_list')

としてのparamsにアクセスすることができます

外部トリガ可能なDAGのschedule_intervalは、上記の作業方法のためにNoneと設定されています。