Ingest data from webhook

​

How managed webhook routing works

• Public ingress: HTTPS :443
• Webhook path format: /webhook/<database>/<schema>/<table>

1. Hosted projects: SNI hostname first, then tenant query parameter fallback.
2. BYOC projects: currently use tenant query parameter (SNI is not supported).

​

Prerequisites

1. A running RisingWave Cloud cluster.
2. The tenant identifier of your cluster (for example, rwc-g1huxxxxxx-mycluster).
3. A webhook table in your target database/schema (you can create it in the wizard).

​

Hosted vs BYOC requirements

​

Use the Cloud Portal webhook wizard (recommended)

1. Go to the RisingWave Cloud dashboard, open your cluster, and select Data Catalog in the cluster navigation.
2. Click Create source, then open Webhook.
3. Select Database, Schema, and Table.
4. (Optional) Use Create new webhook table to generate SQL, preview it, and run it.
5. Copy the generated Webhook Endpoint URL.
6. Expand cURL Example and copy the generated command.

​

Recommended SQL and cURL commands

CREATE TABLE wbhtable (
  data JSONB
) WITH (
  connector = 'webhook'
) VALIDATE AS secure_compare(
  headers->>'signature',
  '1'
);

curl -i -X POST "<webhook_endpoint_url_from_wizard>" \
  -H "Content-Type: application/json" \
  -H "signature: 1" \
  -d '{"event":"user.signup","user_id":"123"}'

curl -k -i -X POST "<webhook_endpoint_url_from_wizard>" \
  -H "Content-Type: application/json" \
  -H "signature: 1" \
  -d '{"event":"user.signup","user_id":"123"}'

SELECT * FROM wbhtable;