您好, 欢迎来到 !    登录 | 注册 | | 设为首页 | 收藏本站

在op_kwargs中具有执行日期的Airflow Python脚本

在op_kwargs中具有执行日期的Airflow Python脚本

这确实有点令人困惑,而且没有很好的记录。

您已经在使用PythonOperator

现在只需添加选项

provide_context=True,

并使用指针扩展您的可调用对象,例如

update_bmk(bmk_code, is_hedged, **context)

现在,在您的函数中,您将可以访问有关任务的所有信息,包括执行日期,如下所示:

task_instance = context['task_instance']
execution_date = context['execution_date']

要查看上下文中项目的完整参考,请参阅https://airflow.apache.org/macros.html

这些是宏的文档,但是您可以使用上下文字典中的项目。

python 2022/1/1 18:52:10 有311人围观

撰写回答


你尚未登录,登录后可以

和开发者交流问题的细节

关注并接收问题和回答的更新提醒

参与内容的编辑和改进,让解决方法与时俱进

请先登录

推荐问题


联系我
置顶