API Airflow

Apache Airflow est un système de gestion de flux de travail ETL (Extraction, Transformation, Chargement) beaucoup utilisé pour la transformation de données. Il est codé en python et les workflow sont écrits via des scripts pythons.

Pour faciliter la gestion, Apache Airflow prend en charge une gamme de points de terminaison d’API REST sur ses objets. Cette section fournit une vue d’ensemble de la conception de l’API, des méthodes et des cas d’utilisation pris en charge.

# Authnetification API Rest Airflow

L’authentification pour l’API est gérée séparément de l’authentification Web. La valeur par défaut est de refuser toutes les requêtes 

#Etape 1 :

#Rendez vous dans le fichier airflow.cfg et modifiez les lignes suivantes
auth_backend = airflow.api.auth.backend.deny_all
en 
auth_backend = airflow.api.auth.backend.basic_auth

endpoint_url = http://localhost:8080/api/v1/
en
endpoint_url = http://votre-adresse:8080/api/v1/

#Etape 2

# Vérifiez que l'autorisation marche très bien en exécutant la commande suivante:
 airflow config get-value api auth_backend

Sortie:
airflow.api.auth.backend.basic_auth

#Etape 3

# Vérifiez que l'API fonctionne bien en exécutant votre première requête:
 curl --verbose 'http://votre-adresse:8080/api/v1/dags' --user "username:mot de passe"

Si vous obtenez une sorti correcte, votre API fonctionne.

Référez vous à cet article pour en savoir plus sur les requêtes.