:mod:`airflow.hooks.postgres_hook`
==================================

.. py:module:: airflow.hooks.postgres_hook







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






.. py:class:: PostgresHook(*args, **kwargs)

   Bases::class:`airflow.hooks.dbapi_hook.DbApiHook`

   

   Interact with Postgres.
   You can specify ssl parameters in the extra field of your connection
   as ``{"sslmode": "require", "sslcert": "/path/to/cert.pem", etc}``.

   Note: For Redshift, use keepalives_idle in the extra connection parameters
   and set it to less than 300 seconds.


   

   

   .. attribute:: conn_name_attr
      :annotation: = postgres_conn_id 

      



   

   

   .. attribute:: default_conn_name
      :annotation: = postgres_default 

      



   

   

   .. attribute:: supports_autocommit
      :annotation: = True 

      



   

   

   

   .. method:: get_conn(self)

      



   

   .. method:: copy_expert(self, sql, filename, open=open)

      
      Executes SQL using psycopg2 copy_expert method.
      Necessary to execute COPY command without access to a superuser.

      Note: if this method is called with a "COPY FROM" statement and
      the specified input file does not exist, it creates an empty
      file and no data is loaded, but the operation succeeds.
      So if users want to be aware when the input file does not exist,
      they have to check its existence by themselves.

      



   

   .. method:: bulk_load(self, table, tmp_file)

      
      Loads a tab-delimited file into a database table

      



   

   .. method:: bulk_dump(self, table, tmp_file)

      
      Dumps a database table into a tab-delimited file

      



   

   .. staticmethod:: _serialize_cell(cell, conn)

      
      Postgresql will adapt all arguments to the execute() method internally,
      hence we return cell without any conversion.

      See http://initd.org/psycopg/docs/advanced.html#adapting-new-types for
      more information.

      :param cell: The cell to insert into the table
      :type cell: object
      :param conn: The database connection
      :type conn: connection object
      :return: The cell
      :rtype: object