Apache Airflow est une plate-forme de gestion de flux de travail permettant de créer, de planifier et de surveiller par programme des flux de travail sous forme de graphiques acycliques dirigés (DAG) de tâches.
J'ai installé Python, Docker sur ma machine et j'essaye d'importer le
de airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator mais lorsque je connec ...
J'exécute Dataflow à partir de Google Cloud Composer, le script de flux de données contient des dépendances non standard telles que zeep, googleads.
qui doivent ê ...
Le processus du planificateur de flux d'air se bloque si nous commençons à activer le DAG et le DAG de déclenchement à partir du serveur Web Airflow. Versi ...
Mon DAG est censé s'exécuter toutes les heures. Je tire chaque heure de données d'une source s3 et je les traite. Parfois, la tâche prend plus d'une heure. À ce m ...
