Skip to main content

Templating for Airflow connections

Project description

Templating for Airflow connections

PyPI version

The connection plugin contains an Airflow macro for templating connections in tasks. You can use it like this:

# prints 'mysql'
{{ macros.connection_plugin.get_conn('airflow_db').host }}

connection_plugin.get_conn returns the Connection object that you can interact with as described in the documentation.

Installation

pip install airflow-connection-plugin

Demo

To start the docker container simply run the following command in the root directory:

cd example && docker-compose up

After that you can reach the airflow frontend via http://localhost:8080. You will find an example DAG that demonstrates how to retrieve different connection information.

Attention: Be especially careful when using passwords in templates.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

airflow-connection-plugin-1.0.0.tar.gz (2.1 kB view hashes)

Uploaded Source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page