from airflow.hooks.postgres_hook import PostgresHook
pg_hook = PostgresHook('my_db', schema='my_schema')
在这个例子中,“my_db”连接的密码已加密,并且可以在Airflow UI中使用。
from airflow.hooks.http_hook import HttpHook
http_hook = HttpHook('my_http_conn')
在这个例子中,“my_http_conn”连接的额外参数已被加密,并且可以在Airflow UI中使用。