Cloud DataFlowのCloud Pub/Sub Message属性へのアクセス

Question

私がDataFlowを読んだところによると、Pub/Subデータソースはパイプラインで動作するメッセージ本体のみを提供します。特定の決定を下すためにメッセージの属性を検査するユースケースがあります。これを達成する方法はありますか？私はPub/Sub I/Oを拡張して、必要に応じてこれを組み込むようにしています。

Answer 1

現在のところ、メッセージのメッセージ属性にはPubsubIOコネクタを介してアクセスする方法はありませんが、そうすることは明らかに便利です。これは、問題としてApache Beam（インキュベート中）で追跡されますBEAM-404。

新しい開発状況を把握するために、この問題に従うことをおすすめします。