Aan de slagGa gratis aan de slag

Een getemplate BashOperator maken

Je hebt met succes een BashOperator gemaakt die een opgegeven databestand opschoont door het script cleandata.sh uit te voeren. Dit werkt, maar vereist helaas dat het script alleen voor de huidige dag wordt gedraaid. Sommige van je databronnen lopen af en toe een paar dagen achter en moeten handmatig worden uitgevoerd.

Je past het script cleandata.sh aan zodat het één argument accepteert: de datum in het formaat YYYYMMDD. Je test werkt op de commandoregel, maar je moet dit nu in je Airflow-DAG implementeren. Gebruik voorlopig de term {{ ds_nodash }} in je template — later zie je precies wat dit betekent.

Deze oefening maakt deel uit van de cursus

Introductie tot Apache Airflow in Python

Cursus bekijken

Praktische interactieve oefening

Zet theorie om in actie met een van onze interactieve oefeningen.

Begin met trainen