如何为 GCP 数据流作业构建租户级指标计数器？答案

【问题标题】：How to build tenant level metrics counter for GCP dataflow jobs?如何为 GCP 数据流作业构建租户级指标计数器？
【发布时间】：2020-09-22 19:36:29
【问题描述】：

目前我正在尝试使用 apache Beam Metrics 为 GCP 数据流作业创建自定义指标，并想检查我们是否可以根据租户跟踪/分组计数器。例如，我们有多个租户生成的事件，所有事件都在数据流作业（写入大表）中处理，我想添加指标过滤器以按租户对它们进行分组，以便我们可以在租户级别看到 elmentsAdded。

【问题讨论】：

标签： google-cloud-platform google-cloud-dataflow apache-beam metrics

【解决方案1】：

目前无法使用 Beam Metrics；他们无法设置额外的指标字段，例如租户。

但是，您可以直接使用流水线代码中的 Cloud Monitoring API 以您想要的任何架构将数据导出到 Cloud Monitoring

【讨论】：

有例子吗？
API 文档中有示例。您无需在此处执行任何特定于 Beam 或 Dataflow 的操作。