Pianifica flussi di lavoro


Questo tutorial mostra come utilizzare Cloud Scheduler per eseguire automaticamente Flussi di lavoro in modo che un flusso di lavoro venga eseguito in base a una determinata pianificazione, in questo caso ogni 5 minuti.

Obiettivi

  1. Crea ed esegui il deployment di un flusso di lavoro che può ricevere argomenti di runtime.
  2. Crea un job Cloud Scheduler che attivi il flusso di lavoro e lo esegue ogni 5 minuti, passando argomenti JSON nel formato corretto.

Costi

In questo documento utilizzi i seguenti componenti fatturabili di Google Cloud:

Per generare una stima dei costi basata sull'utilizzo previsto, utilizza il Calcolatore prezzi. I nuovi utenti di Google Cloud potrebbero essere idonei per una prova gratuita.

Prima di iniziare

  1. Configura il tuo ambiente per Cloud Scheduler, ad esempio sulla creazione di un'app di App Engine.
  2. Enable the Workflows API.

    Enable the API

  3. Imposta la posizione predefinita utilizzata in questo tutorial:
      gcloud config set workflows/location REGION
    Sostituisci REGION con i Workflows supportati località di tua scelta.
  4. Creare un account di servizio da utilizzare in Workflows. ad esempio sa-name.
      gcloud iam service-accounts create sa-name
  5. Concedi al tuo account di servizio il ruolo workflows.invoker in modo che account dispone dell'autorizzazione per attivare il tuo flusso di lavoro:
      gcloud projects add-iam-policy-binding PROJECT_ID \
          --member "serviceAccount:sa-name@PROJECT_ID.iam.gserviceaccount.com" \
          --role "roles/workflows.invoker"
  6. Sostituisci PROJECT_ID con l'ID del tuo progetto Google Cloud.
  7. Concedi il ruolo logging.logWriter all'account di servizio.
      gcloud projects add-iam-policy-binding PROJECT_ID \
          --member "serviceAccount:sa-name@PROJECT_ID.iam.gserviceaccount.com" \
          --role "roles/logging.logWriter"

Crea un flusso di lavoro che riceve argomenti di runtime

Una definizione di flusso di lavoro è composta da una serie di passaggi descritti utilizzando la sintassi di Workflows, che può essere scritta in formato YAML o JSON. Dopo aver creato un flusso di lavoro, esegui il deployment per renderlo disponibile per l'esecuzione.

Console

  1. Nella console Google Cloud, vai alla pagina Flussi di lavoro:

    Vai a Flussi di lavoro

  2. Fai clic su Crea.

  3. Inserisci myFirstWorkflow come nome del nuovo flusso di lavoro.

  4. Seleziona us-central1 come regione.

  5. Seleziona l'account di servizio che hai creato in precedenza.

  6. Fai clic su Avanti.

  7. Nell'editor del flusso di lavoro, inserisci la seguente definizione per il flusso di lavoro.

    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}"
            }
          }
        ]
      }
    }
      

    Questo flusso di lavoro restituisce un saluto "Un saluto da Google" a una persona di cui hai passato il nome e il cognome come argomenti di runtime.

  8. Fai clic su Esegui il deployment.

gcloud

  1. Apri un terminale.
  2. Salva la definizione del flusso di lavoro seguente come YAML o JSON come myFirstWorkflow.yaml o 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}"
            }
          }
        ]
      }
    }
      

    Questo flusso di lavoro restituisce un saluto "Un saluto da Google" a una persona di cui hai passato il nome e il cognome come argomenti di runtime.

  3. Esegui il deployment del flusso di lavoro inserendo il comando seguente:

    gcloud workflows deploy myFirstWorkflow \
        --source=myFirstWorkflow.yaml_OR_json \
        --service-account=sa-name@PROJECT_ID.iam.gserviceaccount.com

    Sostituisci yaml_OR_json con yaml o json, a seconda sul formato del file di definizione di Workflows che creati in precedenza.

Pianifica il flusso di lavoro

Crea un job Cloud Scheduler che attivi il flusso di lavoro utilizzando il servizio creato in precedenza.

Console

  1. Nella console Google Cloud, vai alla pagina Cloud Scheduler:

    Vai a Cloud Scheduler

  2. Fai clic su Crea job.

  3. Imposta il Nome su my-workflow-job.

  4. In Frequenza, inserisci:

    */5 * * * *
    Il job verrà eseguito ogni 5 minuti. L'intervallo è definito utilizzando il formato unix-cron.

  5. In Fuso orario, seleziona un paese e un fuso orario.

    Ad esempio, seleziona Stati Uniti e Los Angeles o Ora legale del Pacifico (PDT).

  6. Fai clic su Continua.

  7. In Tipo di destinazione, seleziona HTTP.

  8. Per URL, inserisci:

    https://workflowexecutions.googleapis.com/v1/projects/PROJECT_ID/locations/us-central1/workflows/myFirstWorkflow/executions
    

  9. Lascia il metodo HTTP sul valore predefinito POST.

  10. Aggiungi le due intestazioni HTTP seguenti:

    • Nome: Content-Type e valore: application/octet-stream
    • Nome: User-Agent e valore: Google-Cloud-Scheduler
  11. In Testo, inserisci:

    {"argument": "{\"firstName\":\"Sherlock\", \"lastName\":\"Holmes\"}"}
    

    Viene passata una codifica JSON degli argomenti del flusso di lavoro; in questo caso, il nome "Sherlock" e il cognome "Holmes". Le virgolette doppie all'interno della stringa vengono trasformati in caratteri di escape mediante barre rovesciate (\).

  12. Per Intestazione autorizzazione, seleziona Aggiungi token OAuth.

  13. Inserisci l'account di servizio creato in precedenza.

    sa-name@PROJECT_ID.iam.gserviceaccount.com
    
    Non è necessario specificare l'Ambito come valore predefinito Viene utilizzato https://www.googleapis.com/auth/cloud-platform.

  14. Accetta tutte le altre impostazioni predefinite e fai clic su Crea.

gcloud

Pianifica un job denominato my-workflow-job inserendo il seguente 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"

L'intervallo viene definito utilizzando unix-cron. formato.

Il flag message-body viene utilizzato per passare una codifica JSON degli argomenti del flusso di lavoro; in questo caso, il nome "Sherlock" e il cognome "Holmes". Le virgolette doppie all'interno della stringa sono interpretate come carattere di escape utilizzando le barre rovesciate (\).

Ora il flusso di lavoro viene eseguito ogni 5 minuti.

Per ulteriori informazioni sui flag gcloud scheduler e su come applicarli il logging delle chiamate in modo che ogni passaggio della chiamata durante l'esecuzione del flusso di lavoro registrato, consulta Pianificare un flusso di lavoro e gcloud riferimento.

Esegui il job e verifica i risultati

Console

  1. Nella console Google Cloud, vai alla pagina Cloud Scheduler:

    Vai a Cloud Scheduler

    Se il job non viene visualizzato, potresti dover aggiornare la pagina.

  2. Per il job denominato my-workflow-job, fai clic su Esegui ora.

    Il valore di Result dovrebbe essere aggiornato in Success.

  3. Nella console Google Cloud, vai alla pagina Flussi di lavoro:

    Vai a Flussi di lavoro

  4. Nell'elenco dei flussi di lavoro, fai clic su myFirstWorkflow per aprire il relativo pagina dei dettagli.

    Lo stato di esecuzione del flusso di lavoro deve essere Riuscito.

  5. Fai clic sull'ID esecuzione del flusso di lavoro per aprire la pagina dei dettagli e per visualizzare i risultati del flusso di lavoro nel riquadro Output.

    L'output dovrebbe essere "Ciao, Sherlock Holmes!".

gcloud

  1. Esegui il job Cloud Scheduler per il flusso di lavoro:

    gcloud scheduler jobs run my-workflow-job
    
  2. Recupera l'ID esecuzione per il tuo flusso di lavoro:

    gcloud workflows executions list myFirstWorkflow
    

    L'output dovrebbe essere simile al seguente, con l'ID esecuzione in grassetto:

    projects/316710615161/locations/us-central1/workflows/myFirstWorkflow/executions/138b31e1-f3bb-4ba7-a6da-008d0cb4a320
  3. Recupera i risultati dell'esecuzione del flusso di lavoro:

    gcloud workflows executions describe EXECUTION_ID --workflow myFirstWorkflow

    Sostituisci EXECUTION_ID con l'ID esecuzione restituito nel passaggio precedente.

    L'output dovrebbe essere simile al seguente:

    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

Complimenti! Hai creato un job Cloud Scheduler che esegue automaticamente un flusso di lavoro in base a una determinata pianificazione.

Esegui la pulizia

Al termine del tutorial, puoi eliminare le risorse che hai creato in modo che smettano di utilizzare la quota e di generare addebiti. Le seguenti sezioni descrivono come eliminare o disattivare queste risorse.

Elimina il progetto

Il modo più semplice per eliminare la fatturazione creato per il tutorial.

Per eliminare il progetto:

  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.

Elimina il job Cloud Scheduler

  1. Vai alla pagina Cloud Scheduler nella console Google Cloud.

    Vai a Cloud Scheduler

  2. Seleziona la casella di controllo accanto al job.

  3. Fai clic su Elimina nella parte superiore della pagina e conferma l'eliminazione.

Elimina il flusso di lavoro di Workflows

  1. Vai alla pagina Flussi di lavoro nella console Google Cloud.

    Vai a Flussi di lavoro

  2. Seleziona il flusso di lavoro.

  3. Fai clic su Elimina nella parte superiore della pagina, digita il nome del flusso di lavoro e conferma l'eliminazione.

Disattiva l'app App Engine

La disabilitazione di un'app di App Engine interrompe l'esecuzione dell'applicazione le istanze VM e gestire le richieste, conservando i dati e le impostazioni dell'applicazione.

  1. Vai alla pagina Impostazioni applicazione nella console Google Cloud.

    Vai a Impostazioni applicazione

  2. Fai clic su Disabilita applicazione.

  3. Segui le istruzioni.

Passaggi successivi