API Reference

class intake_postgres.intake_postgres.PostgresSource(uri, sql_expr, pg_kwargs={}, metadata=None)

Read data from PostgreSQL to dataframes

uri: str

Connection to PostgreSQL server

sql_expr: str

The full text of the SQL query to execute

pg_kwargs: dict

Further args passed to postgresadapter.PostgresAdapter, see https://github.com/ContinuumIO/PostgresAdapter/blob/master/postgresadapter/core/PostgresAdapter.pyx#L281