PubSub にトピックがあり、トピックから読み取り、メッセージ データに従ってそれらを分類し、さらに属性キーと値のペアを読み取るデータフローのパイプラインを作成したいと考えています。PubSubIO の read 変換を使用して PCollection に変換した後、メッセージと属性を区別する方法はありますか?
質問する
823 次
1 に答える
1
残念ながら、Dataflow の PubsubIO API は現在、Pubsub メッセージのメタデータと属性を処理していません。簡単な回避策は思いつきません。
これは、私たちがすぐに改善することを目指しているものです。この作品はBEAM-53として追跡されています。最新の状況はこちらでご確認ください。
于 2016-03-22T15:13:28.917 に答える