1. Apprendre
    2. /
  2. Cours
    3. /
  3. Introduction à Apache Airflow en Python
Connected

Exercice

Plus de @tasks

Pour poursuivre la mise en place de votre flux de travail, vous devez ajouter une autre étape pour analyser et enregistrer les changements du fichier téléchargé. Le Dag process_sales est défini et la tâche pull_file y est déjà ajoutée. Dans ce cas, la fonction Python est déjà définie pour vous : parse_file(inputfile, outputfile).

Notez que, souvent, lorsque vous implémentez des tâches Airflow, vous ne comprendrez pas nécessairement chacune des étapes qui vous sont fournies. Tant que vous savez encapsuler ces étapes dans la structure d'Airflow, vous pourrez mettre en œuvre le flux de travail souhaité.

Instructions

100 XP
  • Créez une tâche Airflow en utilisant la méthode parse_file.
  • Appelez la tâche avec les arguments nécessaires.