3.3.2.1 数据推送与拉取

文档摘要

3.3.2.1 数据推送与拉取你有没有在凌晨两点盯着 Airflow DAG 的日志，看着一个本该 5 秒完成的卡在上整整 17 分钟，而下游任务早已超时失败？你有没有把写进，却在时只拿到空字符串，翻遍文档才发现 Bash 的 stdout 被截断了——不是你的脚本没输出，是 Airflow 默认只存前 48KB？你有没有在生产环境上线后突然发现：三个并行分支任务各自了不同格式的 JSON（、、），而汇聚层时用直接抛出，整个数据链路无声崩塌？这不是玄学。这是 XCom —— Airflow 最被滥用、最常被误解、也最值得被重新驯服的核心机制之一。而“3.3.2.1 数据推送与拉取”，从来就不是教你怎么调用和的 API 文档复述。