airflow.providers.google.cloud.transfers.postgres_to_gcs

PostgreSQL to GCS operator.

Module Contents

Classes

PostgresToGCSOperator

Copy data from Postgres to Google Cloud Storage in JSON or CSV format.
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

  • postgres_conn_id -- Reference to a specific Postgres hook.

  • use_server_side_cursor -- If server-side cursor should be used for querying postgres. For detailed info, check https://www.psycopg.org/docs/usage.html#server-side-cursors

  • cursor_itersize -- How many records are fetched at a time in case of server-side cursor.

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

Queries Postgres and returns a cursor to the results.

field_to_bigquery(self, field)[source]

Convert a DBAPI field to BigQuery schema format.

convert_type(self, value, schema_type, stringify_dict=True)[source]

Takes a value from Postgres, and converts it to a value that's safe for JSON/Google Cloud Storage/BigQuery. Timezone aware Datetime are converted to UTC seconds. Unaware Datetime, Date and Time are converted to ISO formatted strings. Decimals are converted to floats.

Parameters

  • value -- Postgres column value.

  • schema_type -- BigQuery data type.

  • stringify_dict -- Specify whether to convert dict to string.

Was this entry helpful?