A plugin for interacting airflow and treasuredata to make our life easier, including two components:
- TreasureHook
- TreasureToPostgresOperator
- Git clone this repository
- Move treasuredata_plugin to {AIRFLOW_PLUGINS_FOLDER}
- Restart airflow
from airflow.hooks import TreasureHook
from airflow.operators import TreasureToPostgresOperator