airflow.providers.snowflake.transfers.s3_to_snowflake

This module contains AWS S3 to Snowflake operator.

Module Contents

class airflow.providers.snowflake.transfers.s3_to_snowflake.S3ToSnowflakeOperator(*, s3_keys: list, table: str, stage: Any, file_format: str, schema: str, columns_array: Optional[list] = None, autocommit: bool = True, snowflake_conn_id: str = 'snowflake_default', **kwargs)[source]

Bases: airflow.models.BaseOperator

Executes an COPY command to load files from s3 to Snowflake

See also

For more information on how to use this operator, take a look at the guide: S3ToSnowflakeOperator

Parameters

  • s3_keys (list) -- reference to a list of S3 keys

  • table (str) -- reference to a specific table in snowflake database

  • stage (str) -- reference to a specific snowflake stage

  • file_format (str) -- reference to a specific file format

  • schema (str) -- reference to a specific schema in snowflake database

  • columns_array (list) -- reference to a specific columns array in snowflake database

  • snowflake_conn_id (str) -- reference to a specific snowflake database

execute(self, context: Any)[source]

Was this entry helpful?