BaseSQLOperator

Apache Airflow

This is a base class for generic SQL Operator to get a DB Hook

View on GitHub

Last Updated: May. 25, 2021

Access Instructions

Install the Apache Airflow provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Documentation

This is a base class for generic SQL Operator to get a DB Hook

The provided method is .get_db_hook(). The default behavior will try to retrieve the DB hook based on connection type. You can custom the behavior by overriding the .get_db_hook() method.

Was this page helpful?