0

我已经使用 KubernetesExecutor 在 Kubernetes 上部署了 Airflow。在我尝试获取日志之前,一切似乎都运行良好。UI 确实向我显示了日志,但实际上并没有写入完整的日志。对于我执行的每个任务,使用尽可能多的打印语句,日志只会显示到排队状态,也就是说,我看不到任何记录的消息。我尝试过使用常见的打印语句以及日志导入。此外,我尝试使用不同的 Helm 图表,并且在所有这些图表中我得到相同的结果。从 Kubernetes pod 本身读取日志​​给了我与气流 UI 相同的结果。

[2021-08-16 21:47:44,062] {dagbag.py:448} INFO - 从 /home/airflow/.local/lib/python3.8/site-packages/airflow/example_dags/example_bash_operator 填充 DagBag。 py 在主机 examplebashoperatorrunme1.6ef611f7e3c143d2a7a1df5e91984a82 上运行 <TaskInstance: example_bash_operator.runme_1 2021-08-16T21:47:15.407072+00:00 [queued]>

这是完整的日志。POD 成功终止,一切似乎都正常,而不是日志。有人可以帮助我,因为我已经尝试了 yaml 文件中可能的每个参数好几天了,但仍然被困在这个问题上?

这与远程日志记录无关,因为我什至无法访问本地日志记录。

4

0 回答 0