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
Praktische interactieve oefening
Zet theorie om in actie met een van onze interactieve oefeningen.
Begin met trainen