0

因为我不能使用气流 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调度程序日志中找到这些数据。

是否需要更改配置？

问候， 游吟诗人

4

1 回答 1

0

您应该改用 Airflow 2 REST API。

这样做是为了让您不必解析日志。https://airflow.apache.org/docs/apache-airflow/stable/stable-rest-api-ref.html

于 2021-12-01T17:50:29.837 回答