airflow.example_dags.example_xcom

範例 DAG 示範 XComs 的用法。

模組內容

函式

push([ti])

推送一個沒有特定目標的 XCom

push_by_returning()

推送一個沒有特定目標的 XCom,僅透過回傳它

puller(pulled_value_2[, ti])

提取所有先前推送的 XComs 並檢查推送的值是否與提取的值相符。

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)[原始碼]

提取所有先前推送的 XComs 並檢查推送的值是否與提取的值相符。

airflow.example_dags.example_xcom.pull_value_from_bash_push(ti=None)[原始碼]
airflow.example_dags.example_xcom.bash_push[原始碼]

此條目是否有幫助?