Как я могу создать пользовательские метрики в Beam для каждого значения определенного атрибута сообщения?

# #google-cloud-dataflow #apache-beam Вопрос: У нас есть потоковый конвейер Apache Beam, который работает на потоке данных Google Cloud. Каждое сообщение, поступающее в конвейер, является документом JSON и содержит атрибут типа…