Google Cloud - 如何从远程PubSub获取数据作为Apache Beam Pipeline在本地执行的输入？

Question

我已经在官方doc之后配置了一个本地（java）环境来执行Apache Beam Pipeline。

示例项目（WordCount）工作正常，但现在我想更改它并从PubSub主题获取输入数据并将输出放到BigQuery。

我已经创建了我的PubSub主题和我的BigQuery数据集，但我的问题是：如何为本地运行的管道配置REMOTE输入（pubsub主题）和输出（BigQuery）（用于调试目的）？

Answer 1

参见类PubsubIO / PubsubClient（或com.google.cloud.pubsub.v1）。

对于远程访问，您很可能需要注册外部IP。