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:
- Schuif in het deelvenster Taakdetails voor uw taak omlaag naar de sectie Taakmeldingen en klik vervolgens op Meldingen bewerken.
- Klik in de linkerbenedenhoek op Melding toevoegen.
- In doelselecte-mailadres of een systeembestemming.
- Select de selectievakjes voor elk type gebeurtenis waarvoor u een melding wilt ontvangen: Start, Succes, Mislukking, Duurwaarschuwing, of Streamingachterstand.
- Als u een andere bestemming wilt configureren, klikt u nogmaals op Melding toevoegen en volgt u de vorige stappen.
- 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"
}
}