Publish data from Postgres
Ingest query results from Postgres
Each entry in queries produces one output table, so the query list and the table list line
up position by position.
There are several ways to pass secrets into Tabsdata. See Secrets Management for more info if you are planning to have an LLM register secrets into Tabsdata's credential store.
Listed 1 directory, called tabsdata 3 times (ctrl+o to expand)
The Postgres publisher guide and connection template are loaded. Four values left, then I generate and register. Reply with them one per line, or point me at a file that has them:
- collection name
- connection URI
- user and password
- tables to read
Read 1 file, called tabsdata 2 times (ctrl+o to expand)
Password found. Reading back what is not secret: uri postgres://db.internal:5432/world, collection world_src, tables country and city.
Called tabsdata 4 times (ctrl+o to expand)
Connection written to , and collection world_src created from it in group sources. Connection check passed.
Called tabsdata 2 times (ctrl+o to expand)
The publisher, registered in world_src:
@publisher(
source=PostgresSrc(
queries=[
"SELECT * FROM country",
"SELECT * FROM city",
],
),
output_tables=["country", "city"],
)
def read_world(
country: TableFramesSpec,
city: TableFramesSpec,
) -> tuple[TableFrameSpec, TableFrameSpec]:
return (country[0], city[0])
Called tabsdata 6 times (ctrl+o to expand)
Execution committed, 0 failures.
Two tables are live in world_src, one per query, in the order the queries were listed:
┌─────────┬───────────────────────┬───────┬─────────┐ │ table │ from │ rows │ columns │ ├─────────┼───────────────────────┼───────┼─────────┤ │ country │ SELECT * FROM country │ 239 │ 15 │ ├─────────┼───────────────────────┼───────┼─────────┤ │ city │ SELECT * FROM city │ 4,079 │ 5 │ └─────────┴───────────────────────┴───────┴─────────┘
The connection carries the URI and the credentials, so the publisher holds SQL and nothing about where the database is. Registering the same code into a second source collection reads the same queries against a different server.