2016-03-22 14 views
2

PubSub ile ilgili bir konuğum var ve konudan okuyan veri mesajında ​​bir boru hattı oluşturmak istiyorum. Bunları mesaj verilerine göre sınıflandırıyor ve özellik anahtarı değer çiftlerini okuyor. PubSubIO'nun okuma dönüşümü kullanılarak PCollection'a dönüştürüldükten sonra mesaj ve öznitelikleri birbirinden ayırmanın bir yolu var mı?PubSubIO'dan iletiyi ve isteğe bağlı özellikleri nasıl alırsınız?

cevap

1

Ne yazık ki, Dataflow'un PubsubIO API'sı Pubsub iletilerinin meta verilerini ve öznitelikleriyle ilgilenmiyor. Kolay bir çözüm düşünemiyorum.

Bu, yakında geliştirmeyi düşündüğümüz bir şeydir. Bu çalışma BEAM-53 olarak izlenir. En son durum için lütfen kontrol edin.

+0

Teşekkür ederiz. Bu oldukça yardımcı oldu. – alpheus

+1

En son Apache Beam PubSub IO'da getAttributeMap ve getAttribute kullanarak mesajın öznitelik listesini alabilirsiniz. Https://beam.apache.org/documentation/sdks/javadoc/0.6.0/org/apache/beam/sdk/io/PubsubIO.PubsubMessage.html#getAttribute-java.lang.String- sayfasına bakın. –