Neste tutorial, mostramos como usar o Cloud Scheduler para executar automaticamente fluxos de trabalho. Assim, um fluxo de trabalho é executado em uma programação específica, nesse caso, a cada cinco minutos.
Crie um fluxo de trabalho que receba argumentos de ambiente de execução
Uma definição de fluxo de trabalho é composta por uma série de etapas descritas usando a sintaxe de fluxos de trabalho, que pode ser escrita em formato YAML ou JSON. Depois de criar um fluxo de trabalho, implante-o para que ele fique disponível para execução.
Console
No console Google Cloud , acesse a página Fluxos de trabalho:
Clique em Criar.
Insira
myFirstWorkflowcomo um nome para o novo fluxo de trabalho.Selecione us-central1 para a região.
Selecione a conta de serviço que você criou.
Clique em Next.
No editor de fluxo de trabalho, insira a seguinte definição para seu fluxo de trabalho:
YAML
main: params: [args] steps: - step1: assign: - outputVar: ${"Hello, " + args.firstName + " " + args.lastName + "!"} - step2: return: ${outputVar}
JSON
{ "main": { "params": [ "args" ], "steps": [ { "step1": { "assign": [ { "outputVar": "${\"Hello \" + args.firstName + \" \" + args.lastName}" } ] } }, { "step2": { "return": "${outputVar}" } } ] } }
Esse fluxo de trabalho retorna uma saudação "Hello" para uma pessoa cujo nome e sobrenome você passa como argumentos de execução.
Clique em Deploy.
gcloud
- Abra um terminal.
Salve a seguinte definição de fluxo de trabalho como um arquivo YAML ou JSON, como myFirstWorkflow.yaml ou myFirstWorkflow.json.
YAML
main: params: [args] steps: - step1: assign: - outputVar: ${"Hello, " + args.firstName + " " + args.lastName + "!"} - step2: return: ${outputVar}
JSON
{ "main": { "params": [ "args" ], "steps": [ { "step1": { "assign": [ { "outputVar": "${\"Hello \" + args.firstName + \" \" + args.lastName}" } ] } }, { "step2": { "return": "${outputVar}" } } ] } }
Esse fluxo de trabalho retorna uma saudação "Hello" para uma pessoa cujo nome e sobrenome você passa como argumentos de execução.
Implante o fluxo de trabalho digitando o seguinte comando:
gcloud workflows deploy myFirstWorkflow \ --source=myFirstWorkflow.yaml_OR_json \ --service-account=sa-name@PROJECT_ID.iam.gserviceaccount.com
Substitua
yaml_OR_jsonporyamloujson, dependendo do formato do arquivo de definição de fluxos de trabalho que você criou.
Programe o fluxo de trabalho
Criar um job do Cloud Scheduler que acione seu fluxo de trabalho usando a conta de serviço que você criou.
Console
No console Google Cloud , acesse a página Cloud Scheduler:
Clique em Criar job.
Defina o Nome como
my-workflow-job.Em Frequência, insira:
Isso vai executar o job a cada cinco minutos. O intervalo é definido usando o formato unix-cron.*/5 * * * *Em Fuso horário, selecione um país e um fuso horário.
Por exemplo, selecione Estados Unidos e Los Angeles ou Horário de verão do Pacífico (PDT, na sigla em inglês).
Clique em Continuar.
Em Tipo de destino, selecione HTTP.
Em URL, digite:
https://workflowexecutions.googleapis.com/v1/projects/PROJECT_ID/locations/us-central1/workflows/myFirstWorkflow/executions
Deixe o método HTTP no padrão POST.
Adicione os dois cabeçalhos HTTP a seguir:
- Nome:
Content-Typee Valor:application/octet-stream - Nome:
User-Agente Valor:Google-Cloud-Scheduler
- Nome:
Em Corpo, digite:
{"argument": "{\"firstName\":\"Sherlock\", \"lastName\":\"Holmes\"}"}Isso transmite uma codificação JSON dos argumentos do fluxo de trabalho: nesse caso, o nome, "Sherlock" e o sobrenome, "Holmes". As aspas duplas dentro da string são escapadas usando barras invertidas (\).
Em Cabeçalho do Auth, selecione Adicionar token OAuth.
Insira a conta de serviço que você criou.
Não é necessário especificar o Escopo, já que o padrãosa-name@PROJECT_ID.iam.gserviceaccount.com
https://www.googleapis.com/auth/cloud-platformé usado.Aceite todos os padrões e clique em Criar.
gcloud
Programe um job chamado my-workflow-job digitando o seguinte comando:
gcloud scheduler jobs create http my-workflow-job \
--schedule="*/5 * * * *" \
--uri="https://workflowexecutions.googleapis.com/v1/projects/PROJECT_ID/locations/us-central1/workflows/myFirstWorkflow/executions" \
--message-body="{\"argument\": \"{\\\"firstName\\\":\\\"Sherlock\\\", \\\"lastName\\\":\\\"Holmes\\\"}\"}" \
--time-zone="America/Los_Angeles" \
--oauth-service-account-email="sa-name@PROJECT_ID.iam.gserviceaccount.com"O intervalo é definido usando o formato unix-cron.
A sinalização message-body é usada para transmitir uma codificação JSON dos argumentos do
fluxo de trabalho. nesse caso, o primeiro nome, "Sherlock" e o sobrenome, "Holmes". As aspas duplas dentro da string são escapadas usando barras invertidas (\).
Agora seu fluxo de trabalho é executado a cada cinco minutos.
Para mais informações sobre as flags gcloud scheduler e como aplicar
o registro de chamadas para que cada etapa de chamada durante a execução do fluxo de trabalho seja
registrada, consulte Programar um fluxo de trabalho e a
referência gcloud.
Execute o job e verifique os resultados
Console
No console Google Cloud , acesse a página Cloud Scheduler:
Se a tarefa não for exibida, talvez seja necessário atualizar a página.
Para o job
my-workflow-job, clique em Executar agora.O valor Result será atualizado para Success.
No console Google Cloud , acesse a página Fluxos de trabalho:
Na lista de fluxos de trabalho, clique em myFirstWorkflow para abrir a página de detalhes.
O estado de execução do fluxo de trabalho deve ser Concluído.
Clique no ID da execução do fluxo de trabalho para abrir a página de detalhes e ver os resultados do fluxo de trabalho no painel Saída.
A resposta será "Hello, Sherlock Holmes!".
gcloud
Execute o job do Cloud Scheduler para executar o fluxo de trabalho:
gcloud scheduler jobs run my-workflow-job
Recupere o ID de execução do seu fluxo de trabalho:
gcloud workflows executions list myFirstWorkflow
A saída será semelhante a esta com o ID de execução em negrito:
projects/316710615161/locations/us-central1/workflows/myFirstWorkflow/executions/138b31e1-f3bb-4ba7-a6da-008d0cb4a320
Recupere os resultados da execução do fluxo de trabalho:
gcloud workflows executions describe EXECUTION_ID --workflow myFirstWorkflow
Substitua
EXECUTION_IDpelo ID de execução retornado na etapa anterior.A saída será semelhante a esta:
argument: '{"firstName":"Sherlock","lastName":"Holmes"}' endTime: '2021-09-09T15:15:00.869350639Z' name: projects/316710615161/locations/us-central1/workflows/myFirstWorkflow/executions/138b31e1-f3bb-4ba7-a6da-008d0cb4a320 result: '"Hello, Sherlock Holmes!"' startTime: '2021-09-09T15:15:00.839175480Z' state: SUCCEEDED workflowRevisionId: 000001-4f9
Parabéns! Você criou um job do Cloud Scheduler que executa automaticamente um fluxo de trabalho em uma programação específica.