Executar uma tarefa do Cloud Run que processa dados de eventos guardados no Cloud Storage

Pode usar os fluxos de trabalho para executar uma tarefa do Cloud Run como parte de um fluxo de trabalho que realize um processamento de dados mais complexo ou que organize um sistema de tarefas existentes.

Este tutorial demonstra como usar os fluxos de trabalho para executar uma tarefa do Cloud Run que processa dados de eventos armazenados num contentor do Cloud Storage. O armazenamento da carga útil do evento num contentor do Cloud Storage permite encriptar os dados através de chaves de encriptação geridas pelo cliente, o que não é possível se transmitir os dados do evento como variáveis de ambiente para a tarefa do Cloud Run.

O diagrama seguinte apresenta uma vista geral de nível superior:

Objetivos

Neste tutorial, vai:

1. Crie uma tarefa do Cloud Run que processe dados de eventos armazenados num contentor do Cloud Storage.
2. Implemente um fluxo de trabalho que faça o seguinte:
   1. Recebe um evento como argumento.
   2. Escreve os dados de payload do evento no contentor do Cloud Storage.
   3. Usa o conetor da API Cloud Run Admin para executar a tarefa do Cloud Run.
3. Crie um tópico do Pub/Sub para poder publicar uma mensagem no mesmo. Este tutorial usa um evento Pub/Sub como exemplo de como encaminhar eventos usando fluxos de trabalho, guardando o evento no Cloud Storage para que uma tarefa do Cloud Run possa processar os dados do evento.
4. Crie um acionador do Eventarc que execute o fluxo de trabalho quando uma mensagem for escrita no tópico do Pub/Sub.
5. Acione o fluxo de trabalho escrevendo uma mensagem no tópico do Pub/Sub.

Custos

Neste documento, usa os seguintes componentes faturáveis do Google Cloud:

• Artifact Registry
• Cloud Build
• Cloud Run
• Cloud Storage
• Eventarc
• Workflows

Para gerar uma estimativa de custos com base na sua utilização prevista, use a calculadora de preços.

Os novos Google Cloud utilizadores podem ser elegíveis para uma avaliação sem custo financeiro.

Antes de começar

As restrições de segurança definidas pela sua organização podem impedir a conclusão dos seguintes passos. Para informações de resolução de problemas, consulte o artigo Desenvolva aplicações num ambiente Google Cloud restrito.

Antes de começar este tutorial, tem de ativar APIs específicas e criar uma conta de serviço gerida pelo utilizador. Tem de conceder à conta de serviço as funções e as autorizações necessárias para poder encaminhar eventos através de um acionador do Eventarc e executar um fluxo de trabalho.

Tenha em atenção que, se estiver a usar a Cloud Shell para experimentar este tutorial, pode ter de conceder funções adicionais à conta de serviço predefinida do Compute Engine. Para ver detalhes, consulte a secção Crie uma tarefa do Cloud Run neste documento.

Consola

Sign in to your Google Cloud account. If you're new to Google Cloud, create an account to evaluate how our products perform in real-world scenarios. New customers also get $300 in free credits to run, test, and deploy workloads.

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Roles required to select or create a project

• Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
• Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.

Go to project selector

Verify that billing is enabled for your Google Cloud project.

Enable the Artifact Registry, Cloud Build, Cloud Run, Cloud Storage, Compute Engine, Eventarc, and Workflows APIs.

Roles required to enable APIs

To enable APIs, you need the Service Usage Admin IAM role (roles/serviceusage.serviceUsageAdmin), which contains the serviceusage.services.enable permission. Learn how to grant roles.

Enable the APIs

Create a service account:

1. Ensure that you have the Create Service Accounts IAM role (roles/iam.serviceAccountCreator) and the Project IAM Admin role (roles/resourcemanager.projectIamAdmin). Learn how to grant roles.

2. In the Google Cloud console, go to the Create service account page.

   Go to Create service account
3. Select your project.

4. In the Service account name field, enter a name. The Google Cloud console fills in the Service account ID field based on this name.

   In the Service account description field, enter a description. For example, Service account for quickstart.

5. Click Create and continue.

6. Grant the following roles to the service account: Cloud Run Admin, Eventarc Event Receiver, Logs Writer, Storage Object Creator, Workflows Invoker.

   To grant a role, find the Select a role list, then select the role.

   To grant additional roles, click Add another role and add each additional role.

   Note: The Role field affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later.
7. Click Continue.

8. Click Done to finish creating the service account.

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Roles required to select or create a project

• Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
• Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.

Go to project selector

Verify that billing is enabled for your Google Cloud project.

Enable the Artifact Registry, Cloud Build, Cloud Run, Cloud Storage, Compute Engine, Eventarc, and Workflows APIs.

Roles required to enable APIs

To enable APIs, you need the Service Usage Admin IAM role (roles/serviceusage.serviceUsageAdmin), which contains the serviceusage.services.enable permission. Learn how to grant roles.

Enable the APIs

Create a service account:

1. Ensure that you have the Create Service Accounts IAM role (roles/iam.serviceAccountCreator) and the Project IAM Admin role (roles/resourcemanager.projectIamAdmin). Learn how to grant roles.

2. In the Google Cloud console, go to the Create service account page.

   Go to Create service account
3. Select your project.

4. In the Service account name field, enter a name. The Google Cloud console fills in the Service account ID field based on this name.

   In the Service account description field, enter a description. For example, Service account for quickstart.

5. Click Create and continue.

6. Grant the following roles to the service account: Cloud Run Admin, Eventarc Event Receiver, Logs Writer, Storage Object Creator, Workflows Invoker.

   To grant a role, find the Select a role list, then select the role.

   To grant additional roles, click Add another role and add each additional role.

   Note: The Role field affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later.
7. Click Continue.

8. Click Done to finish creating the service account.

1. Se ativou o agente de serviço do Cloud Pub/Sub a 8 de abril de 2021 ou antes, para suportar pedidos push do Pub/Sub autenticados, conceda a função de criador de tokens de conta de serviço (roles/iam.serviceAccountTokenCreator) ao agente de serviço. Caso contrário, esta função é concedida por predefinição:
   1. Na Google Cloud consola, aceda à página IAM.
      

      Aceder ao IAM

   2. Selecione a caixa de verificação Incluir concessões de funções fornecidas pela Google.
   3. Na coluna Nome, encontre a conta de serviço do Cloud Pub/Sub e, de seguida, clique em Editar principal na linha correspondente.
   4. Clique em Adicionar função ou Adicionar outra função.
   5. Na lista Selecionar uma função, filtre por Criador de tokens de conta de serviço e, de seguida, selecione a função.
   6. Clique em Guardar.

2. In the Google Cloud console, activate Cloud Shell.

   Activate Cloud Shell

   At the bottom of the Google Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.

O Cloud Shell suporta os passos da linha de comandos neste tutorial.

gcloud

Sign in to your Google Cloud account. If you're new to Google Cloud, create an account to evaluate how our products perform in real-world scenarios. New customers also get $300 in free credits to run, test, and deploy workloads.
Install the Google Cloud CLI.
Se estiver a usar um fornecedor de identidade (IdP) externo, tem primeiro de iniciar sessão na CLI gcloud com a sua identidade federada.
Para inicializar a CLI gcloud, execute o seguinte comando:
gcloud init
Create or select a Google Cloud project.
Roles required to select or create a project
• Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
• Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.
Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.
• Create a Google Cloud project:

  gcloud projects create PROJECT_ID

  Replace PROJECT_ID with a name for the Google Cloud project you are creating.

• Select the Google Cloud project that you created:

  gcloud config set project PROJECT_ID

  Replace PROJECT_ID with your Google Cloud project name.
Verify that billing is enabled for your Google Cloud project.
Enable the Artifact Registry, Cloud Build, Cloud Run, Cloud Storage, Compute Engine, Eventarc, and Workflows APIs:
Roles required to enable APIs
To enable APIs, you need the Service Usage Admin IAM role (roles/serviceusage.serviceUsageAdmin), which contains the serviceusage.services.enable permission. Learn how to grant roles.
gcloud services enable artifactregistry.googleapis.com cloudbuild.googleapis.com compute.googleapis.com run.googleapis.com storage.googleapis.com eventarc.googleapis.com workflows.googleapis.com
Set up authentication:
1. Ensure that you have the Create Service Accounts IAM role (roles/iam.serviceAccountCreator) and the Project IAM Admin role (roles/resourcemanager.projectIamAdmin). Learn how to grant roles.

2. Create the service account:

   gcloud iam service-accounts create SERVICE_ACCOUNT_NAME

   Replace SERVICE_ACCOUNT_NAME with a name for the service account.

3. Grant roles to the service account. Run the following command once for each of the following IAM roles: roles/eventarc.eventReceiver, roles/logging.logWriter, roles/run.admin, roles/storage.objectCreator, roles/workflows.invoker :

   gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=ROLE

   Replace the following:

   • SERVICE_ACCOUNT_NAME: the name of the service account
   • PROJECT_ID: the project ID where you created the service account
   • ROLE: the role to grant
   Note: The --role flag affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later.

Install the Google Cloud CLI.

Se estiver a usar um fornecedor de identidade (IdP) externo, tem primeiro de iniciar sessão na CLI gcloud com a sua identidade federada.

Para inicializar a CLI gcloud, execute o seguinte comando:

gcloud init

Create or select a Google Cloud project.

Roles required to select or create a project

• Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
• Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

Note: If you don't plan to keep the resources that you create in this procedure, create a project instead of selecting an existing project. After you finish these steps, you can delete the project, removing all resources associated with the project.

• Create a Google Cloud project:

  gcloud projects create PROJECT_ID

  Replace PROJECT_ID with a name for the Google Cloud project you are creating.

• Select the Google Cloud project that you created:

  gcloud config set project PROJECT_ID

  Replace PROJECT_ID with your Google Cloud project name.

Verify that billing is enabled for your Google Cloud project.

Enable the Artifact Registry, Cloud Build, Cloud Run, Cloud Storage, Compute Engine, Eventarc, and Workflows APIs:

Roles required to enable APIs

To enable APIs, you need the Service Usage Admin IAM role (roles/serviceusage.serviceUsageAdmin), which contains the serviceusage.services.enable permission. Learn how to grant roles.

gcloud services enable artifactregistry.googleapis.com cloudbuild.googleapis.com compute.googleapis.com run.googleapis.com storage.googleapis.com eventarc.googleapis.com workflows.googleapis.com

Set up authentication:

1. Ensure that you have the Create Service Accounts IAM role (roles/iam.serviceAccountCreator) and the Project IAM Admin role (roles/resourcemanager.projectIamAdmin). Learn how to grant roles.

2. Create the service account:

   gcloud iam service-accounts create SERVICE_ACCOUNT_NAME

   Replace SERVICE_ACCOUNT_NAME with a name for the service account.

3. Grant roles to the service account. Run the following command once for each of the following IAM roles: roles/eventarc.eventReceiver, roles/logging.logWriter, roles/run.admin, roles/storage.objectCreator, roles/workflows.invoker :

   gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=ROLE

   Replace the following:

   • SERVICE_ACCOUNT_NAME: the name of the service account
   • PROJECT_ID: the project ID where you created the service account
   • ROLE: the role to grant
   Note: The --role flag affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later.
1. Se ativou o agente do serviço Cloud Pub/Sub a 8 de abril de 2021 ou antes, para suportar pedidos de envio autenticados do Pub/Sub, conceda a função de criador de tokens de conta de serviço (roles/iam.serviceAccountTokenCreator) ao agente do serviço. Caso contrário, esta função é concedida por predefinição:

   gcloud projects add-iam-policy-binding PROJECT_ID \
       --member=serviceAccount:[e-mail] \
       --role=roles/iam.serviceAccountTokenCreator

Substitua PROJECT_NUMBER pelo seu Google Cloud número do projeto. Pode encontrar o número do projeto na página Boas-vindas da Google Cloud consola ou executando o seguinte comando:

gcloud projects describe PROJECT_ID --format='value(projectNumber)'

Crie uma tarefa do Cloud Run

Este tutorial usa código de exemplo que pode encontrar no GitHub. O script de implementação cria uma imagem de contentor para criar uma tarefa do Cloud Run denominada message-payload-job.

O script também cria um contentor do Cloud Storage e gera um identificador único universal (UUID) para o respetivo nome através do uuidgen, uma utilidade que é frequentemente instalada no Linux, macOS e Windows.

A tarefa do Cloud Run lê quaisquer dados de eventos armazenados no contentor do Cloud Storage e, em seguida, imprime os dados de eventos.

Nota: se receber a mensagem "bucket already exists" (o contentor já existe), certifique-se de que a propriedade do contentor e as respetivas autorizações estão configuradas conforme esperado antes de continuar.

1. Se estiver a executar o script de implementação no Cloud Shell e se a conta de serviço predefinida do Compute Engine não tiver a função de Editor, conceda as seguintes funções no projeto à conta de serviço predefinida do Compute Engine. (Caso contrário, pode ignorar este passo e continuar com a clonagem do repositório da app de exemplo no passo seguinte.)

   Nota: a restrição da política da organização iam.automaticIamGrantsForDefaultServiceAccounts impede que a função Editor seja concedida automaticamente às contas de serviço predefinidas. Se tiver criado a sua organização após 3 de maio de 2024, esta restrição é aplicada por predefinição.

   1. Conceda a função de escritor do Artifact Registry (roles/artifactregistry.writer):

      gcloud projects add-iam-policy-binding PROJECT_ID \
          --member=serviceAccount:[e-mail] \
          --role=roles/artifactregistry.writer

      Substitua PROJECT_NUMBER pelo seu Google Cloud número do projeto. Pode encontrar o número do projeto na página Boas-vindas da Google Cloud consola ou executando o seguinte comando:

      gcloud projects describe PROJECT_ID --format='value(projectNumber)'

   2. Conceda a função de utilizador do objeto de armazenamento (roles/storage.objectUser):

      gcloud projects add-iam-policy-binding PROJECT_ID \
          --member=serviceAccount:[e-mail] \
          --role=roles/storage.objectUser

   3. Conceda a função Logging Logs Writer (roles/logging.logWriter):

      gcloud projects add-iam-policy-binding PROJECT_ID \
          --member=serviceAccount:[e-mail] \
          --role=roles/logging.logWriter

2. Obtenha o exemplo de código clonando o repositório da app de exemplo para o seu computador local:

   git clone https://github.com/GoogleCloudPlatform/workflows-demos.git

   Em alternativa, pode transferir o exemplo como um ficheiro ZIP.

3. Altere para o diretório que contém o código de exemplo:

   cd workflows-demos/cloud-run-jobs-payload-gcs/message-payload-job

4. Crie a tarefa do Cloud Run executando o script de implementação:

   ./deploy-job.sh

   O resultado deve ser semelhante ao seguinte:

   STATUS: SUCCESS
   Creating input bucket message-payload-UNIQUE_ID
   ...
   Creating Cloud Run job [message-payload-job] in project [PROJECT_ID] region [us-central1]
   Creating job...
   Done.
   Job [message-payload-job] has successfully been created.
   

   Tenha em atenção o UUID gerado para o nome do contentor do Cloud Storage. Vai precisar deste identificador quando implementar o fluxo de trabalho.

Implemente um fluxo de trabalho que execute a tarefa do Cloud Run

Defina e implemente um fluxo de trabalho que execute a tarefa do Cloud Run que acabou de criar. Uma definição de fluxo de trabalho é composta por uma série de passos descritos através da sintaxe dos fluxos de trabalho.

O fluxo de trabalho recebe um evento, guarda os dados do evento num contentor do Cloud Storage e, em seguida, executa uma tarefa do Cloud Run para processar os dados do evento.

Consola

1. Na Google Cloud consola, aceda à página Fluxos de trabalho:

   Aceder a Fluxos de trabalho

2. Clique em Criar.

3. Introduza um nome para o novo fluxo de trabalho, como message-payload-workflow.

4. Escolha uma região adequada; por exemplo, us-central1.

5. No campo Conta de serviço, selecione a conta de serviço que criou anteriormente.

   A conta de serviço funciona como a identidade do fluxo de trabalho. Já deve ter concedido as seguintes funções à conta de serviço:

   • Administrador do Cloud Run: para executar tarefas do Cloud Run
   • Escritor de registos: para escrever entradas de registo
   • Storage Object Creator: para criar objetos no Cloud Storage

6. Clicar em Seguinte.

7. No editor de fluxos de trabalho, introduza a seguinte definição para o seu fluxo de trabalho:

   main:
       params: [event]
       steps:
           - init:
               assign:
                   - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
                   - event_bucket: message-payload-UNIQUE_ID
                   - event_file: ${event.id + ".data.json"}
                   - job_name: message-payload-job
                   - job_location: us-central1
           - log_event:
               call: sys.log
               args:
                   data: ${event}
           - write_payload_to_gcs:
               call: http.post
               args:
                   url: ${"https://storage.googleapis.com/upload/storage/v1/b/" + event_bucket + "/o"}
                   auth:
                       type: OAuth2
                   query:
                       name: ${event_file}
                   body:
                       ${event.data}
           - run_job_to_process_payload:
               call: googleapis.run.v1.namespaces.jobs.run
               args:
                   name: ${"namespaces/" + project_id + "/jobs/" + job_name}
                   location: ${job_location}
                   body:
                       overrides:
                           containerOverrides:
                               env:
                                   - name: INPUT_BUCKET
                                     value: ${event_bucket}
                                   - name: INPUT_FILE
                                     value: ${event_file}
               result: job_execution
           - finish:
               return: ${job_execution}

   Substitua UNIQUE_ID pelo UUID gerado para o nome do contentor do Cloud Storage e que anotou anteriormente.

8. Clique em Implementar.

gcloud

1. Crie um ficheiro de código-fonte para o seu fluxo de trabalho:

   touch message-payload-workflow.yaml

2. Copie a seguinte definição do fluxo de trabalho para message-payload-workflow.yaml:

   main:
       params: [event]
       steps:
           - init:
               assign:
                   - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
                   - event_bucket: message-payload-UNIQUE_ID
                   - event_file: ${event.id + ".data.json"}
                   - job_name: message-payload-job
                   - job_location: us-central1
           - log_event:
               call: sys.log
               args:
                   data: ${event}
           - write_payload_to_gcs:
               call: http.post
               args:
                   url: ${"https://storage.googleapis.com/upload/storage/v1/b/" + event_bucket + "/o"}
                   auth:
                       type: OAuth2
                   query:
                       name: ${event_file}
                   body:
                       ${event.data}
           - run_job_to_process_payload:
               call: googleapis.run.v1.namespaces.jobs.run
               args:
                   name: ${"namespaces/" + project_id + "/jobs/" + job_name}
                   location: ${job_location}
                   body:
                       overrides:
                           containerOverrides:
                               env:
                                   - name: INPUT_BUCKET
                                     value: ${event_bucket}
                                   - name: INPUT_FILE
                                     value: ${event_file}
               result: job_execution
           - finish:
               return: ${job_execution}

   Substitua UNIQUE_ID pelo UUID gerado para o nome do contentor do Cloud Storage e que anotou anteriormente.

3. Implemente o fluxo de trabalho introduzindo o seguinte comando:

   gcloud workflows deploy message-payload-workflow \
       --location=us-central1 \
       --source=message-payload-workflow.yaml \
       --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com

   Substitua o seguinte:

   • SERVICE_ACCOUNT_NAME: o nome da conta de serviço que criou anteriormente
   • PROJECT_ID: o ID do seu Google Cloud projeto

   A conta de serviço funciona como a identidade do fluxo de trabalho. Já deve ter concedido as seguintes funções à conta de serviço:

   • roles/logging.logWriter: para escrever entradas do registo
   • roles/run.admin: para executar tarefas do Cloud Run
   • roles/storage.objectCreator: para criar objetos no Cloud Storage

O fluxo de trabalho faz o seguinte:

1. init passo: aceita um evento como argumento e define as variáveis necessárias.

2. log_event passo: cria uma entrada de registo no Cloud Logging através da função sys.log.

3. write_payload_to_gcs passo: faz um pedido HTTP POST e escreve os dados de carga útil do evento num ficheiro do contentor do Cloud Storage.

4. run_job_to_process_payload passo: usa o método do conetor da Cloud Run Admin API, googleapis.run.v1.namespaces.jobs.run, para executar a tarefa. O contentor do Cloud Storage e o nome do ficheiro de dados são transmitidos como variáveis de substituição do fluxo de trabalho para a tarefa.

5. finish passo: devolve informações sobre a execução da tarefa como resultado do fluxo de trabalho.

Crie um tópico do Pub/Sub

Crie um tópico Pub/Sub para poder publicar uma mensagem no mesmo. Um evento do Pub/Sub é usado para demonstrar como encaminhar um evento usando fluxos de trabalho e guardar o evento no Cloud Storage para que uma tarefa do Cloud Run possa processar os dados do evento.

Consola

1. Na Google Cloud consola, aceda à página Tópicos.

   Aceder a Tópicos

2. Clique em Criar tópico.

3. No campo ID do tópico, introduza um ID para o tópico, como message-payload-topic.

4. Manter a opção Adicionar uma subscrição predefinida.

5. Não selecione as outras opções.

6. Clique em Criar.

gcloud

Para criar um tópico com o ID message-payload-topic, execute o comando gcloud pubsub topics create:

gcloud pubsub topics create message-payload-topic

Crie um acionador do Eventarc para encaminhar eventos para o fluxo de trabalho

Para executar automaticamente o fluxo de trabalho e, por sua vez, a tarefa do Cloud Run, crie um acionador do Eventarc que responda a eventos do Pub/Sub e que encaminhe os eventos para o fluxo de trabalho. Sempre que uma mensagem é escrita no tópico Pub/Sub, o evento aciona uma execução do fluxo de trabalho.

Consola

1. Na Google Cloud consola, aceda à página Fluxos de trabalho:

   Aceder a Fluxos de trabalho

2. Clique no nome do fluxo de trabalho, como message-payload-workflow.

3. Na página Detalhes do fluxo de trabalho, clique em Editar.

4. Na página Editar fluxo de trabalho, na secção Acionadores, clique em Adicionar novo acionador > Eventarc.

   É aberto o painel Acionador do Eventarc.

5. No campo Nome do acionador, introduza um nome para o acionador, como message-payload-trigger.

6. Na lista Fornecedor de eventos, selecione Cloud Pub/Sub.

7. Na lista Evento, selecione google.cloud.pubsub.topic.v1.messagePublished.

8. Na lista Selecionar um tópico do Cloud Pub/Sub, selecione o tópico do Pub/Sub que criou anteriormente.

9. No campo Conta de serviço, selecione a conta de serviço que criou anteriormente.

   A conta de serviço funciona como a identidade do acionador. Já deve ter concedido as seguintes funções à conta de serviço:

   • Eventarc Event Receiver: para receber eventos
   • Workflows Invoker: para executar fluxos de trabalho

10. Clique em Guardar acionador.

    O acionador do Eventarc aparece agora na secção Acionadores na página Editar fluxo de trabalho.

11. Clicar em Seguinte.

12. Clique em Implementar.

gcloud

Crie um acionador do Eventarc executando o seguinte comando:

gcloud eventarc triggers create message-payload-trigger \
    --location=us-central1 \
    --destination-workflow=message-payload-workflow \
    --destination-workflow-location=us-central1 \
    --event-filters="type=google.cloud.pubsub.topic.v1.messagePublished" \
    --transport-topic=projects/PROJECT_ID/topics/message-payload-topic \
    --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com

Substitua o seguinte:

• PROJECT_ID: o ID do seu Google Cloud projeto
• SERVICE_ACCOUNT_NAME: o nome da conta de serviço que criou anteriormente.

A conta de serviço funciona como a identidade do acionador. Já deve ter concedido as seguintes funções à conta de serviço:

• roles/eventarc.eventReceiver: para receber eventos
• roles/workflows.invoker: para executar fluxos de trabalho

Acione o fluxo de trabalho

Teste o sistema ponto a ponto publicando uma mensagem no tópico do Pub/Sub e gerando um evento. Para mais informações, consulte o artigo sobre como acionar um fluxo de trabalho com eventos ou mensagens do Pub/Sub.

1. Publique uma mensagem no tópico Pub/Sub para gerar um evento:

   gcloud pubsub topics publish message-payload-topic --message="Hello World"
   

   O evento é encaminhado para o fluxo de trabalho que regista a mensagem de evento, guarda os dados de eventos no contentor do Cloud Storage e executa a tarefa do Cloud Run para processar os dados guardados no Cloud Storage. Este processo pode demorar alguns minutos.

2. Confirme se a tarefa do Cloud Run foi executada conforme esperado, consultando as execuções da tarefa:

   gcloud run jobs executions list --job=message-payload-job

   Deverá ver uma nova execução de tarefa na saída.

3. Pode confirmar se os resultados são os esperados ao ver os dados de eventos no objeto do contentor do Cloud Storage.

   1. Recupere o nome do contentor:

      gcloud storage ls

      O resultado é semelhante ao seguinte:

      gs://message-payload-UNIQUE_ID/

   2. Liste os objetos no seu contentor:

      gcloud storage ls gs://message-payload-UNIQUE_ID/** --recursive

      O resultado deve ser semelhante ao seguinte:

      gs://message-payload-UNIQUE_ID/OBJECT_ID.data.json

      Tome nota do OBJECT_ID para usar no passo seguinte.

   3. Transfira o objeto no seu contentor como um ficheiro:

      gcloud storage cp gs://message-payload-UNIQUE_ID/OBJECT_ID.data.json message-event.txt

      Substitua OBJECT_ID pelo ID devolvido no passo anterior.

   4. Num editor de texto, abra o ficheiro message-event.txt. O corpo do evento escrito no ficheiro deve ser semelhante ao seguinte:

      {
        "message": {
          "data": "SGVsbG8gV29ybGQ=",
          "messageId": "8254002311197919",
          "publishTime": "2023-09-20T16:54:29.312Z"
        },
        "subscription": "projects/MY_PROJECT/subscriptions/eventarc-us-central1-message-payload-trigger-sub-741"
      }
      

      Tenha em atenção que, se descodificar o valor de dados de SGVsbG8gV29ybGQ= do respetivo formato Base64, é devolvido "Hello World".

Limpar

Se criou um novo projeto para este tutorial, elimine o projeto. Se usou um projeto existente e quer mantê-lo sem as alterações adicionadas neste tutorial, elimine os recursos criados para o tutorial.

Elimine o projeto

A forma mais fácil de eliminar a faturação é eliminar o projeto que criou para o tutorial.

Para eliminar o projeto:

Atenção: a eliminação de um projeto tem os seguintes efeitos:

• Tudo no projeto é eliminado. Se usou um projeto existente para as tarefas neste documento, quando o elimina, também elimina qualquer outro trabalho que tenha feito no projeto.
• Os IDs dos projetos personalizados são perdidos. Quando criou este projeto, pode ter criado um ID do projeto personalizado que quer usar no futuro. Para preservar os URLs que usam o ID do projeto, como um URL appspot.com, elimine os recursos selecionados no projeto em vez de eliminar o projeto inteiro.

Se planeia explorar várias arquiteturas, tutoriais ou inícios rápidos, a reutilização de projetos pode ajudar a evitar exceder os limites de quota de projetos.

1. In the Google Cloud console, go to the Manage resources page.

   Go to Manage resources

2. In the project list, select the project that you want to delete, and then click Delete.
3. In the dialog, type the project ID, and then click Shut down to delete the project.

Elimine recursos de tutoriais

Elimine os recursos que criou neste tutorial:

1. Elimine o tópico do Pub/Sub.

2. Elimine o acionador do Eventarc.

3. Elimine o fluxo de trabalho Workflows.

4. Elimine a tarefa do Cloud Run.

5. Elimine o contentor do Cloud Storage.

O que se segue?

• Saiba mais sobre as tarefas do Cloud Run.
• Saiba mais sobre os conetores do Workflows.
• Saiba mais sobre os fluxos de trabalho.

Envie comentários