Crea ed esegui un job che invia notifiche sullo stato Pub/Sub

Questo documento spiega come creare un job batch che invia Notifiche Pub/Sub. Puoi utilizzare Pub/Sub per ricevere notifiche quando lo stato di un job o di un'attività modifiche o quando un job o un'attività entrano in uno stato specifico. Per ulteriori informazioni, consulta Monitorare i job utilizzando le notifiche.

Prima di iniziare

Ruoli obbligatori

  • Per ottenere le autorizzazioni necessarie per creare ed eseguire un job che invia notifiche, chiedi all'amministratore di concederti seguenti ruoli IAM:

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

    Potresti anche riuscire a ottenere le autorizzazioni richieste tramite la ruoli o altri ruoli predefiniti ruoli.

  • A meno che non utilizzi la configurazione predefinita per l'account di servizio del job, assicurati che disponga delle autorizzazioni necessarie.

    Per garantire che l'account di servizio del job abbia gli elementi necessari le autorizzazioni per pubblicare notifiche Pub/Sub, chiedi all'amministratore di concedere all'account di servizio del job Ruolo IAM Pub/Sub Publisher (roles/pubsub.publisher) nell'argomento Pub/Sub.

  • Se vuoi che un job pubblichi notifiche in un argomento Pub/Sub che si trova in un progetto diverso dal job, Agente di servizio batch per il progetto del job deve essere concessa l'autorizzazione per pubblicare in quell'argomento.

    Per garantire che l'agente di servizio Batch per il progetto del job abbia i necessari le autorizzazioni per pubblicare notifiche Pub/Sub in un argomento Pub/Sub di un altro progetto, chiedi all'amministratore di concedere all'agente di servizio Batch per il progetto del job la Ruolo IAM Pub/Sub Publisher (roles/pubsub.publisher) nell'argomento Pub/Sub.

Crea ed esegui un job che invia notifiche

Puoi creare un job batch che invia notifiche Pub/Sub nel seguente modo:

Utilizza Google Cloud CLI o l'API REST per creare un job che include il campo notifications e uno o più jobNotification oggetti nel corpo principale del file JSON:

  "notifications": [
    {
      "pubsubTopic": "projects/PROJECT_ID/topics/TOPIC_ID",
      "message": {
        ATTRIBUTES
      }
    }
  ]

Sostituisci quanto segue:

  • PROJECT_ID: l'ID del progetto che contiene l'argomento Pub/Sub.
  • TOPIC_ID: l'ID dell'argomento Pub/Sub dell'argomento che hai creato notifiche Pub/Sub abilitate.

  • ATTRIBUTES: specifica uno o più dei seguenti criteri ciascuno dei quali consente di ricevere notifiche sullo stato lavoro o tutte le sue attività.

    • Per ricevere notifiche relative a tutte le modifiche allo stato del job, specifica quanto segue:

      "type": "JOB_STATE_CHANGED"

    • Per le notifiche relative a una specifica modifica dello stato del job, specifica quanto segue:

      "type": "JOB_STATE_CHANGED",
"newJobState": "JOB_STATE"

      Sostituisci JOB_STATE con uno dei seguenti job stati:

      • QUEUED
      • SCHEDULED
      • RUNNING
      • SUCCEEDED
      • FAILED

      Per ulteriori informazioni sugli stati dei job, consulta Ciclo di vita del job.

    • Per le notifiche relative a tutte le modifiche dello stato delle attività, specifica quanto segue:

      "type": "TASK_STATE_CHANGED"

    • Per notifiche relative a modifiche specifiche dello stato di un'attività, specifica quanto segue:

      "type": "TASK_STATE_CHANGED",
"newTaskState": "TASK_STATE"

      Sostituisci TASK_STATE con uno dei seguenti stati dell'attività:

      • PENDING
      • ASSIGNED
      • RUNNING
      • SUCCEEDED
      • FAILED

      Per ulteriori informazioni sugli stati delle attività, consulta Ciclo di vita del job.

Ad esempio, supponiamo che tu voglia ricevere notifiche su tutti gli stati dei job modifiche e ogni volta che un'attività non riesce. Per farlo, puoi avere un file JSON di configurazione di rete simile al seguente:

{
  "taskGroups": [
    {
      "taskSpec": {
        "runnables": [
          {
            "script": {
              "text": "echo Hello World! This is task $BATCH_TASK_INDEX."
            }
          }
        ]
      },
      "taskCount": 3,
    }
  ],
  "logsPolicy": {
      "destination": "CLOUD_LOGGING"
  },
  "notifications": [
    {
      "pubsubTopic": "projects/PROJECT_ID/topics/TOPIC_ID",
      "message": {
        "type": "JOB_STATE_CHANGED"
      }
    },
    {
      "pubsubTopic": "projects/PROJECT_ID/topics/TOPIC_ID",
      "message": {
        "type": "TASK_STATE_CHANGED",
        "newTaskState": "FAILED"
      }
    }
  ]
}

Dopo l'avvio del job, puoi utilizzare le relative notifiche. Ad esempio, se l'argomento Pub/Sub per il tuo job ha una sottoscrizione che invia notifiche in streaming a BigQuery, analizzare le notifiche Pub/Sub in BigQuery.

Passaggi successivi