Erstellen einer Produktionspipeline #1

Du hast viel darüber gelernt, wie Airflow funktioniert – jetzt ist es Zeit, deinen Workflow in eine Produktionspipeline zu überführen, die aus vielen Objekten wie Sensoren und Operatoren besteht. Deine Chefin/dein Chef möchte sehen, dass dieser Workflow automatisiert ist und SLA-Reporting liefern kann, weil das dem Vertrieb hilft, einen laufenden Deal abzuschließen. Die potenzielle Kundin/der potenzielle Kunde hat signalisiert, dass sie sich für den genannten Datendienst anmelden, sobald sie automatisierte Aktualisierungen sehen.

Aus dem Prozess weißt du, dass Verkaufsdaten ins System hochgeladen werden. Sobald die Daten hochgeladen sind, sollte eine neue Datei erstellt werden, um die vollständige Verarbeitung zu starten – aber etwas funktioniert nicht richtig.

Sieh dir den Quellcode des DAG an, um festzustellen, ob noch etwas hinzugefügt werden muss.