我正在尝试运行气流DAG并需要为任务传递一些参数.
如何trigger_dag在python DAG文件中读取命令行命令中作为--conf参数传递的JSON字符串.
trigger_dag
例如: airflow trigger_dag 'dag_name' -r 'run_id' --conf '{"key":"value"}'
airflow trigger_dag 'dag_name' -r 'run_id' --conf '{"key":"value"}'
airflow apache-airflow airflow-scheduler
airflow ×1
airflow-scheduler ×1
apache-airflow ×1