如何追踪GCP PubSub消息ID后续状态？含订阅者与BigQuery验证

发布消息到GCP Pub/Sub主题后，会收到包含消息ID的响应：

{
  "messageIds": [
    "6113243608857025"
  ]
}

a) 确认消息ID对应的消息是否送达指定订阅者 #

• 命令行拉取验证：使用gcloud命令直接从目标订阅拉取并过滤指定消息ID：

  gcloud pubsub subscriptions pull <订阅名称> --filter="messageId='6113243608857025'" --limit=10
  

  如果消息已被订阅者确认（ACK），需添加--include-acknowledged参数才能返回已处理的消息：

  gcloud pubsub subscriptions pull <订阅名称> --filter="messageId='6113243608857025'" --include-acknowledged --limit=10
  

  能返回匹配结果则说明消息已送达该订阅。
• 订阅者日志核查：若订阅者是自研服务，直接查询服务日志中记录的消息ID，匹配到则表示消息已被接收处理。
• 监控指标辅助判断：在GCP控制台或Cloud Monitoring中，查看目标订阅的num_undelivered_messages指标，若该指标未包含对应消息（结合发布时间范围），可辅助判断消息已送达，但无法精准定位单个ID。

b) 确认消息ID对应的消息是否送达BigQuery（BigQuery投递订阅） #

• 直接查询BigQuery表：Pub/Sub投递到BigQuery时，会自动将消息ID存入attributes.pubsub_message_id字段（默认 schema），执行SQL查询验证：

  SELECT * FROM `<项目ID>.<数据集ID>.<目标表名>` 
  WHERE attributes.pubsub_message_id = '6113243608857025'
  

  返回结果则说明消息已成功写入BigQuery。
• 投递日志验证：在GCP控制台的Pub/Sub订阅页面切换到「日志」标签，过滤日志内容中的messageId="6113243608857025"，若存在包含Successfully inserted rows into BigQuery的日志条目，则表示投递成功。
• 投递指标辅助：在Cloud Monitoring中查看订阅的bigquery/delivery_success_count指标，结合发布时间范围判断投递情况，但需配合日志或表查询精准定位单个消息ID。

内容的提问来源于stack exchange，提问作者toinbis