Snowflake SQL API Operator Async¶
The Snowflake SQL API allows submitting multiple SQL statements in a single request.
In combination with aiohttp, make post request to submit SQL statements for execution,
poll to check the status of the execution of a statement. Fetch query results concurrently
SnowflakeSqlApiOperatorAsync
.
snowflake_op_sql_multiple_stmt = SnowflakeSqlApiOperatorAsync(
task_id="snowflake_op_sql_multiple_stmt",
sql="create or replace table user_test (i int); insert into user_test (i) "
"values (200); insert into user_test (i) values (300); select i from user_test order by i;",
statement_count=4,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/snowflake/example_dags/example_snowflake_sql_api.py