我看到很多关于如何使用的例子xcom_push and xcom_pull与 Airflow 中的 PythonOperators 一起使用。
我需要去做xcom_pull from a 非Python运算符类，但找不到如何做。
任何指针或示例将不胜感激！
您可以从模板化字段中访问 XCom 变量。例如，从 XCom 读取：
myOperator = MyOperator(
message="Operation result: {{ task_instance.xcom_pull(task_ids=['task1', 'task2'], key='result_status') }}",
...
也可以不指定任务来获取具有相同密钥名称的一个 DagRun 中的所有 XCom 推送
myOperator = MyOperator(
message="Warning status: {{ task_instance.xcom_pull(task_ids=None, key='warning_status') }}",
...
将返回一个数组。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
