Согласно тому, что я читал о DataFlow, источник данных Pub / Sub предоставляет только тело сообщения для работы в конвейере. У нас есть вариант использования, когда мы хотим проверить атрибуты сообщения, чтобы принять определенные решения. Есть ли какой-нибудь способ достичь этого в настоящее время? Я открыт для расширения ввода-вывода Pub / Sub, чтобы включить это в случае необходимости.
Доступ к атрибутам сообщений Cloud Pub / Sub в Cloud DataFlow
Ответы (1)
В настоящее время нет возможности получить доступ к атрибутам сообщений ваших сообщений через коннектор PubsubIO, но, безусловно, было бы полезно сделать это. Это отслеживается в Apache Beam (инкубация) как проблема BEAM-404.
Рекомендую следить за этим выпуском, чтобы быть в курсе новых событий.
person
Kenn Knowles
schedule
12.05.2016
Доступ к атрибутам сообщения через
PubsubIO по-прежнему не поддерживается?
- person dina; 03.11.2016
Теперь он явно отслеживается как BEAM-404. Я обновлю свой ответ.
- person Kenn Knowles; 04.11.2016
