Есть ли способ прочитать идентификатор сообщения Google Pubsub сообщения с помощью Apache Beam - PullRequest
0 голосов
/ 21 января 2019

Привет. Я пытаюсь получить сообщения из pubsub с помощью луча apache.

PubsubIO.readMessagesWithAttributes().fromSubscription(myTopic)

И я пытаюсь вставить полезную нагрузку в большой запрос.Я хочу получить идентификатор сообщения, сгенерированного pubsub.

Но я не могу его получить, атрибуты также не имеют идентификатора сообщения.

Любая помощь приветствуется.

1 Ответ

0 голосов
/ 21 января 2019

Это проблема на данный момент и в настоящее время отслеживается под этим https://issues.apache.org/jira/browse/BEAM-3489

Мы преодолели это, сгенерировав UUID и сохранив сообщение в BQ.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...