我已经使用Google Cloud Dataflow SDK编写了流式传输管道，但是我想在本地测试管道。我的管道从Google Pub / Sub获取输入数据。
是否可以运行使用DirectPipelineRunner（本地执行，不在Google Cloud中）访问Pub / Sub（pubsubIO）的作业？
以我的普通用户帐户登录时，我遇到权限问题。我是该项目的所有者，并且正在尝试访问pub / sub主题。
DirectPipelineRunner当前不支持PubsubIO。在本地使用时，您将收到一条错误消息，指出“没有为PubsubIO.Read注册评估器”。
您的权限问题可能来自其他来源。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句