Neste tutorial, mostramos como criar e executar um fluxo de trabalho pai que executa vários fluxos de trabalho filhos em paralelo.
No diagrama a seguir, quatro execuções paralelas do fluxo de trabalho filho são invocadas. Isso permite que o fluxo de trabalho pai processe dados em ramificações paralelas e reduz o tempo geral de execução. O fluxo de trabalho pai aguarda a conclusão de todas as execuções do fluxo de trabalho filho antes de retornar um resumo das execuções bem-sucedidas e com falha, simplificando qualquer detecção de erros.
Objetivos
Neste tutorial, você aprenderá a:
- Criar e implantar um fluxo de trabalho filho que recebe dados de um fluxo pai.
- Criar e implantar um fluxo de trabalho pai que execute vários fluxos de trabalho filhos
usando uma repetição
for
paralela. - executar o fluxo de trabalho pai, que invoca execuções paralelas do filho.
- Os resultados de todas as execuções bem-sucedidas e com falha do fluxo de trabalho filho são armazenados e retornados em um mapa.
É possível executar os comandos a seguir no console do Google Cloud ou usando a Google Cloud CLI no seu terminal ou no Cloud Shell.
Custos
Neste documento, você usará os seguintes componentes faturáveis do Google Cloud:
Para gerar uma estimativa de custo baseada na projeção de uso deste tutorial, use a calculadora de preços.
Antes de começar
As restrições de segurança definidas pela sua organização podem impedir que você conclua as etapas a seguir. Para informações sobre solução de problemas, consulte Desenvolver aplicativos em um ambiente restrito do Google Cloud.
Console
-
Faça login na sua Conta do Google.
Se você ainda não tiver uma, inscreva-se agora.
-
No console do Google Cloud, na página do seletor de projetos, selecione ou crie um projeto do Google Cloud.
-
Verifique se a cobrança está ativada para o seu projeto do Google Cloud.
-
Ative as APIs Workflow Executions and Workflows.
-
Crie uma conta de serviço:
-
No Console do Google Cloud, acesse a página Criar conta de serviço.
Acesse "Criar conta de serviço" - Selecione o projeto.
-
No campo Nome da conta de serviço, insira um nome. O Console do Google Cloud preenche o campo ID da conta de serviço com base nesse nome.
No campo Descrição da conta de serviço, insira uma descrição. Por exemplo,
Service account for quickstart
. - Clique em Criar e continuar.
-
Conceda o papel Workflows > Workflows Invoker à conta de serviço do.
Para conceder o papel, encontre a lista Selecionar um papel e clique em Workflows > Workflows Invoker.
- Clique em Continuar.
-
Clique em Concluído para terminar a criação da conta de serviço.
-
-
No console do Google Cloud, na página do seletor de projetos, selecione ou crie um projeto do Google Cloud.
-
Verifique se a cobrança está ativada para o seu projeto do Google Cloud.
-
Ative as APIs Workflow Executions and Workflows.
-
Crie uma conta de serviço:
-
No Console do Google Cloud, acesse a página Criar conta de serviço.
Acesse "Criar conta de serviço" - Selecione o projeto.
-
No campo Nome da conta de serviço, insira um nome. O Console do Google Cloud preenche o campo ID da conta de serviço com base nesse nome.
No campo Descrição da conta de serviço, insira uma descrição. Por exemplo,
Service account for quickstart
. - Clique em Criar e continuar.
-
Conceda o papel Workflows > Workflows Invoker à conta de serviço do.
Para conceder o papel, encontre a lista Selecionar um papel e clique em Workflows > Workflows Invoker.
- Clique em Continuar.
-
Clique em Concluído para terminar a criação da conta de serviço.
-
gcloud
-
Faça login na sua Conta do Google.
Se você ainda não tiver uma, inscreva-se agora.
- Instale a CLI do Google Cloud.
-
Para inicializar a CLI gcloud, execute o seguinte comando:
gcloud init
-
Crie ou selecione um projeto do Google Cloud.
-
Crie um projeto do Google Cloud:
gcloud projects create PROJECT_ID
Substitua
PROJECT_ID
por um nome para o projeto do Google Cloud que você está criando. -
Selecione o projeto do Google Cloud que você criou:
gcloud config set project PROJECT_ID
Substitua
PROJECT_ID
pelo nome do projeto do Google Cloud.
-
-
Verifique se a cobrança está ativada para o seu projeto do Google Cloud.
-
Ative as APIs Workflow Executions and Workflows:
gcloud services enable workflowexecutions.googleapis.com
workflows.googleapis.com -
Configure a autenticação:
-
Crie a conta de serviço:
gcloud iam service-accounts create SERVICE_ACCOUNT_NAME
Substitua
SERVICE_ACCOUNT_NAME
por um nome para a conta de serviço. -
Conceda o papel do IAM
roles/workflows.invoker
à conta de serviço:gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=roles/workflows.invoker
Substitua:
SERVICE_ACCOUNT_NAME
: o nome da conta de serviço.PROJECT_ID
: o ID do projeto em que você criou a conta de serviço
-
- Instale a CLI do Google Cloud.
-
Para inicializar a CLI gcloud, execute o seguinte comando:
gcloud init
-
Crie ou selecione um projeto do Google Cloud.
-
Crie um projeto do Google Cloud:
gcloud projects create PROJECT_ID
Substitua
PROJECT_ID
por um nome para o projeto do Google Cloud que você está criando. -
Selecione o projeto do Google Cloud que você criou:
gcloud config set project PROJECT_ID
Substitua
PROJECT_ID
pelo nome do projeto do Google Cloud.
-
-
Verifique se a cobrança está ativada para o seu projeto do Google Cloud.
-
Ative as APIs Workflow Executions and Workflows:
gcloud services enable workflowexecutions.googleapis.com
workflows.googleapis.com -
Configure a autenticação:
-
Crie a conta de serviço:
gcloud iam service-accounts create SERVICE_ACCOUNT_NAME
Substitua
SERVICE_ACCOUNT_NAME
por um nome para a conta de serviço. -
Conceda o papel do IAM
roles/workflows.invoker
à conta de serviço:gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=roles/workflows.invoker
Substitua:
SERVICE_ACCOUNT_NAME
: o nome da conta de serviço.PROJECT_ID
: o ID do projeto em que você criou a conta de serviço
-
Criar e implantar um fluxo de trabalho filho
Um fluxo de trabalho filho pode receber e processar dados de um fluxo pai. O fluxo de trabalho filho demonstra isso fazendo o seguinte:
- Recebe um número inteiro como argumento
- Suspende por 10 segundos para simular algum processamento
Retorna um indicador (com base em um número ímpar ou par) para simular o sucesso ou a falha da execução do fluxo de trabalho.
Console
No console do Google Cloud, abra a página Workflows.
Clique em
Criar.Insira o nome,
workflow-child
, para o novo fluxo de trabalho.Na lista Região, selecione us-central1.
Selecione a conta de serviço que você criou anteriormente.
Clique em Próxima.
No editor de fluxo de trabalho, insira a seguinte definição para seu fluxo de trabalho:
Selecione Implantar.
gcloud
Crie um arquivo de código-fonte para seu fluxo de trabalho:
touch workflow-child.yaml
Abra o arquivo de código-fonte em um editor de texto e copie o fluxo de trabalho a seguir para o arquivo.
Implante o fluxo de trabalho:
gcloud workflows deploy workflow-child \ --source=workflow-child.yaml \ --location=us-central1 \ --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com
Substitua
SERVICE_ACCOUNT_NAME
pelo nome da conta de serviço criada anteriormente.
Criar e implantar o fluxo de trabalho pai
O fluxo de trabalho pai executa várias ramificações do filho usando uma
repetição for
paralela.
Copie o código-fonte da definição do fluxo de trabalho. Ele consiste nas seguintes partes:
Um mapa é usado para armazenar os resultados das execuções do fluxo de trabalho filho. Para mais informações, consulte Maps.
Uma repetição
for
é executada em paralelo para invocar o fluxo de trabalho filho. Para mais informações, consulte Etapas paralelas e Iteração.O fluxo de trabalho filho é invocado usando um conector. Cada iteração do fluxo de trabalho filho recebe o argumento
iteration
. O fluxo de trabalho pai aguarda e armazena o resultado de cada execução de fluxo de trabalho filho. Para mais informações, consulte Conector da API Workflows Executions e Argumentos de ambiente de execução.Os resultados da execução são retornados. Para mais informações, consulte Concluir a execução de um fluxo de trabalho.
Implante o fluxo de trabalho:
Console
No console do Google Cloud, acesse a página Fluxos de trabalho:
Clique em
Criar.Insira o nome,
workflow-parent
, para o novo fluxo de trabalho.Na lista Região, selecione us-central1.
Selecione a conta de serviço que você criou anteriormente.
Clique em Próxima.
No editor de fluxo de trabalho, cole a definição do fluxo de trabalho pai.
Selecione Implantar.
gcloud
Crie um arquivo de código-fonte para seu fluxo de trabalho:
touch workflow-parent.yaml
Abra o arquivo de código-fonte em um editor de texto e cole a definição para o fluxo de trabalho pai.
Implante o fluxo de trabalho:
gcloud workflows deploy workflow-parent \ --source=workflow-parent.yaml \ --location=us-central1 \ --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com
Substitua
SERVICE_ACCOUNT_NAME
pelo nome da conta de serviço criada anteriormente.
Executar o fluxo de trabalho pai
Execute o fluxo de trabalho pai para que as invocações do fluxo de trabalho filho sejam executadas em paralelo. As execuções levam cerca de 10 segundos para serem concluídas.
Console
No console do Google Cloud, acesse a página Fluxos de trabalho:
Na página Fluxos de trabalho, clique no fluxo de trabalho pai para acessar a página de detalhes.
Na página Detalhes do fluxo de trabalho, clique em play_arrow Executar.
Clique em Executar novamente.
Veja os resultados do fluxo de trabalho no painel Saída.
Os resultados serão semelhantes aos mostrados a seguir, indicando erros nas iterações 2 e 4 e sucesso nas iterações 1 e 3.
"failure": { "2": { "message": "Execution failed or cancelled.", "operation": { "argument": "{\"iteration\":2}", "duration": "10.157992541s", "endTime": "2023-07-11T13:13:13.028424329Z", "error": { "context": "RuntimeError: \"Error with iteration 2\"\nin step \"raise_error\", routine \"main\", line: 18", "payload": "\"Error with iteration 2\"", ... "4": { "message": "Execution failed or cancelled.", "operation": { "argument": "{\"iteration\":4}", "duration": "10.157929734s", "endTime": "2023-07-11T13:13:13.061289142Z", "error": { "context": "RuntimeError: \"Error with iteration 4\"\nin step \"raise_error\", routine \"main\", line: 18", "payload": "\"Error with iteration 4\"", ... "success": { "1": "Hello world1", "3": "Hello world3"
gcloud
Execute o fluxo de trabalho:
gcloud workflows run workflow-parent \ --location=us-central1
Os resultados serão semelhantes aos mostrados a seguir, indicando erros nas iterações 2 e 4 e sucesso nas iterações 1 e 3.
Waiting for execution [06c753e4-6947-4c62-ac0b-2a9d53fb1b8f] to complete...done. argument: 'null' duration: 14.065415004s endTime: '2023-07-11T12:50:43.929023883Z' name: projects/386837416586/locations/us-central1/workflows/workflow-parent/executions/06c753e4-6947-4c62-ac0b-2a9d53fb1b8f result: '{"failure":{"2":{"message":"Execution failed or cancelled.","operation":{"argument":"{\"iteration\":2}","duration":"10.143718070s","endTime":"2023-07-11T12:50:40.673209821Z","error":{"context":"RuntimeError: ... "Error with iteration 2\"\nin step \"raise_error\", routine \"main\", line: 18","payload":"\"Error ... "Error with iteration 4\"\nin step \"raise_error\", routine \"main\", line: 18","payload":"\"Error ... "success":{"1":"Hello world1","3":"Hello world3"}}' startTime: '2023-07-11T12:50:29.863608879Z' state: SUCCEEDED
Você criou e implantou com sucesso um fluxo de trabalho que invoca um fluxo de trabalho filho, executa quatro iterações do fluxo de trabalho filho em ramificações paralelas e retorna um indicador de sucesso ou falha para cada execução de fluxo de trabalho filho.
Limpar
Se você criou um novo projeto para este tutorial, exclua o projeto. Se você usou um projeto atual e quer mantê-lo sem as alterações incluídas neste tutorial, exclua os recursos criados para o tutorial.
Exclua o projeto
O jeito mais fácil de evitar cobranças é excluindo o projeto que você criou para o tutorial.
Para excluir o projeto:
- No Console do Google Cloud, acesse a página Gerenciar recursos.
- Na lista de projetos, selecione o projeto que você quer excluir e clique em Excluir .
- Na caixa de diálogo, digite o ID do projeto e clique em Encerrar para excluí-lo.
Excluir recursos do tutorial
Exclua os fluxos de trabalho criados neste tutorial:
gcloud workflows delete workflow-child gcloud workflows delete workflow-parent
A seguir
- Para saber mais sobre a sintaxe do Workflows, consulte a referência de sintaxe do Workflows.
- Para saber mais sobre os conectores do Workflows, consulte Noções básicas sobre conectores.