airflow_client_basic_auth_list_dags_quickstart.py

1import time
2import airflow_client.client
3from airflow_client.client.api import dag_api
4from airflow_client.client.model.dag_collection import DAGCollection
5from pprint import pprint
6
7# Defining the host is optional and defaults to http://localhost/api/v1
8# See configuration.py for a list of all supported configuration parameters.
9configuration = airflow_client.client.Configuration(
10    host = "http://localhost:8080/api/v1"
11)
12
13# Configure HTTP basic authorization: Basic
14configuration.username = 'admin'
15configuration.password = 'admin'
16
17# Enter a context with an instance of the API client
18with airflow_client.client.ApiClient(configuration) as api_client:
19    # Create an instance of the API class
20    api_instance = dag_api.DAGApi(api_client)
21
22    try:
23        # Get all DAGs
24        api_response = api_instance.get_dags()
25        pprint(api_response)
26    except airflow_client.client.ApiException as e:
27        print("Exception when calling DAGApi->get_dags: %s\n" % e)