Documentation Index
Fetch the complete documentation index at: /llms.txt
Use this file to discover all available pages before exploring further.
Use the HTTP sink connector to send append-only data from RisingWave to an HTTP endpoint with either a static URL or a per-row dynamic URL.
CREATE SINK [ IF NOT EXISTS ] sink_name
[FROM sink_from | AS select_query]
WITH (
connector = 'http',
connector_parameter = 'value', ...
);
| Parameter | Description |
|---|---|
url | Optional. The target URL to POST data to. This is required when the sink outputs exactly one column. Do not set this option when the sink output includes a url column for dynamic per-row targets. |
content_type | Optional. The HTTP Content-Type header. If omitted, RisingWave uses text/plain for varchar payloads and application/json for jsonb payloads. |
header.<name> | Optional. Adds a custom HTTP header. For example, header.authorization = 'Bearer <token>'. |
type | Required. Must be append-only. |
varchar or jsonb, and set WITH (url = '...').payload and url. The payload column must be varchar or jsonb, and the url column must be varchar.payload and url are allowed. When using a dynamic URL sink, do not also set the url option in the WITH clause.
CREATE TABLE http_events (
payload jsonb
) APPEND ONLY;
CREATE SINK http_sink
FROM http_events
WITH (
connector = 'http',
url = 'https://example.com/events',
type = 'append-only'
);
CREATE TABLE http_events_dynamic (
payload jsonb,
url varchar
) APPEND ONLY;
CREATE SINK dynamic_http_sink
FROM http_events_dynamic
WITH (
connector = 'http',
type = 'append-only'
);
CREATE SINK AS SELECTCREATE TABLE source_events_append_only (
event_body jsonb,
workspace_id varchar
) APPEND ONLY;
CREATE SINK dynamic_query_http_sink AS
SELECT
event_body AS payload,
format('https://example.com/workspaces/%s/events', workspace_id) AS url
FROM source_events_append_only
WITH (
connector = 'http',
type = 'append-only'
);
Was this page helpful?