RTB House apps pg_stream_copy
Project description
PG Stream Copy
Fast COPY TO postgresql table directly from python by converting input data to bytes and stream to psycopg2 cursor using COPY <table> FROM STDIN BINARY
Usage:
from datetime import date
from psycopg2 import connect
from pg_stream_copy import Schema, WriterEncoder
conn = connect('postgresql://postgres@localhost')
cursor = conn.cursor()
table_name = 'public.example_table'
cursor.execute(f'''
CREATE TABLE {table_name} (
_smallint SMALLINT NULL,
_integer INTEGER NULL,
_bigint BIGINT NULL,
_float DOUBLE PRECISION NULL,
_character_varying CHARACTER VARYING NULL,
_date DATE NULL
);
''')
schema = Schema.load_from_table(cursor, table_name)
with WriterEncoder(cursor, table_name, schema) as writer_encoder:
writer_encoder.append_tuple((2, 3, 4, 2.34, 'foo bar', date(2019, 2, 1)))
writer_encoder.append_dict({
'_smallint': 200,
'_integer': 300,
'_bigint': 400,
'_float': 234,
'_character_varying': 'bar baz',
'_date': date(2019, 2, 3),
})
conn.commit()
conn.close()
Supported PostgreSQL types:
- smallint
- integer
- bigint
- double precision
- character varying
- date
Changelog
1.0.3
- Add README to pypi.org
- Add LICENCE, CHANGELOG
1.0.2
- Update pypi token
1.0.1
- add Travis CI
1.0.0
- initial commit
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
pg_stream_copy-1.0.5.tar.gz
(8.3 kB
view hashes)