airflow.providers.google.cloud.transfers.postgres_to_gcs

PostgreSQL to GCS operator.

Module Contents

class airflow.providers.google.cloud.transfers.postgres_to_gcs._PostgresServerSideCursorDecorator(cursor)[source]

Inspired by _PrestoToGCSPrestoCursorAdapter to keep this consistent.

Decorator for allowing description to be available for postgres cursor in case server side cursor is used. It doesn’t provide other methods except those needed in BaseSQLToGCSOperator, which is more of a safety feature.

description[source]

Fetch first row to initialize cursor description when using server side cursor.

__iter__(self)[source]
__next__(self)[source]
class airflow.providers.google.cloud.transfers.postgres_to_gcs.PostgresToGCSOperator(*, postgres_conn_id='postgres_default', use_server_side_cursor=False, cursor_itersize=2000, **kwargs)[source]

Bases: airflow.providers.google.cloud.transfers.sql_to_gcs.BaseSQLToGCSOperator

Copy data from Postgres to Google Cloud Storage in JSON or CSV format.

Parameters
ui_color = #a0e08c[source]
type_map[source]
_unique_name(self)[source]
query(self)[source]

Queries Postgres and returns a cursor to the results.

field_to_bigquery(self, field)[source]
convert_type(self, value, schema_type)[source]

Takes a value from Postgres, and converts it to a value that’s safe for JSON/Google Cloud Storage/BigQuery. Dates are converted to UTC seconds. Decimals are converted to floats. Times are converted to seconds.

Was this entry helpful?