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

属性¶

`T`
`SECTION`

根据数据大小将数据存储在对象存储或数据库中的 XCom 后端。

class airflow.providers.common.io.xcom.backend.XComObjectStorageBackend[源]¶

基类: airflow.sdk.bases.xcom.BaseXCom

根据数据大小将数据存储在对象存储或数据库中的 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=None)[源]¶

从底层存储实现中清除 XCom 条目。