2

我们有许多 python 进程，它们都实现了一个通用的记录器设置，它将所有内容记录到同一个文件并每天轮换文件。

我们最近开始改用 Airflow。最初我们使用 BashOperators，但我们想开始使用 PythonOperators 以利用 Airflow 的更多功能。但是，当我们从 DAG 调用日志记录设置时，日志记录设置似乎没有得到应用。我尝试了许多方法，从our_custom_logging.setup()在 DAG 顶部调用到将其放入 python 可调用对象中：

def python_callable():
    our_custom_logging.setup()
    run_job()

似乎这仍然总是在标准 Airflow 日志位置结束。我知道我们可以如何更改 Airflow 日志记录配置，但我们仍然希望将这些日志存储并在 UI 中可见，因此理想情况下，我们只想在 Airflow 旁边添加额外的日志处理。这有可能吗？

4

0 回答 0