• Home
• Index

Index

_

__mapper_args__ (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute)

__version__ (in module airflow.providers.common.sql)

A

accept_none (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) airflow.providers.common.sql module airflow.providers.common.sql.dialects module airflow.providers.common.sql.dialects.dialect module airflow.providers.common.sql.get_provider_info module airflow.providers.common.sql.hooks module airflow.providers.common.sql.hooks.handlers module airflow.providers.common.sql.hooks.sql module airflow.providers.common.sql.operators module airflow.providers.common.sql.operators.generic_transfer module

airflow.providers.common.sql.operators.sql module airflow.providers.common.sql.sensors module airflow.providers.common.sql.sensors.sql module airflow.providers.common.sql.triggers module airflow.providers.common.sql.triggers.sql module airflow.providers.common.sql.version_compat module AIRFLOW_DB_METADATA_TABLE (in module tests.system.common.sql.example_sql_column_table_check) (in module tests.system.common.sql.example_sql_execute_query) AIRFLOW_V_3_0_PLUS (in module airflow.providers.common.sql.version_compat) AIRFLOW_V_3_1_PLUS (in module airflow.providers.common.sql.version_compat) autocommit (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute)

B

BaseSQLOperator (class in airflow.providers.common.sql.operators.sql) BranchSQLOperator (class in airflow.providers.common.sql.operators.sql)

bulk_dump() (airflow.providers.common.sql.hooks.sql.DbApiHook method) bulk_load() (airflow.providers.common.sql.hooks.sql.DbApiHook method)

C

check_value() (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator method) checks (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) column_check (in module tests.system.common.sql.example_sql_column_table_check) column_checks (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) column_mapping (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) conn_id (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger attribute) conn_id_field (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) conn_name_attr (airflow.providers.common.sql.hooks.sql.DbApiHook attribute)

connect() (airflow.providers.common.sql.hooks.sql.ConnectorProtocol method) connection (airflow.providers.common.sql.hooks.sql.DbApiHook property) connection_args (in module tests.system.common.sql.example_generic_transfer) (in module tests.system.common.sql.example_sql_column_table_check) (in module tests.system.common.sql.example_sql_execute_query) (in module tests.system.common.sql.example_sql_threshold_check) connection_extra (airflow.providers.common.sql.hooks.sql.DbApiHook property) connection_extra_lower (airflow.providers.common.sql.hooks.sql.DbApiHook property) connector (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) ConnectorProtocol (class in airflow.providers.common.sql.hooks.sql)

D

database (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) date_filter_column (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) days_back (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) DbApiHook (class in airflow.providers.common.sql.hooks.sql) default_conn_name (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) default_output_processor() (in module airflow.providers.common.sql.operators.sql) descriptions (airflow.providers.common.sql.hooks.sql.DbApiHook attribute)

destination_conn_id (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) destination_hook (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer property) destination_hook_params (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) destination_table (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) dialect (airflow.providers.common.sql.hooks.sql.DbApiHook property) Dialect (class in airflow.providers.common.sql.dialects.dialect) dialect_name (airflow.providers.common.sql.hooks.sql.DbApiHook property)

E

escape_column_names (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property) escape_word() (airflow.providers.common.sql.dialects.dialect.Dialect method) escape_word_format (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property) execute() (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer method) (airflow.providers.common.sql.operators.sql.BranchSQLOperator method) (airflow.providers.common.sql.operators.sql.SQLCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator method) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator method) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator method)

execute_complete() (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer method) execute_query (in module tests.system.common.sql.example_sql_execute_query) extract_schema_from_table() (airflow.providers.common.sql.dialects.dialect.Dialect class method)

F

fail_on_empty (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) failure (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) fetch_all_handler() (in module airflow.providers.common.sql.hooks.handlers) (in module airflow.providers.common.sql.hooks.sql)

fetch_one_handler() (in module airflow.providers.common.sql.hooks.handlers) (in module airflow.providers.common.sql.hooks.sql) follow_task_ids_if_false (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) follow_task_ids_if_true (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute)

G

generate_insert_sql() (airflow.providers.common.sql.dialects.dialect.Dialect method) generate_replace_sql() (airflow.providers.common.sql.dialects.dialect.Dialect method) GenericTransfer (class in airflow.providers.common.sql.operators.generic_transfer) get_autocommit() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_column_names() (airflow.providers.common.sql.dialects.dialect.Dialect method) get_conn() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_conn_id() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_cursor() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_db_hook() (airflow.providers.common.sql.operators.sql.BaseSQLOperator method) get_db_log_messages() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_df() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_df_by_chunks() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_first() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_hook() (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer class method) (airflow.providers.common.sql.operators.sql.BaseSQLOperator class method) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger method) get_openlineage_authority_part() (airflow.providers.common.sql.hooks.sql.DbApiHook static method)

get_openlineage_database_dialect() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_openlineage_database_info() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_openlineage_database_specific_lineage() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_openlineage_default_schema() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_openlineage_facets_on_complete() (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator method) get_openlineage_facets_on_start() (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator method) get_paginated_sql() (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer method) get_pandas_df() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_pandas_df_by_chunks() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_primary_keys() (airflow.providers.common.sql.dialects.dialect.Dialect method) get_provider_info() (in module airflow.providers.common.sql.get_provider_info) get_records() (airflow.providers.common.sql.dialects.dialect.Dialect method) (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_reserved_words() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_sqlalchemy_engine() (airflow.providers.common.sql.hooks.sql.DbApiHook method) get_target_fields() (airflow.providers.common.sql.dialects.dialect.Dialect method) get_uri() (airflow.providers.common.sql.hooks.sql.DbApiHook method)

H

handler (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) has_tolerance (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) hook (airflow.providers.common.sql.dialects.dialect.Dialect attribute)

hook_params (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger attribute)

I

ignore_zero (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) insert_args (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) insert_rows() (airflow.providers.common.sql.hooks.sql.DbApiHook method)

insert_statement_format (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property) inspector (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property)

L

last_description (airflow.providers.common.sql.hooks.sql.DbApiHook property)

log_sql (airflow.providers.common.sql.hooks.sql.DbApiHook attribute)

M

max_threshold (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) metrics_sorted (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) metrics_thresholds (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) min_threshold (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) module airflow.providers.common.sql airflow.providers.common.sql.dialects airflow.providers.common.sql.dialects.dialect airflow.providers.common.sql.get_provider_info airflow.providers.common.sql.hooks airflow.providers.common.sql.hooks.handlers airflow.providers.common.sql.hooks.sql airflow.providers.common.sql.operators airflow.providers.common.sql.operators.generic_transfer airflow.providers.common.sql.operators.sql airflow.providers.common.sql.sensors airflow.providers.common.sql.sensors.sql airflow.providers.common.sql.triggers airflow.providers.common.sql.triggers.sql airflow.providers.common.sql.version_compat tests.system.common.sql tests.system.common.sql.example_generic_transfer tests.system.common.sql.example_sql_column_table_check tests.system.common.sql.example_sql_execute_query tests.system.common.sql.example_sql_threshold_check

P

page_size (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) parameters (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) parse_boolean (in module airflow.providers.common.sql.operators.sql) partition_clause (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute)

pass_value (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) pattern (airflow.providers.common.sql.dialects.dialect.Dialect attribute) placeholder (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property) poke() (airflow.providers.common.sql.sensors.sql.SqlSensor method) preoperator (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) prepare_template() (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator method) push() (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator method)

R

ratio_formula (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) ratio_formulas (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) render_template_fields() (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer method) replace_statement_format (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property) requires_result_fetch (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) reserved_words (airflow.providers.common.sql.dialects.dialect.Dialect property) (airflow.providers.common.sql.hooks.sql.DbApiHook property)

resolve_dialects() (in module airflow.providers.common.sql.hooks.sql) retry_on_failure (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) return_last (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) return_single_query_results() (in module airflow.providers.common.sql.hooks.handlers) (in module airflow.providers.common.sql.hooks.sql) run() (airflow.providers.common.sql.dialects.dialect.Dialect method) (airflow.providers.common.sql.hooks.sql.DbApiHook method) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger method)

S

selector (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) serialize() (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger method) set_autocommit() (airflow.providers.common.sql.hooks.sql.DbApiHook method) show_return_value_in_logs (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) source_conn_id (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) source_hook (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer property) source_hook_params (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) split_sql_string() (airflow.providers.common.sql.hooks.sql.DbApiHook static method) split_statements (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) sql (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) (airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger attribute) (in module tests.system.common.sql.example_generic_transfer)

sql1 (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) sql2 (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) sql_check_template (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) SQL_PLACEHOLDERS (in module airflow.providers.common.sql.hooks.sql) sqlalchemy_url (airflow.providers.common.sql.hooks.sql.DbApiHook property) SQLCheckOperator (class in airflow.providers.common.sql.operators.sql) SQLColumnCheckOperator (class in airflow.providers.common.sql.operators.sql) SQLExecuteQueryOperator (class in airflow.providers.common.sql.operators.sql) SQLExecuteQueryTrigger (class in airflow.providers.common.sql.triggers.sql) SQLIntervalCheckOperator (class in airflow.providers.common.sql.operators.sql) SqlSensor (class in airflow.providers.common.sql.sensors.sql) SQLTableCheckOperator (class in airflow.providers.common.sql.operators.sql) SQLThresholdCheckOperator (class in airflow.providers.common.sql.operators.sql) SQLValueCheckOperator (class in airflow.providers.common.sql.operators.sql) strip_semicolon (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) strip_sql_string() (airflow.providers.common.sql.hooks.sql.DbApiHook static method) success (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) supports_autocommit (airflow.providers.common.sql.hooks.sql.DbApiHook attribute) supports_executemany (airflow.providers.common.sql.hooks.sql.DbApiHook attribute)

T

T (in module airflow.providers.common.sql.dialects.dialect) (in module airflow.providers.common.sql.hooks.sql) table (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) template_ext (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) template_fields (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) (airflow.providers.common.sql.operators.sql.BaseSQLOperator attribute) (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute) template_fields_renderers (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLColumnCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLTableCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLThresholdCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute)

test_connection() (airflow.providers.common.sql.hooks.sql.DbApiHook method) test_run (in module tests.system.common.sql.example_generic_transfer) (in module tests.system.common.sql.example_sql_column_table_check) (in module tests.system.common.sql.example_sql_execute_query) (in module tests.system.common.sql.example_sql_threshold_check) tests.system.common.sql module tests.system.common.sql.example_generic_transfer module tests.system.common.sql.example_sql_column_table_check module tests.system.common.sql.example_sql_execute_query module tests.system.common.sql.example_sql_threshold_check module threshhold_check (in module tests.system.common.sql.example_sql_threshold_check) tol (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute)

U

ui_color (airflow.providers.common.sql.operators.generic_transfer.GenericTransfer attribute) (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) (airflow.providers.common.sql.operators.sql.SQLCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator attribute) (airflow.providers.common.sql.operators.sql.SQLIntervalCheckOperator attribute) (airflow.providers.common.sql.operators.sql.SQLValueCheckOperator attribute) (airflow.providers.common.sql.sensors.sql.SqlSensor attribute)

ui_fgcolor (airflow.providers.common.sql.operators.sql.BranchSQLOperator attribute) unescape_word() (airflow.providers.common.sql.dialects.dialect.Dialect method)

W

WARNING_MESSAGE (in module airflow.providers.common.sql.hooks.sql)

PreviousNext

Was this entry helpful?