Рабочий процесс не выполнен.Причины: не удалось обновить ваши учетные данные

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.

И я создал служебную учетную запись и разрешения в рамках проекта.

Сервисный аккаунт

, поэтому я до сих пор не могу определить эту ошибку.Я отключил Dataflow API и повторно активировал и все еще ничего.Или, если возможно восстановить эту учетную запись службы для выполнения задания?

С уважением

Answer 1

Добавьте адрес электронной почты учетной записи службы в service_account_email опцию ваших PipelineOptions.

 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             = "etldemo@etldemo-000000.iam.gserviceaccount.com"
      options.view_as( StandardOptions ).runner     = 'DataflowRunner'

      return options