When used in combination, Airflow and Snowflake help data teams orchestrate and automate end-to-end ETL/ELT operations to power analytics insights and MLOps.
This technical cheat sheet contains core tips with code examples to help you make the most of using Airflow and Snowflake together. You’ll learn:
- How to define a Snowflake Airflow connection using key-pair authentication
- Multiple options for executing SQL in Snowflake with Airflow
- Options for SQL parameterization with the SQLExecuteQueryOperator
- How to run Snowpark queries with @task.snowpark
- Methods for running data quality checks on Snowflake tables
You’ll walk away with a practical reference you can start using immediately to write your Snowflake DAGs.