GCP中按地域拆分Pub/Sub订阅指标及统计消息发布量方法咨询

核心问题 #

Pub/Sub的默认message_published_count指标是否支持地域拆分，取决于你的Topic类型：全局Topic本身没有地域属性，所以不带region标签；而区域化Topic（Regional Topic）会自动携带region标签，这是实现地域统计的关键。

分场景解决方法 #

1. 用区域化Topic直接统计（最优方案） #

如果你的Topic是按区域创建的（比如us-east1、asia-southeast1），直接用MQL查询即可按地域拆分消息发布数：

fetch pubsub_topic
| metric 'pubsub.googleapis.com/topic/message_published_count'
| group_by [region], sum(val())
| every 1m

在GCP监控控制台或仪表盘面板中，选择该指标后，通过region维度拆分就能看到各区域的消息发布量。

2. 全局Topic下间接统计发布者地域 #

如果用的是全局Topic，只能通过审计日志+BigQuery的方式间接统计：

• 先开启Pub/Sub的Data Access审计日志，过滤Publish请求
• 将审计日志导出到BigQuery
• 在BigQuery中，通过发布请求的源IP关联地域数据（比如导入MaxMind GeoIP数据集），统计各地域的发布次数
• 把BigQuery的统计结果接入GCP仪表盘

示例BigQuery查询（假设已导入GeoIP数据）：

SELECT
  geoip.region_name AS region,
  COUNT(*) AS publish_count
FROM
  `your-project.audit_logs.cloudaudit_googleapis_com_data_access`
WHERE
  proto_payload.methodName = 'google.pubsub.v1.Publisher.Publish'
  AND resource.labels.topic_id = 'your-target-topic'
GROUP BY region
ORDER BY publish_count DESC

3. 自定义指标上报（备选） #

如果上述方法都不满足需求，可以在发布消息的客户端代码中，主动上报带地域标签的自定义指标：

• 在客户端获取当前地域（比如通过GCP元数据服务器获取实例所在区域，或通过IP解析）
• 使用OpenTelemetry或GCP自定义指标API，上报custom/pubsub/message_published指标，附带region标签
• 在GCP监控中直接用这个自定义指标做地域拆分

关于message_sizes的补充 #

pubsub.googleapis.com/topic/message_sizes指标如果是区域化Topic，同样带有region标签，可以通过“总消息大小/平均单条消息大小”估算发布数量，但这种方法不如直接统计message_published_count准确，仅作为临时替代方案。

内容的提问来源于stack exchange，提问作者Mr. Techie