| 写入 | ti.xcom_push(key, value) 或函数返回值 |
|---|---|
| 读取 | ti.xcom_pull(task_ids=..., key=...) |
| 存储位置 | Airflow 元数据库 xcom 表 |
| 清理 | 随 DAG 运行记录归档或清理 |
push 与 pull
push 与 pull
def push(**context):
context["ti"].xcom_push(key="part", value="dt=2026-10-11")
def pull(**context):
part = context["ti"].xcom_pull(task_ids="push", key="part")
print(part)TaskFlow 自动传参
TaskFlow 自动传参
@task
def a() -> str:
return "dt=2026-10-11"
@task
def b(part: str) -> None:
print(part)
b(a())XCom 值会序列化进元数据库；传百万行数据会让元数据库膨胀、界面卡顿。