python - 如何传递 Airflow 'ds' 默认变量？

Question

我是 Airflow 的新手，对默认变量有点困惑。我有自定义运算符，我想ds在文件名中使用。文件名 = str(f) + '{{ ds }}' + str(ext)

我得到的实际结果是 file{{ds}}.docx 但我希望 file2020-01-01.docx

标签： pythonairflow

Answer 1

包含花括号（例如{{ ds }}：）的字符串是模板值，Airflow 通过 Jinja2 模板呈现某些运算符属性，提供有关当前运行的详细信息。

本文档概述了如何在自定义运算符中使用模板：https ://airflow.apache.org/docs/stable/howto/custom-operator.html#templating