`airflow.providers.common.io.xcom.backend`¶

模組內容¶

XCom 後端，根據資料大小將資料儲存在物件儲存區或資料庫中。

`T`
`SECTION`

class airflow.providers.common.io.xcom.backend.XComObjectStorageBackend(context=None)[原始碼]¶

XCom 後端，根據資料大小將資料儲存在物件儲存區或資料庫中。

如果值大於設定的閾值，則會儲存在物件儲存區中。否則，將儲存在資料庫中。如果儲存在物件儲存區中，則物件在儲存區中的路徑將會被回傳並儲存在資料庫中 (由 BaseXCom)。否則，值本身將被回傳，並因此儲存在資料庫中。

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

將 XCom 值序列化為 JSON 字串。

static deserialize_value(result)[原始碼]¶

從資料庫或物件儲存區反序列化值。

壓縮方式從檔案副檔名推斷。

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

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