Snowshoe logo
all-things-risingwave

How to ingest data into RisingWave table from NATS CLI?

I want to know how to ingest data into a RisingWave table from NATS CLI following the table creation and schema setup provided in the discussion thread.

AH

AHMED BOUTARAA

Asked on Dec 28, 2023

  1. RisingWave expects one JSON message per data ingestion.
  2. The JSON message format should match the schema defined in the table creation.

Example JSON message:

{
  "ts": 1234567890,
  "device_id": "some device",
  "temperature": 123.456
}
  1. Use the NATS CLI nats pub command to publish messages to the specified subject.
  2. When using NATS CLI, the message should be in the JSON format as shown above.
Dec 28, 2023Edited by