python - 如何以编程方式在 apache beam python 中提供凭据？

Question

我们通过 Airflow 使用 Apache Beam。默认 GCS 帐户设置有环境变量 - GOOGLE_APPLICATION_CREDENTIALS。我们不想更改环境变量，因为它可能会影响当时正在运行的其他进程。我找不到以编程方式更改 Google Cloud Dataflow 服务帐户的方法。我们正在通过以下方式创建管道p = beam.Pipeline(argv=self.conf)

是否有通过 argv 或选项的任何选项，我可以在其中提及 gcs 凭证文件的位置？搜索了文档，但没有找到太多信息。

Answer 1

您可以在使用基本标志启 Action 业时指定服务帐户:--serviceAccount=my-service-account-name@my-project.iam.gserviceaccount.com

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