0

ここに例があります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は次のように述べています。

def reader(self):
    raise NotImplementedError(
        'PubSubSource is not supported in local execution.')

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

4

3 に答える 3

0

Java SDK と pubsub エミュレーターを使用してローカルで実行できたので、まだ準備ができていないように見えますが、Python SDK では実行できませんでした。

于 2017-04-20T15:56:32.543 に答える