blob: b9d8f5bf822561e20221d7c9d9e27dd19e98b410 [file] [log] [blame]
:mod:`airflow.providers.snowflake.transfers.s3_to_snowflake`
============================================================
.. py:module:: airflow.providers.snowflake.transfers.s3_to_snowflake
.. autoapi-nested-parse::
This module contains AWS S3 to Snowflake operator.
Module Contents
---------------
.. py:class:: 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)
Bases: :class:`airflow.models.BaseOperator`
Executes an COPY command to load files from s3 to Snowflake
.. seealso::
For more information on how to use this operator, take a look at the guide:
:ref:`howto/operator:S3ToSnowflakeOperator`
:param s3_keys: reference to a list of S3 keys
:type s3_keys: list
:param table: reference to a specific table in snowflake database
:type table: str
:param stage: reference to a specific snowflake stage
:type stage: str
:param file_format: reference to a specific file format
:type file_format: str
:param schema: reference to a specific schema in snowflake database
:type schema: str
:param columns_array: reference to a specific columns array in snowflake database
:type columns_array: list
:param snowflake_conn_id: reference to a specific snowflake database
:type snowflake_conn_id: str
.. method:: execute(self, context: Any)