0

我在这里看到示例https://cloud.google.com/dataflow/model/pubsub-io#reading-with-pubsubio for 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

1

这意味着在本地（在您的机器上，即不在云中）执行管道时，当前不支持从 PubSub 读取。本地执行主要用于测试。

当您使用 Dataflow 运行程序运行时，支持 PubSub。

于 2017-04-19T04:54:33.067 回答
0

看起来它还没有准备好，因为我能够使用 Java SDK 并使用 pubsub 模拟器在本地运行它，但正如您所遇到的，不是使用 Python SDK。

于 2017-04-20T15:56:32.543 回答
0

对于 2019 年访问此问题的任何人，只要提供适当的 Google Cloud 身份验证，我可以确认 PubSub 确实可以与 DirectRunner 一起使用。

于 2019-08-07T08:09:16.900 回答