因为我不能使用气流 CLI,我实际上是在气流1上使用 grep 解析调度程序日志,以便检索一些信息,例如:
- 检查 dag 是否被触发/是否成功/使用模式“INFO Marking run”开始时间戳:
[2021-12-01 11:06:50,340] {logging_mixin.py:112} 信息 - [2021-12-01 11:06:50,339] {dagrun.py:307} 信息 - 标记运行 <DagRun prd_*** @ 2021-12-01 10:02:00+00:00:预定__2021-12-01T10:02:00+00:00,外部触发:False>成功
- 当 dag 没有被触发时,我使用模式“INFO - Created”来检索 dag 的开始时间戳:
[2021-12-01 11:04:49,213] {scheduler_job.py:1298} 信息 - 创建 <DagRun prd_*** @ 2021-12-01T10:02:00+00:00: schedule__2021-12-01T10:02 :00+00:00,外部触发:False>
它在气流 1 上运行良好,但迁移后我无法在气流2调度程序日志中找到这些数据。
是否需要更改配置?
问候, 游吟诗人