Snowflake

apache-airflow-providers-snowflake

Snowflake

Works with Airflow 2.11+

Install:

pip install apache-airflow-providers-snowflake==6.11.0

Extras:

Version:

Airflow

2.11+

Python

>=3.10

Dependencies (12)

Show all Hide

apache-airflow>=2.11.0 apache-airflow-providers-common-compat>=1.12.0 apache-airflow-providers-common-sql>=1.32.0 pandas>=2.1.2; python_version <"3.13" pandas>=2.2.3; python_version >="3.13" pyarrow>=16.1.0; python_version < '3.13' pyarrow>=18.0.0; python_version >= '3.13' snowflake-connector-python>=3.16.0 snowflake-sqlalchemy>=1.7.0 snowflake-snowpark-python>=1.17.0,<9999;python_version<'3.12' snowflake-snowpark-python>=1.27.0,<9999;python_version>='3.12' and python_version<'3.14' setuptools>=80.0.0,<9999

Connections (1)

Modules

SnowflakeCheckOperator

Perform a check against Snowflake.

airflow.providers.snowflake.operators.snowflake.SnowflakeCheckOperator

View Docs Source

SnowflakeIntervalCheckOperator

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

airflow.providers.snowflake.operators.snowflake.SnowflakeIntervalCheckOperator

View Docs Source

SnowflakeSqlApiOperator

Implemented Snowflake SQL API Operator to support multiple SQL statements sequentially.

airflow.providers.snowflake.operators.snowflake.SnowflakeSqlApiOperator

View Docs Source

SnowflakeValueCheckOperator

Performs a simple check using sql code against a specified value, within a certain level of tolerance.

airflow.providers.snowflake.operators.snowflake.SnowflakeValueCheckOperator

View Docs Source

SnowparkOperator

Executes a Python function with Snowpark Python code.

airflow.providers.snowflake.operators.snowpark.SnowparkOperator

View Docs Source

SnowflakeHook

A client to interact with Snowflake.

airflow.providers.snowflake.hooks.snowflake.SnowflakeHook

View Docs Source

SnowflakeSqlApiHook

A client to interact with Snowflake using SQL API and submit multiple SQL statements in a single request.

airflow.providers.snowflake.hooks.snowflake_sql_api.SnowflakeSqlApiHook

View Docs Source

SnowflakeSqlApiTrigger

Fetch the status for the query ids passed.

airflow.providers.snowflake.triggers.snowflake_trigger.SnowflakeSqlApiTrigger

View Docs Source

CopyFromExternalStageToSnowflakeOperator

Executes a COPY INTO command to load files from an external stage from clouds to Snowflake.

airflow.providers.snowflake.transfers.copy_into_snowflake.CopyFromExternalStageToSnowflakeOperator

View Docs Source

@task.snowpark

Wrap a function that contains Snowpark code into an Airflow operator.

airflow.providers.snowflake.decorators.snowpark.snowpark_task

View Docs Source