gpt4 book ai didi

java - 数据流管道和发布订阅模拟器

转载 作者:搜寻专家 更新时间:2023-11-01 01:49:45 24 4
gpt4 key购买 nike

我正在尝试设置我的开发环境。我没有在生产中使用 google cloud pubsub,而是一直在使用 pubsub 模拟器进行开发和测试。为此,我设置了以下环境变量:

export PUBSUB_EMULATOR_HOST=localhost:8586

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

最佳答案

我在 PubsubOptions 接口(interface)中找到了解决方案,并将其扩展为我自己的 PipelineOptions 实现。然后使用 setPubsubRootUrl() 将其设置为模拟器的 localhost:port。

关于java - 数据流管道和发布订阅模拟器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43354599/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com