1. Învăţa
    2. /
  2. Courses
    3. /
  3. Introducere în Apache Airflow în Python
Connected

exercise

Crearea unui DAG simplu

Ai petrecut ceva timp explorând componentele Airflow și ești curios să îți testezi propriile fluxuri de lucru. Pentru început, decizi să definești parametrii impliciți și să creezi un obiect DAG pentru fluxul tău de lucru.

Obiectul datetime a fost deja importat pentru tine.

Instrucțiuni

100 XP
  • Importă obiectul DAG din Airflow; reține că este sensibil la majuscule.
  • Definește decoratorul DAG și numește DAG-ul example_etl.
  • Apelează funcția DAG la sfârșitul fișierului de cod.