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

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

O

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
O

SQLCheckOperator

Performs checks against a db.

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

SQLColumnCheckOperator

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

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

SQLExecuteQueryOperator

Executes SQL code in a specific database.

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

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
O

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
O

SQLTableCheckOperator

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

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

SQLThresholdCheckOperator

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

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

SQLValueCheckOperator

Performs a simple value check using sql code.

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

GenericTransfer

Moves data from a connection to another.

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

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
H

DbApiHook

Abstract base class for sql hooks.

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

SqlSensor

Run a SQL statement repeatedly until a criteria is met.

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

SQLExecuteQueryTrigger

A trigger that executes SQL code in async mode.

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

@task.sql

Wrap a Python function into a SQLExecuteQueryOperator.

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

@task.analytics

Wrap a Python function into a AnalyticsOperator.

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