`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 条目。