SQLThresholdCheckOperator
Common SQLPerforms a value check using sql code against a minimum threshold and a maximum threshold. Thresholds can be in the form of a numeric value OR a sql statement that results a numeric.
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
sqlRequiredthe sql to be executed. (templated)
conn_idthe connection ID used to connect to the database.
databasename of database which overwrite the defined one in connection
min_thresholdRequirednumerical value or min threshold sql to be executed (templated)
max_thresholdRequirednumerical value or max threshold sql to be executed (templated)
Documentation
Performs a value check using sql code against a minimum threshold and a maximum threshold. Thresholds can be in the form of a numeric value OR a sql statement that results a numeric.