如何显示DockerOperator的日志记录输出？

Question

我有一个可以工作的DockerOperator，但是airflow没有显示我的DockerOperator的任何日志记录语句，当我使用"airflow test“运行它时，它对PythonOperator或BashOperator是这样做的。但是，我可以看到运行相同任务的日志语句。我如何使记录器在“气流测试”中也可见？

Answer 1

将以下内容添加到我的执行模块会在DockerOperator中为我显示日志。

import logging
import sys

logging.basicConfig(stream=sys.stdout, level=logging.INFO)