【问题标题】:What is the prefered way to write next_ds on an Airflow template?在 Airflow 模板上编写 next_ds 的首选方式是什么?
【发布时间】:2022-06-18 04:16:27
【问题描述】:

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

Here 是我们可以找到当前和已弃用的气流模板变量的地方。

【问题讨论】:

  • next_ds = {{ macros.ds_add(ds, 1) }}
  • @Emma。 ds_add 宏只是将一天添加到dsnext_ds 比它聪明得多,因为它考虑了 schedule_interval。我不认为你的建议是替代品。

标签: python jinja2 airflow


【解决方案1】:

在大多数情况下,我认为这可行:{{ data_interval_end | ds }}

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

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2011-12-03
    • 1970-01-01
    • 1970-01-01
    • 2019-12-06
    • 1970-01-01
    • 2011-06-05
    相关资源
    最近更新 更多