有没有办法使用 apache Beam 读取 google pubsub 消息的消息 ID答案

【问题标题】：Is there way to read the message id of a google pubsub message using apache beam有没有办法使用 apache Beam 读取 google pubsub 消息的消息 ID
【发布时间】：2019-01-21 12:55:36
【问题描述】：

您好，我正在尝试使用 apache 梁从 pubsub 中提取消息

PubsubIO.readMessagesWithAttributes().fromSubscription(myTopic)

我正在尝试将有效负载插入到 bigquery。我想检索 pubsub 将生成的消息 ID。

但我无法得到它，属性也没有消息ID。

感谢任何帮助。

【问题讨论】：

标签： java google-cloud-platform google-cloud-dataflow apache-beam google-cloud-pubsub

【解决方案1】：

到目前为止，这是一个问题，目前在此下进行跟踪 https://issues.apache.org/jira/browse/BEAM-3489

我们通过生成 UUID 并将消息存储在 BQ 中克服了这个问题。

【讨论】：