BaseSQLOperator

Common SQL

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

View on GitHub

Last Updated: Mar. 7, 2023

Access Instructions

Install the Common SQL provider package into your Airflow environment.

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

Parameters

conn_idreference to a specific database

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 customize the behavior by overriding the .get_db_hook() method.

Was this page helpful?