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

Question

我有一个DockerOperator在工作，但是当我使用“气流测试”运行它时，气流没有像对PythonOperator或BashOperator那样显示我的DockerOperator的任何日志记录语句。但是，我可以看到运行相同任务的日志记录语句。我还将如何使记录仪可见以进行“气流测试”？

Answer 1

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

import logging
import sys

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