python - 如何将 execution_date 作为纪元时间？

Question

在常规的 python 代码中我可以这样做:

import time
int(time.time())

这给了我作为纪元的时间。我希望能够使用 Airflow 宏执行此操作:execution_date

这是我尝试过的:

"{{  strptime(execution_date.strftime('%Y-%m-%d %H:%M:%S'), '%d.%m.%Y %H:%M:%S') }}"

但这给出了:

jinja2.exceptions.UndefinedError: 'strptime' is undefined

我正在运行 Airflow 1.9 和 Python 2.7

Answer 1

从 Airflow 1.10 开始，Airflow 使用 Pendulum 作为日期时间，它具有返回纪元的属性 timestamp()、int_timestamp 和 float_timestamp。

所以，你可以这样做:

{{ execution_date.int_timestamp }}

文档:https://pendulum.eustace.io/docs/#attributes-and-properties

其他选项是:

{{ execution_date.strftime('%s') }} # Also Python 2
{{ execution_date.timestamp() }}    # Python >=3.3