:mod:`airflow.operators.generic_transfer`
=========================================

.. py:module:: airflow.operators.generic_transfer


Module Contents
---------------

.. py:class:: GenericTransfer(sql, destination_table, source_conn_id, destination_conn_id, preoperator=None, *args, **kwargs)

   Bases: :class:`airflow.models.BaseOperator`

   Moves data from a connection to another, assuming that they both
   provide the required methods in their respective hooks. The source hook
   needs to expose a `get_records` method, and the destination a
   `insert_rows` method.

   This is meant to be used on small-ish datasets that fit in memory.

   :param sql: SQL query to execute against the source database. (templated)
   :type sql: str
   :param destination_table: target table. (templated)
   :type destination_table: str
   :param source_conn_id: source connection
   :type source_conn_id: str
   :param destination_conn_id: source connection
   :type destination_conn_id: str
   :param preoperator: sql statement or list of statements to be
       executed prior to loading the data. (templated)
   :type preoperator: str or list[str]

   .. attribute:: template_fields
      :annotation: = ['sql', 'destination_table', 'preoperator']

      
   .. attribute:: template_ext
      :annotation: = ['.sql', '.hql']

      
   .. attribute:: ui_color
      :annotation: = #b0f07c

      
   .. method:: execute(self, context)