如何以编程方式在apachebeampython中提供凭证？

Question

我们使用阿帕奇光束通过气流。使用环境变量-GOOGLE_APPLICATION_CREDENTIALS设置默认GCS帐户。我们不想改变环境变量，因为它可能会影响其他进程在那个时候运行。我找不到以编程方式更改Google云数据流服务帐户的方法。 我们按照以下方式创建管道 p=横梁。管道（argv）=自我确认)在

有没有通过argv或options的选项，在这里我可以提到gcs凭证文件的位置？ 搜索了文档，但没有找到太多信息。在

Answer 1

启动带有基本标志的作业时，可以指定服务帐户： serviceAccount=my-service-account-name@my-project.iam.gserviceaccount.com

该帐户将需要附加Dataflow Worker角色以及您想要的任何其他角色（GCS/BQ/Etc）。Details here。您不需要将SA存储在GCS中，也不需要本地密钥来使用它。在