Databases
Ingest data from PostgreSQL tables
Describes how to ingest data from PostgreSQL table to RisingWave using table-valued function.
RisingWave allows you to query PostgreSQL tables directly with the postgres_query
table-valued function (TVF). It offers a simpler alternative to Change Data Capture (CDC) when working with PostgreSQL data in RisingWave.
Unlike CDC, which continuously syncs data changes, this function lets you fetch data directly from PostgreSQL when needed. Therefore, this approach is ideal for static or infrequently updated data, as it’s more resource-efficient than maintaining a constant CDC connection.
Syntax
Define postgres_query
as follows:
Example
- In your PostgreSQL database, create a table and populate it with sample data.
- In RisingWave, use
postgres_query
function to retrieve rows whereid > 90
.