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?
2
A
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.
İlgili konular
- 1. Varsayılan ve isteğe bağlı argümanlar nasıl alınır?
- 2. Ninj. İsteğe Bağlı Enjeksiyon
- 3. Çift isteğe bağlı nasıl açılır?
- 4. Linq isteğe bağlı parametreler
- 5. İsteğe bağlı (nil)
- 6. Verilen isteğe bağlı koleksiyon
- 7. İsteğe bağlı özellik
- 8. Hızlı isteğe bağlı bağlantıya sahip isteğe bağlı birleştirme hala
- 9. Swift 2.2 isteğe bağlı/isteğe bağlı istekleri keser
- 10. Regex isteğe bağlı tırnak
- 11. İsteğe Bağlı PORTlar?
- 12. isteğe bağlı parametreler proc?
- 13. Şemada isteğe bağlı argümanlar ve noktalar
- 14. Swift: İsteğe bağlı değişken
- 15. Yöntem Geçersiz Kılma ve İsteğe Bağlı Parametreler
- 16. Salatalıkta isteğe bağlı parametre
- 17. Raylar, isteğe bağlı parametreler
- 18. İsteğe bağlı .NULL yap ve yöntem zincirleme
- 19. NoUIslider - İsteğe bağlı güncelleştirme aralığı
- 20. TimeSpan BiçimString İsteğe bağlı saatlerde
- 21. Perl6 isteğe bağlı işlev bayrakları
- 22. Regexp pattern İsteğe bağlı karakter
- 23. MATLAB işlevlerinde isteğe bağlı hatalar
- 24. İsteğe bağlı [Zorunlu] karmaşık türlerde
- 25. C# bu parametreler isteğe bağlı
- 26. Makroya isteğe bağlı değişken ekleme
- 27. RestKit RKObjectMapping Swift İsteğe Bağlı
- 28. initializer_list ile isteğe bağlı yapıcı
- 29. İsteğe bağlı eşanlamlılık Swift'de nasıl çalışır?
- 30. Log4net.dll'yi isteğe bağlı olarak nasıl yapabilirim?
Teşekkür ederiz. Bu oldukça yardımcı oldu. – alpheus
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. –