Delen via


Meldingen toevoegen aan een taak

U kunt meldingen set instellen die verstuurd moeten worden tijdens het uitvoeren van een opdracht en bij individuele deeltaken voor de volgende gebeurtenissen:

  • Beginnen
  • Geslaagde voltooiing
  • Falen
  • De duur overschrijdt een geconfigureerde drempelwaarde

U kunt meldingen verzenden naar een of meer e-mailadressen of bestemmingen van derden, zoals Slack, Microsoft Teams, PagerDuty of een webhookservice. In dit artikel worden de verschillende manieren beschreven waarop u meldingen op taakniveau kunt set.

systeembestemmingen van derden toevoegen

U kunt meldingen set die moeten worden bezorgd bij systemen van derden. Systeembestemmingen van derden kunnen worden geïntegreerd met populaire meldingshulpprogramma's, waaronder Slack, PagerDuty, Microsoft Teams en HTTP-webhooks. Een beheerder moet systeemdoelen configureren.

Als u systeembestemmingen wilt configureren, gaat u naar de pagina met beheerdersinstellingen, klikt u op Systeemmeldingen bewerken en klikt u vervolgens op Nieuwe bestemming maken. Voor elke taak of taak kunt u maximaal drie systeembestemmingen configureren voor elk type meldingsevenement. Zie pagina met beheerdersinstellingen.

Belangrijk

De inhoud van Slack- en Microsoft Teams-berichten kan in toekomstige releases veranderen. U moet geen clients of verwerking implementeren die afhankelijk zijn van de specifieke inhoud of opmaak van deze berichten. Als u een specifieke schema of opmaak voor meldingen nodig hebt, raadt Databricks u aan een door de gebruiker gedefinieerde webhook te configureren.

Meldingen voor een taak configureren

Voordat u begint, moet u rekening houden met het volgende:

  • Meldingen op taakniveau worden niet verzonden wanneer mislukte taken opnieuw worden geprobeerd. Als u een melding wilt ontvangen na elke mislukte taak, gebruikt u in plaats daarvan taakmeldingen. Als u meldingen voor taakuitvoeringen wilt toevoegen, klikt u op Toevoegen naast Meldingen in het taakvenster wanneer u een taak toevoegt of bewerkt.
  • Voor elke taak of taak kunt u maximaal drie systeembestemmingen configureren voor elk type meldingsevenement.
  • Een taak die is voltooid in een Geslaagd met fouten wordt beschouwd als een succesvolle status. Als u een melding wilt ontvangen wanneer taken in deze status zijn voltooid, moet u select Success selecteren wanneer u meldingen configureert.
  • Als u een melding wilt ontvangen wanneer uw taak een duur limitoverschrijdt, moet u set de limit.

Ga als volgt te werk om een of meer meldingen toe te voegen wanneer een taakuitvoering begint, is voltooid of mislukt:

  1. Schuif in het deelvenster Taakdetails voor uw taak omlaag naar de sectie Taakmeldingen en klik vervolgens op Meldingen bewerken.
  2. Klik in de linkerbenedenhoek op Melding toevoegen.
  3. In doelselecte-mailadres of een systeembestemming.
  4. Select de selectievakjes voor elk type gebeurtenis waarvoor u een melding wilt ontvangen: Start, Succes, Mislukking, Duurwaarschuwing, of Streamingachterstand.
  5. Als u een andere bestemming wilt configureren, klikt u nogmaals op Melding toevoegen en volgt u de vorige stappen.
  6. Nadat u alle meldingen hebt geconfigureerd, klikt u op Opslaan.

Meldingen configureren voor trage taken

Als u een verwachte duur voor een taakhebt geconfigureerd, kunt u een e-mail of systeemmelding toevoegen als de taak of opdracht de geconfigureerde drempelwaarde overschrijdt. Als u een melding wilt ontvangen voor een taak of opdracht die een drempelwaarde voor een duur overschrijdt, gebruikt u de selectwaarschuwing voor duur wanneer u een melding toevoegt of bewerkt. Als u een melding wilt ontvangen voor een taak of opdracht die een streamingachterstandmetriek overschrijdt, selectstreamingachterstand wanneer u een melding toevoegt of bewerkt.

Het volgende is van toepassing op metrische gegevens voor streamingachterstand:

  • Meldingen worden verzonden wanneer de gemiddelde achterstand gedurende een periode van tien minuten de gedefinieerde drempelwaarde overschrijdt.
  • Om overmatige berichten te voorkomen, wacht Azure Databricks 30 minuten voordat wordt bepaald of een ander bericht moet worden verzonden. Terwijl de achterstand hoog blijft, ontvangt u updates met intervallen van 30 minuten.

Meldingen filteren voor overgeslagen of geannuleerde uitvoeringen

U kunt het aantal verzonden meldingen verminderen door meldingen voor overgeslagen of geannuleerde uitvoeringen uit te filteren. Als u meldingen wilt filteren, selectMeldingen dempen voor overgeslagen uitvoeringen of Meldingen dempen voor geannuleerde uitvoeringen wanneer u e-mailmeldingen of systeemmeldingen toevoegt of wijzigt.

Taken worden standaard drie keer opnieuw geprobeerd voordat ze volledig mislukken. Wanneer u taakmeldingen configureert, kunt u meldingen selectdempen totdat de laatste poging om alle meldingen te filteren totdat de laatste poging is gedaan.

Notitie

Wanneer u selectMeldingen dempen voor overgeslagen uitvoeringen of Meldingen dempen voor geannuleerde uitvoeringen voor een taak, worden er geen meldingen gefilterd die zijn geconfigureerd voor taaktaken. Als u alle meldingen wilt filteren voor overgeslagen of geannuleerde uitvoeringen, moet u ook eventuele meldingen op taakniveau filteren die u hebt geconfigureerd.

HTTP-webhookpayloads

U kunt HTTP-webhooks zo configureren dat ze worden verzonden op de gebeurtenissen die worden vermeld in de volgende table.

Event_type code Wanneer wordt het verzonden?
jobs.on_start Verzonden wanneer een uitvoering wordt gestart.
jobs.on_success Verzonden wanneer een uitvoering stopt en is voltooid in een status van succes of succes met enkele mislukkingen.
jobs.on_failure Verzonden wanneer een proces in een mislukte status stopt.
jobs.on_duration_warning_threshold_exceeded Wordt verzonden wanneer een taak langer duurt dan de geconfigureerd als verwachte duur.

Hier volgen voorbeelden van nettoladingen die door Azure Databricks naar uw geconfigureerde eindpunt worden verzonden. Deze webhooks kunnen worden toegepast op banen of taken.

Melding voor de start-gebeurtenis van een taakuitvoering:

{
  "event_type": "jobs.on_start",
  "workspace_id": "your_workspace_id",
  "run": {
    "run_id": "run_id"
  },
  "job": {
    "job_id": "job_id",
    "name": "job_name"
  }
}

Melding voor een start-gebeurtenis voor het uitvoeren van een taak:

{
  "event_type": "jobs.on_start",
  "workspace_id": "your_workspace_id",
  "task": {
    "task_key": "task_name"
  },
  "run": {
    "run_id": "run_id_of_task"
    "parent_run_id": "run_id_of_parent_job_run"
  },
  "job": {
    "job_id": "job_id",
    "name": "job_name"
  }
}

Melding voor een mislukte taakuitvoering:

{
  "event_type": "jobs.on_failure",
  "workspace_id": "your_workspace_id",
  "run": {
    "run_id": "run_id"
  },
  "job": {
    "job_id": "job_id",
    "name": "job_name"
  }
}

Melding voor geslaagde uitvoering van een taak:

{
  "event_type": "jobs.on_success",
  "workspace_id": "your_workspace_id",
  "task": {
    "task_key": "task_name"
  },
  "run": {
    "run_id": "run_id_of_task"
    "parent_run_id": "run_id_of_parent_job_run"
  },
  "job": {
    "job_id": "job_id",
    "name": "job_name"
  }
}