Een Cloud Composer DAG-taak is afhankelijk van een externe service; u moet een melding ontvangen wanneer de taak mislukt. Wat moet u doen?

De onfailurecallback parameter in een Airflow operator is specifiek ontworpen om een Python-callable functie aan te roepen wanneer de taak mislukt. Dit is de meest directe en aanbevolen manier om een melding te ontvangen bij een taakfout. Het koppelen van een notificatiefunctie aan de onretrycallback parameter zou meldingen genereren bij elke herpoging, niet alleen bij de uiteindelijke mislukking. Een Cloud Monitoring-waarschuwing op de slamissed metric zou pas afgaan als de Service Level Agreement (SLA) wordt overschreden, wat niet noodzakelijk direct correleert met een taakfout. De slamisscallback parameter is vergelijkbaar en wordt geactiveerd wanneer de SLA wordt gemist, niet wanneer de taak zelf mislukt.