Automatizza i nuovi tentativi delle attività

In questa pagina viene descritto come riprovare automaticamente le attività dopo tutti o alcuni errori.

Un job batch ha esito negativo quando almeno una delle sue attività ha esito negativo, che può verificarsi per vari motivi. Per impostazione predefinita, ogni attività in un job viene eseguita una sola volta; se un'attività ha esito negativo, non viene riprovata. Tuttavia, alcuni problemi che impediscono un'attività possono essere facilmente risolti semplicemente riprovando. In questi casi, la configurazione del job in modo che ripeta automaticamente le attività può aiutare a ridurre in modo sostanziale gli attriti nella risoluzione dei problemi e il tempo di esecuzione complessivo dei job.

I nuovi tentativi automatici sono particolarmente adatti per attività a basso accoppiamento (indipendenti) e possono aiutare a risolvere una serie di problemi. Ad esempio, i nuovi tentativi automatici possono risolvere problemi urgenti, ad esempio:

• prerilascio delle VM spot
• Eventi di manutenzione delle VM ed errori dell'host
• errori di rete temporanei

Puoi configurare i tentativi automatici di ciascuna attività quando crei un job. In particolare, per ogni attività, puoi utilizzare una delle seguenti opzioni di configurazione:

• Per impostazione predefinita, ogni attività non viene tentata di nuovo in caso di errore.
• Riprovare le attività per tutti gli errori: puoi configurare il tempo massimo per riprovare automaticamente le attività non riuscite. Puoi specificare un numero di tentativi compreso tra 0 (predefinito) e 10.
• Riprovare le attività per alcuni errori: puoi configurare diverse azioni per l'attività, ovvero tentativo automatico o tentativo non riuscito senza nuovo tentativo, per errori specifici. Per tutti gli errori non specificati viene eseguita l'azione opposta. Gli errori specifici possono essere identificati da un codice di uscita definito dall'applicazione o dal batch.

Prima di iniziare

• Se non hai mai utilizzato Batch, consulta la Guida introduttiva all'utilizzo di Batch e abilita Batch completando i prerequisiti per progetti e utenti.

• Per ottenere le autorizzazioni necessarie per creare un job, chiedi all'amministratore di concederti i ruoli IAM seguenti:

  • Editor job batch (roles/batch.jobsEditor) nel progetto
  • Utente account di servizio (roles/iam.serviceAccountUser) nell'account di servizio del job, che per impostazione predefinita è l'account di servizio Compute Engine predefinito

  Per saperne di più sulla concessione dei ruoli, consulta Gestire l'accesso.

  Potresti anche essere in grado di ottenere le autorizzazioni richieste tramite i ruoli personalizzati o altri ruoli predefiniti.

Riprova le attività per tutti gli errori

Puoi definire il numero massimo di tentativi automatici (campo maxRetryCount) per le attività non riuscite di un job utilizzando gcloud CLI o l'API Batch.

gcloud

1. Crea un file JSON che specifichi i dettagli di configurazione del job e il campo maxRetryCount.

   Ad esempio, per creare un job di script di base che specifichi il numero massimo di tentativi per le attività non riuscite, crea un file JSON con i seguenti contenuti:

   {
     "taskGroups": [
       {
         "taskSpec": {
           "runnables": [
             {
               "script": {
                 "text": "echo Hello world from task ${BATCH_TASK_INDEX}"
               }
             }
           ],
           
           "maxRetryCount": MAX_RETRY_COUNT
           
         },
         "taskCount": 3
       }
     ],
     "logsPolicy": {
       "destination": "CLOUD_LOGGING"
     }
   }
   

   Sostituisci MAX_RETRY_COUNT con il numero massimo di nuovi tentativi per ogni attività. Affinché un job possa riprovare le attività non riuscite, questo valore deve essere impostato su un numero intero compreso tra 1 e 10. Se il campo maxRetryCount non è specificato, il valore predefinito è 0, il che significa che non occorre riprovare ad alcuna attività.

2. Per creare ed eseguire il job, utilizza il comando gcloud batch jobs submit:

   gcloud batch jobs submit JOB_NAME \
     --location LOCATION \
     --config JSON_CONFIGURATION_FILE
   

   Sostituisci quanto segue:

   • JOB_NAME: il nome del lavoro.

   • LOCATION: la località del lavoro.

   • JSON_CONFIGURATION_FILE: il percorso di un file JSON con i dettagli di configurazione del job.

API

Effettua una richiesta POST al metodo jobs.create che specifica il campo maxRetryCount.

Ad esempio, per creare un job di script di base che specifichi il numero massimo di tentativi per le attività non riuscite, effettua la richiesta seguente:

POST https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs?job_id=JOB_NAME

{
  "taskGroups": [
    {
      "taskSpec": {
        "runnables": [
          {
            "script": {
              "text": "echo Hello world from task ${BATCH_TASK_INDEX}"
            }
          }
        ],
        
        "maxRetryCount": MAX_RETRY_COUNT
        
      },
      "taskCount": 3
    }
  ],
  "logsPolicy": {
    "destination": "CLOUD_LOGGING"
  }
}

Sostituisci quanto segue:

• PROJECT_ID: l'ID progetto del progetto.

• LOCATION: la località del lavoro.

• JOB_NAME: il nome del lavoro.

• MAX_RETRY_COUNT: il numero massimo di nuovi tentativi per ogni attività. Affinché un job possa riprovare le attività non riuscite, questo valore deve essere impostato su un numero intero compreso tra 1 e 10. Se il campo maxRetryCount non è specificato, il valore predefinito è 0, il che significa che non occorre riprovare ad alcuna attività.

Riprova le attività per alcuni errori

Puoi definire la modalità con cui un job deve gestire diversi errori delle attività utilizzando i criteri del ciclo di vita (campo lifecyclePolicies[]).

Un criterio del ciclo di vita è costituito da azione (campo action), condizione di azione (campo actionCondition) e codice di uscita (campo exitCodes[]). L'azione specificata viene eseguita ogni volta che si verifica la condizione dell'azione (un codice di uscita specifico). Puoi specificare una delle seguenti azioni:

• RETRY_TASK: riprova le attività non riuscite con i codici di uscita specificati nel campo exitCodes[]. Le attività non riuscite con codici di uscita non specificati non vengono tentate di nuovo.
• FAIL_TASK: non riprovare le attività non riuscite con i codici di uscita specificati nel campo exitCodes[]. Le attività non riuscite con codici di uscita non specificati vengono tentate di nuovo.

In particolare, le attività non riuscite con codici di uscita non specificati eseguono l'azione opposta: alcuni codici di uscita vengono tentati di nuovo, mentre altre non vanno a buon fine. Di conseguenza, affinché il criterio del ciclo di vita funzioni come previsto, devi anche definire il numero massimo di tentativi automatici (campo maxRetryCount) per consentire al job di ritentare automaticamente le attività non riuscite almeno una volta.

Ogni codice di uscita rappresenta un errore specifico definito dall'applicazione o dal batch. I codici di uscita da 50001 a 59999 sono riservati e definiti da Batch. Per ulteriori informazioni sui codici di uscita riservati, consulta la sezione Risoluzione dei problemi.

Puoi specificare che un job possa ritentare o non riuscire ad attività dopo errori specifici utilizzando gcloud CLI o l'API Batch.

gcloud

1. Crea un file JSON che specifichi i dettagli di configurazione del job, il campo maxRetryCount e i sottocampi lifecyclePolicies[].

   Per creare un job di script di base che faccia un nuovo tentativo con le attività non riuscite solo per alcuni codici di uscita, crea un file JSON con i seguenti contenuti:

   {
     "taskGroups": [
       {
         "taskSpec": {
           "runnables": [
             {
               "script": {
                 "text": "echo Hello world from task ${BATCH_TASK_INDEX}"
               }
             }
           ],
           
           "maxRetryCount": MAX_RETRY_COUNT,
           "lifecyclePolicies": [
             {
               "action": "ACTION",
               "actionCondition": {
                  "exitCodes": [EXIT_CODES]
               }
             }
           ]
         }
       }
     ],
     "logsPolicy": {
       "destination": "CLOUD_LOGGING"
     }
   }
   

   Sostituisci quanto segue:

   • MAX_RETRY_COUNT: il numero massimo di nuovi tentativi per ogni attività. Affinché un job possa riprovare le attività non riuscite, questo valore deve essere impostato su un numero intero compreso tra 1 e 10. Se il campo maxRetryCount non è specificato, il valore predefinito è 0, il che significa che non occorre riprovare ad alcuna attività.

   • ACTION: l'azione, RETRY_TASK o FAIL_TASK, che vuoi per le attività che non superano i codici di uscita specificati. Le attività non riuscite con codici di uscita non specificati eseguono l'altra azione.

   • EXIT_CODES: un elenco separato da virgole di uno o più codici di uscita che vuoi attivare l'azione specificata, ad esempio 50001, 50002.

     Ogni codice di uscita può essere definito dalla tua applicazione o dal tuo batch. I codici di uscita da 50001 a 59999 sono riservati da Batch. Per ulteriori informazioni sui codici di uscita riservati, consulta la sezione Risoluzione dei problemi.

   Ad esempio, nel job seguente viene eseguito un nuovo tentativo solo per le attività non riuscite a causa del prerilascio delle VM spot.

   {
     "taskGroups": [
       {
         "taskSpec": {
           "runnables": [
             {
               "script": {
                 "text": "sleep 30"
               }
             }
           ],
           "maxRetryCount": 3,
           "lifecyclePolicies": [
             {
                "action": "RETRY_TASK",
                "actionCondition": {
                  "exitCodes": [50001]
               }
             }
           ]
         }
       }
     ],
     "allocationPolicy": {
       "instances": [
         {
           "policy": {
             "machineType": "e2-standard-4",
             "provisioningModel": "SPOT"
           }
         }
       ]
     }
   }
   

2. Per creare ed eseguire il job, utilizza il comando gcloud batch jobs submit:

   gcloud batch jobs submit JOB_NAME \
     --location LOCATION \
     --config JSON_CONFIGURATION_FILE
   

   Sostituisci quanto segue:

   • JOB_NAME: il nome del lavoro.

   • LOCATION: la località del lavoro.

   • JSON_CONFIGURATION_FILE: il percorso di un file JSON con i dettagli di configurazione del job.

API

Effettua una richiesta POST al metodo jobs.create che specifica il campo maxRetryCount e i campi secondari lifecyclePolicies[].

Per creare un job di script di base che faccia un nuovo tentativo con le attività non riuscite solo per alcuni codici di uscita, effettua la seguente richiesta:

POST https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs?job_id=JOB_NAME

{
  "taskGroups": [
    {
      "taskSpec": {
        "runnables": [
          {
            "script": {
              "text": "echo Hello world from task ${BATCH_TASK_INDEX}"
            }
          }
        ],
        
        "maxRetryCount": MAX_RETRY_COUNT,
        "lifecyclePolicies": [
          {
            "action": "ACTION",
            "actionCondition": {
                "exitCodes": [EXIT_CODES]
            }
          }
        ]
      }
    }
  ],
  "logsPolicy": {
    "destination": "CLOUD_LOGGING"
  }
}

Sostituisci quanto segue:

• PROJECT_ID: l'ID progetto del progetto.

• LOCATION: la località del lavoro.

• JOB_NAME: il nome del lavoro.

• MAX_RETRY_COUNT: il numero massimo di nuovi tentativi per ogni attività. Affinché un job possa riprovare le attività non riuscite, questo valore deve essere impostato su un numero intero compreso tra 1 e 10. Se il campo maxRetryCount non è specificato, il valore predefinito è 0, il che significa che non occorre riprovare ad alcuna attività.

• ACTION: l'azione, RETRY_TASK o FAIL_TASK, che vuoi per le attività che non superano i codici di uscita specificati. Le attività non riuscite con codici di uscita non specificati eseguono l'altra azione.

• EXIT_CODES: un elenco separato da virgole di uno o più codici di uscita che vuoi attivare l'azione specificata, ad esempio 50001, 50002.

  Ogni codice di uscita può essere definito dalla tua applicazione o dal tuo batch. I codici di uscita da 50001 a 59999 sono riservati da Batch. Per ulteriori informazioni sui codici di uscita riservati, consulta la sezione Risoluzione dei problemi.

Ad esempio, nel job seguente viene eseguito un nuovo tentativo solo per le attività non riuscite a causa del prerilascio delle VM spot.

POST https://batch.googleapis.com/v1/projects/example-project/locations/us-central1/jobs?job_id=example-job

{
  "taskGroups": [
    {
      "taskSpec": {
        "runnables": [
          {
            "script": {
              "text": "sleep 30"
            }
          }
        ],
        "maxRetryCount": 3,
        "lifecyclePolicies": [
          {
             "action": "RETRY_TASK",
             "actionCondition": {
               "exitCodes": [50001]
            }
          }
        ]
      }
    }
  ],
  "allocationPolicy": {
    "instances": [
      {
        "policy": {
          "machineType": "e2-standard-4",
          "provisioningModel": "SPOT"
        }
      }
    ]
  }
}

Passaggi successivi

• In caso di problemi durante la creazione o l'esecuzione di un job, consulta Risoluzione dei problemi.
• Visualizza job e attività.
• Scopri di più sulle opzioni per la creazione di job.