airflow-dag-getting-connection-details.py

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.hooks.base_hook import BaseHook
from airflow.utils.dates import days_ago
default_args = {
  'start_date': days_ago(2)
}

dag = DAG('test-connection-hook', default_args = default_args, description='Test connection details', schedule_interval='@once')

def _operator_call_get_details_from_conn(**op_kwargs):
  conn = BaseHook.get_connection('test_connection_name')
  print("{}, {}".format(conn.id, conn.password))

with dag:
  getDetailsFromConnection = PythonOperator(task_id = 'getDetailsFromConnection', python_callable = _operator_call_get_details_from_conn)