Google Cloud - 如何从远程 PubSub 获取数据作为本地执行的 Apache Beam Pipeline 的输入？
Google Cloud - How to get data from remote PubSub as input for Apache Beam Pipeline executing locally?
我已经按照官方 doc 配置了一个本地 (java) 环境来执行 Apache Beam Pipeline。
示例项目 (WordCount) 运行良好，但现在我想更改它并从 PubSub 主题获取输入数据并将输出放入 BigQuery。
我已经创建了我的 PubSub 主题和我的 BigQuery 数据集，但我的问题是：如何配置 REMOTE 输入（pubsub 主题）和输出（BigQuery）本地 运行 管道（用于调试目的）？
参见 类 PubsubIO / PubsubClient
（或 com.google.cloud.pubsub.v1）。
对于远程访问，您很可能需要注册一个外部 IP。
我已经按照官方 doc 配置了一个本地 (java) 环境来执行 Apache Beam Pipeline。
示例项目 (WordCount) 运行良好，但现在我想更改它并从 PubSub 主题获取输入数据并将输出放入 BigQuery。
我已经创建了我的 PubSub 主题和我的 BigQuery 数据集，但我的问题是：如何配置 REMOTE 输入（pubsub 主题）和输出（BigQuery）本地 运行 管道（用于调试目的）？
参见 类 PubsubIO / PubsubClient （或 com.google.cloud.pubsub.v1）。
对于远程访问，您很可能需要注册一个外部 IP。