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

Connected

Exercice

Créer un FileSensor

Après avoir lu au sujet des FileSensors, vous décidez d'en implémenter un simple pour vous familiariser avec certains de leurs paramètres. Ce FileSensor servira à vérifier qu'un fichier de données précis est présent avant de poursuivre.

Un FileSensor interroge la présence du fichier à intervalles réguliers et arrête l'attente une fois que timeout secondes se sont écoulées. Avec mode='reschedule', l'emplacement du travailleur est libéré entre les interrogations.

Instructions

100 XP
  • Importez la bibliothèque appropriée pour utiliser un FileSensor.
  • Assignez la référence precheck à l'objet FileSensor.
  • Configurez le FileSensor pour qu'il cherche le fichier "salesdata_ready.csv".
  • Réglez le délai d'expiration (timeout) à 5 minutes.