airflow.example_dags.example_xcom

演示 XComs 用法的示例 DAG。

模块内容

函数

push([ti])

推送一个没有特定目标的 XCom

push_by_returning()

通过返回它来推送一个没有特定目标的 XCom

puller(pulled_value_2[, ti])

拉取所有先前推送的 XCom,并检查推送的值是否与拉取的值匹配。

pull_value_from_bash_push([ti])

属性

value_1

value_2

bash_push

airflow.example_dags.example_xcom.value_1 = [1, 2, 3][源代码]
airflow.example_dags.example_xcom.value_2[源代码]
airflow.example_dags.example_xcom.push(ti=None)[源代码]

推送一个没有特定目标的 XCom

airflow.example_dags.example_xcom.push_by_returning()[源代码]

通过返回它来推送一个没有特定目标的 XCom

airflow.example_dags.example_xcom.puller(pulled_value_2, ti=None)[源代码]

拉取所有先前推送的 XCom,并检查推送的值是否与拉取的值匹配。

airflow.example_dags.example_xcom.pull_value_from_bash_push(ti=None)[源代码]
airflow.example_dags.example_xcom.bash_push[源代码]

此条目是否有帮助?