Python Google 数据流上的流式传输管道缺少一些元素指标

Python Streaming pipeline on Google Dataflow missing some Element metrics

我是 运行 一个 Python 数据流(光束 2.5)并且想知道为什么在 beam.Map(lambda x: x.decode('utf-8')).

之后没有显示步骤指标

一切正常,但元素数量消失了。

如您所见,从这一点开始的数字为零。

有什么我遗漏的吗?

Support for streaming pipelines with Apache Beam Python SDK on Google Cloud Dataflow is in Beta.

有些功能没有得到完全支持,有些监控指标就是这种情况。随着支持的改进,这些将逐渐添加。