Common SQL

apache-airflow-providers-common-sql

Common SQL Provider

Works with Airflow 2.11+

Install:

pip install apache-airflow-providers-common-sql==1.33.0

Extras:

Version:

Airflow

2.11+

Python

>=3.10

Dependencies (5)

Show all Hide

apache-airflow>=2.11.0 apache-airflow-providers-common-compat>=1.14.1 sqlparse>=0.5.1 more-itertools>=9.0.0 methodtools>=0.4.7

Connections (0)

No connections

Modules

BranchSQLOperator

Allows a DAG to "branch" or follow a specified path based on the results of a SQL query.

airflow.providers.common.sql.operators.sql.BranchSQLOperator

View Docs Source

SQLCheckOperator

Performs checks against a db.

airflow.providers.common.sql.operators.sql.SQLCheckOperator

View Docs Source

SQLColumnCheckOperator

Performs one or more of the templated checks in the column_checks dictionary.

airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator

View Docs Source

SQLExecuteQueryOperator

Executes SQL code in a specific database.

airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator

View Docs Source

SQLInsertRowsOperator

Insert rows (e.g. a collection of tuples) into a database table directly from an XCom or Python data structure.

airflow.providers.common.sql.operators.sql.SQLInsertRowsOperator

View Docs Source

SQLIntervalCheckOperator

Check that metrics given as SQL expressions are within tolerance of the ones from days_back before.

airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator

View Docs Source

SQLTableCheckOperator

Performs one or more of the checks provided in the checks dictionary.

airflow.providers.common.sql.operators.sql.SQLTableCheckOperator

View Docs Source

SQLThresholdCheckOperator

Performs a value check using sql code against a minimum threshold and a maximum threshold.

airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator

View Docs Source

SQLValueCheckOperator

Performs a simple value check using sql code.

airflow.providers.common.sql.operators.sql.SQLValueCheckOperator

View Docs Source

GenericTransfer

Moves data from a connection to another.

airflow.providers.common.sql.operators.generic_transfer.GenericTransfer

View Docs Source

AnalyticsOperator

Operator to run queries on various datasource's stored in object stores like S3, GCS, Azure, etc.

airflow.providers.common.sql.operators.analytics.AnalyticsOperator

View Docs Source

DbApiHook

Abstract base class for sql hooks.

airflow.providers.common.sql.hooks.sql.DbApiHook

View Docs Source

SqlSensor

Run a SQL statement repeatedly until a criteria is met.

airflow.providers.common.sql.sensors.sql.SqlSensor

View Docs Source

SQLExecuteQueryTrigger

A trigger that executes SQL code in async mode.

airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger

View Docs Source

@task.sql

Wrap a Python function into a SQLExecuteQueryOperator.

airflow.providers.common.sql.decorators.sql.sql_task

View Docs Source

@task.analytics

Wrap a Python function into a AnalyticsOperator.

airflow.providers.common.sql.decorators.analytics.analytics_task

View Docs Source