問題タブ [apache-beam-io]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

444 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
3 に答える
1123 参照

google-cloud-dataflow - apache beam python sdk を使って PubSub でトランスフォームを読み書きする例

ここに例がありますhttps://cloud.google.com/dataflow/model/pubsub-io#reading-with-pubsubio Java用ですが、ここを見るとhttps://github.com/apache/beam/blob/master /sdks/python/apache_beam/io/gcp/pubsub.pyは次のように述べています。

どういう意味ですか？Cloud Data Flow Python SDK PubSub Source/Sink の準備が整っていませんか?

0 投票する
1 に答える
1643 参照

java - Apache Beam で Google Pub/Sub メッセージを確認する

次のコードで pub/sub から読み込もうとしています

NodeJS で受け取るものと比較すると、dataフィールドに含まれるメッセージが表示されます。フィールドを取得するにはどうすればよいですかackId(後でメッセージを確認するために使用できます)。私が印刷している属性マップはnull. ackId を把握せずにすべてのメッセージを確認する他の方法はありますか?


12345678910