Eine Pipeline idempotent machen
Die Pipeline eines Kollegen hängt bei jedem Lauf Verkaufsdaten an, sodass Wiederholungen und Backfills Duplikate erzeugen. Sowohl die Tabellen staging als auch sales haben eine Spalte date (Format YYYY-MM-DD).
Dein Team muss die Pipeline idempotent machen: Filtere die Staging-Abfrage nach dem logischen Datum und füge einen preoperator hinzu, der vorhandene Zeilen aus der Tabelle sales löscht.
Diese Übung ist Teil des Kurses
<Kurs>Data-Pipelines mit Airflow aufbauen</Kurs>Interaktive praktische Übung
Verwandle Theorie mit einer unserer interaktiven Übungen in die Praxis
Übung starten