Definování BashOperatoru pomocí @task.bash

Bash task ti umožňuje zadat libovolný shellový příkaz nebo skript a zařadit ho do Airflow workflow. Je to skvělý způsob, jak Airflow začít využívat ve svém prostředí.

Doposud jsi ručně spouštěl/a skripty pro čištění dat (konkrétně skript cleanup.sh) před jejich předáním kolegům z týmu Data Analytics. S přibývajícími úkoly ti začíná být jasné, že ruční spouštění všeho je čím dál náročnější — natož řešit chyby nebo opakované spouštění. Chceš proto tento jednoduchý skript implementovat jako Airflow operátor.

Objekty dag a task pro Airflow jsou už naimportované.

Toto cvičení je součástí kurzu

Úvod do Apache Airflow v Pythonu

Zobrazit kurz

Pokyny k cvičení

Použij dekorátor @task.bash k definování tasku.
Pojmenuj metodu cleanup_task.
Zajisti, aby task vracel cleanup.sh.

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

@dag(
  dag_id='analytics_dag', 
  start_date=datetime(2026,1,1)
)
def analytics_dag():
  # Specify a Bash task
  @____
  def ____():
    return '____'
  
  # Run the task
  cleanup_task()

analytics_dag()

Upravit a spustit kód