首页 > 解决方案 > Apache Beam - 监控管道并查询阶段的状态

问题描述

在执行 Apache Beam 管道时,我想更新数据库中管道的状态。

我想这样做,以便我可以在一天结束时进行审查,看看有多少管道执行完全完成,大多数管道当前执行的当前阶段是什么,等等。

从 Apache Beam 的 Java 或 Python API 获取此信息的最佳方式是什么?

标签: apache-beam

解决方案


推荐阅读