Machine Learning Orchestration
Project description
Dbnd Airflow Export plugin
The plugin
dbnd-airflow-export-plugin
is a plugin for Airflow system, enables you to fetch data from Airflow database and DAG folder.
This Airflow side module is one of two components allows you to observe your Airflow data with Databand
system.
What does it do?
The plugin exposes a REST Api within GET
/export_data
which, expects since
(utc).
This api returns json with all the relevant information scraped from airflow system.
Configuring Airflow instance
To improve performance and reduce the runtime overhead on airflow database, we advise to add an index on end_date column to task_instance and dag_run tables i.e.
CREATE INDEX dbnd_ti_end_date_ind ON task_instance (end_date);
CREATE INDEX dbnd_dr_end_date_ind ON dag_run (end_date);
Installation
In order to install dbnd-airflow-export-plugin
we are using Airflow plugin system.
pip install databand[airflow-export]
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
File details
Details for the file dbnd-airflow-export-0.34.0.tar.gz
.
File metadata
- Download URL: dbnd-airflow-export-0.34.0.tar.gz
- Upload date:
- Size: 15.9 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.3.0 pkginfo/1.7.0 requests/2.25.1 setuptools/53.0.0 requests-toolbelt/0.9.1 tqdm/4.56.0 CPython/3.6.12
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 504bff709ac5a49f649b8c1114ecc84c57a906c194dab0a91089c62f475167cb |
|
MD5 | c2628868dc3b4e670537e85266bf0c9d |
|
BLAKE2b-256 | 9eb151a98463b50ddf39dcad9e4336d072434595004f70b4255e429cea277ca3 |
File details
Details for the file dbnd_airflow_export-0.34.0-py2.py3-none-any.whl
.
File metadata
- Download URL: dbnd_airflow_export-0.34.0-py2.py3-none-any.whl
- Upload date:
- Size: 18.2 kB
- Tags: Python 2, Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.3.0 pkginfo/1.7.0 requests/2.25.1 setuptools/53.0.0 requests-toolbelt/0.9.1 tqdm/4.56.0 CPython/3.6.12
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8b47563dec02ea516621f134a097ff85f1c181430b9ff1a330e6db9346c34a89 |
|
MD5 | 39f7769af4c41615d323071a73ca9803 |
|
BLAKE2b-256 | 7130c7a6f0ee75dcb0d45cee82e91e1943fd2735263b5f1be2c06db4b9a6ae83 |