astronomer_airflow_dump_connections.py

from airflow import DAG
from airflow.models import Connection
from airflow.operators import PythonOperator
from airflow.utils import db
from datetime import datetime
from yaml import dump


def dump_connections(**kwargs):
    with db.create_session() as session:
        connections = session.query(Connection).all()

    print(dump({
        'airflow': {
            'connections': [
                {
                    (column if column.startswith('conn_') else 'conn_' + column): getattr(connection, column)
                    for column in ['conn_id', 'conn_type', 'schema', 'host', 'port', 'login', 'password', 'extra']
                }
                for connection in connections
            ]
        }
    }, sort_keys=False))


with DAG(
    dag_id='dump-connections',
    start_date=datetime.min,
) as dag:
    PythonOperator(
        task_id='dump-connections',
        python_callable=dump_connections,
    )