Connect to an existing PostgreSQL instance and extract data. Rows of data in PostgreSQL are extracted as JSON objects.
Supports common implementations of PostgreSQL including Supabase
Properties
Required properties:
connection_string
: Connection string to the Postgres instance
query
: SQL query to extract data (i.e. Select * From TableName)
Optional properties:
batch_size
: The size of batches of rows. Affects performance and latency.
Compatible loaders:
Usage
from neumai.DataConnectors import PostgresConnector
from neumai.Shared import Selector
postgres_connector = PostgresConnector(
connection_string = "postgresql://postgres:<password>@<host>:<port>/postgres",
query = """ Select * From "TableName"; """
)