Databases
Ingest data from PostgreSQL table
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.
Added in version 2.1.
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
.