工作流失败。原因：刷新凭据时出现问题

Question

我有一个数据流问题，我需要执行一个作业，我得到以下错误：

Workflow failed. Causes: There was a problem refreshing your credentials. Please check:
1. Dataflow API is enabled for your project.
2. There is a robot service account for your project:
service-[project number]@dataflow-service-producer-prod.iam.gserviceaccount.com should have access to your project. If this account does not appear in the permissions tab for your project, contact Dataflow support.

并且我已经在项目中创建了服务帐户和许可证。

问候

Answer 1

将服务帐户电子邮件添加到PipelineOptions的service_account_email选项中。

 def get_pipeline_options(self):
      options = PipelineOptions( )

      gcp_options                                   = options.view_as( GoogleCloudOptions )
      gcp_options.job_name                          = "sampleflow"
      gcp_options.project                           = "etldemo-000000"
      gcp_options.staging_location                  = "gs://<bucket name>/stage"
      gcp_options.temp_location                     = "gs://<bucket name>/tmp"
      gcp_options.service_account_email             = "[e-mail]"
      options.view_as( StandardOptions ).runner     = 'DataflowRunner'

      return options