Airflow 3中如何从DAG内自动清理旧XCom记录？

核心结论 #

Airflow 3不支持从DAG任务内直接清理XCom的官方方式，目前只能通过外部cronjob执行airflow db clean命令实现定期清理。

详细说明 #

• Airflow 3彻底封禁了DAG任务直接访问元数据库的操作，同时官方REST API未提供XCom的DELETE端点，切断了从DAG内部操作XCom记录的官方路径。
• 现有主流方案均指向外部调度：通过系统级cronjob定期调用airflow db clean --clean-before-days 15命令，指定清理15天前的旧XCom（该命令默认会清理包括XCom在内的多种过期元数据）。
• 若要更精准地只清理XCom，可基于Airflow的元数据模型编写独立脚本，通过外部调度执行，但同样无法嵌入DAG任务内运行——Airflow 3的沙箱机制会限制此类直接操作元数据的行为。

内容的提问来源于stack exchange，提问作者Sara Brajkovski