数据流管道和pubsub模拟器

Question

我正在尝试设置我的开发环境。我一直在使用pubsub模拟器进行开发和测试，而不是在生产中使用谷歌云pubsub。为此，我设置了以下环境变量：

export PUBSUB_EMULATOR_HOST=localhost:8586

这适用于python google pubsub库，但当我切换到使用java apache beam进行google数据流时，管道仍然指向生产google pubsub。管道上是否有需要设置的设置、环境变量或方法，以便管道读取本地pubsub仿真器？

Answer 1

您也可以在配置文件中指定此选项

pubsubRootUrl=http://localhost:8185

或通过程序参数（尚未测试，但也应有效）

-Dexec.args="--pubsubRootUrl=http://localhost:8185"

http:///code>需要符合Java URL格式

Answer 2

我在PubsubOptions界面中找到了解决方案，并将其扩展为我自己的PipelineOptions实现。然后使用setpubsetrooturl（）将其设置为localhost:emulator的端口。