creating airflow connections via python

create_connection.py

from airflow import settings
from airflow.hooks import BaseHook
from airflow.models import Connection

# Start a session
session = settings.Session()

# Create a new connection - these are not unique by name!
cnx_kwargs =         {
            "conn_id": "mssql_named",
            "conn_type": "mssql",
            "host": "hostname",
            "login": "airflow",
            "password": "pass",
            "schema": "db",
            "port": "1433"
        }
cnx = Connection(**cnx_kwargs)
session.add(cnx)
session.commit()

# Deletes the connection
session.delete(cnx)
session.commit()