在 Airflow 模板上编写 next_ds 的首选方法是什么?

Gui*_*the 2 python jinja2 airflow

一些在以前版本的气流中非常有用的模板变量现在已被弃用,取而代之的是更通用的变量。但是,我不确定如何模拟以前的模板变量。例如,如何使用可用的结构(例如{{ds}}{{data_interval_start }})来创建{{next_ds}}等。

我们可以在这里找到当前和已弃用的气流模板变量。

小智 6

在大多数情况下,我认为这是有效的{{ data_interval_end | ds }}

数据间隔的结束应该是下一个数据间隔的开始,下一个数据间隔应该与下一个执行日期相同,除非执行日期和数据窗口之间的 dag 上存在某种滞后。该| ds部分只是将时间戳格式化为日期。