airflow.models.xcom

模組內容

類別

BaseXCom

XCom 物件的基礎類別。

函式

resolve_xcom_backend()

解析自訂 XCom 類別。

屬性

log

XCom

airflow.models.xcom.log[原始碼]
class airflow.models.xcom.BaseXCom(name, doc)[原始碼]

Bases: airflow.models.base.TaskInstanceDependencies, airflow.utils.log.logging_mixin.LoggingMixin

XCom 物件的基礎類別。

__tablename__ = 'xcom'[原始碼]
dag_run_id[原始碼]
task_id[原始碼]
map_index[原始碼]
key[原始碼]
dag_id[原始碼]
run_id[原始碼]
value[原始碼]
timestamp[原始碼]
__table_args__ = ()[原始碼]
dag_run[原始碼]
execution_date[原始碼]
init_on_load()[原始碼]

在從資料庫載入或以其他方式重建實例後執行；由 ORM 呼叫。

亦即在從資料庫載入時自動反序列化 Xcom 值。

__repr__()[原始碼]

傳回 repr(self)。

static get_value(*, ti_key, key=None, session=NEW_SESSION)[原始碼]

檢索任務實例的 XCom 值。

此方法傳回「完整」的 XCom 值 (即使用來自 XCom 後端的 deserialize_value)。如果您想要透過 orm_deserialize_value 取得「縮短」的值，請使用 get_many()。

如果沒有結果，則傳回 None。如果有多個 XCom 條目符合條件，則傳回任意一個。

參數
classmethod delete(xcoms, session)[原始碼]

刪除一個或多個 XCom 條目。

static purge(xcom, session)[原始碼]

從底層儲存實作中清除 XCom 條目。

static serialize_value(value, *, key=None, task_id=None, dag_id=None, run_id=None, map_index=None)[原始碼]

將 XCom 值序列化為 str 或 pickled 物件。

static deserialize_value(result)[原始碼]

從 str 或 pickle 物件反序列化 XCom 值。

orm_deserialize_value()[原始碼]

用於重建 ORM XCom 物件的反序列化方法。

自訂 XCom 後端應覆寫此方法，以避免在建立 XCom orm 模型時，不必要的請求或其他消耗資源的操作。例如，這用於在 Web 伺服器中檢視 XCom 清單時。

airflow.models.xcom.resolve_xcom_backend()[原始碼]

解析自訂 XCom 類別。

確認自訂 XCom 類別擴展了 BaseXCom。比較自訂 XCom serialize_value 的函式簽名與基礎 XCom serialize_value 的函式簽名。

airflow.models.xcom.XCom[原始碼]

這個條目對您有幫助嗎？