Comment utiliser l'option --conf dans le flux d'air

J'essaie d'exécuter un DAG de flux d'air et j'ai besoin de passer certains paramètres pour les tâches.Comment utiliser l'option --conf dans le flux d'air

Comment lire la chaîne JSON passée en tant que paramètre --conf dans la commande trigger_dag de la ligne de commande, dans le fichier DAG python.

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

trouvé un échantillon à https://github.com/apache/incubator-airflow/blob/master/airflow/example_dags/example_trigger_target_dag.py#L62 –

Deux façons. A partir de l'intérieur d'un champ de modèle ou d'un fichier:

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

Ou quand le contexte est disponible, par exemple dans un python appelable du PythonOperator:

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

2017-08-31 18:32:05

Répondre