В конвейере потоковой передачи Python в потоке данных Google отсутствуют некоторые метрики элементов

Question

Я использую поток данных Python (луч 2.5), и мне было интересно, почему метрики шага не отображаются после beam.Map(lambda x: x.decode('utf-8')).

Все работает нормально, но количество элементов исчезает.

Как видите, числа с этого момента равны нулю.

Есть ли что-то, чего мне не хватает?

Answer 1

Поддержка потоковых конвейеров с помощью Apache Beam Python SDK в Google Cloud Dataflow представлена ​​в бета-версии .

Некоторые функции поддерживаются не полностью, и это относится к некоторым показателям мониторинга.Они будут постепенно добавляться по мере улучшения поддержки.