气流2任务流记录



我正在使用task-flow API(@task annotation(创建一个相当复杂的任务,我需要编写一些日志,这些日志将帮助我在开发期间和将来对运行进行故障诊断。

我研究过这个主题,在官方文档或文章/博客文章中没有发现任何内容。

当使用task-flow API时,编写将显示在任务日志中的日志的惯用方法是什么?

EDIT:函数内的print()语句似乎被记录为logging_mixin中的INFO语句。我仍然认为应该有一种更合适的登录方式。

您需要获得任务记录器:

log = logging.getlogger("airflow.task")

最新更新