RisingWave (Streaming Database)

RisingWave (Streaming Database) MCP Connector for Claude

F

Manage your RisingWave streaming database — execute SQL, ingest events, and monitor tables, materialized views, sources, and sinks directly from any AI agent.

6 tools Official Updated Jun 28, 2026 Official Vinkius Partner

Connect your RisingWave streaming database to any AI agent and take full control of your real-time data processing workflows through natural conversation.

What you can do

  • SQL Execution — Run DDL and DML statements like CREATE, SELECT, and INSERT directly via the HTTP API
  • Event Ingestion — Stream JSON data into your tables instantly using the dedicated Events API
  • Catalog Discovery — List all tables, materialized views, external sources, and sinks to understand your data topology
  • Real-time Monitoring — Inspect the state of your streaming pipelines and materialized views without leaving your workspace

How it works

  1. Subscribe to this server
  2. Enter your RisingWave URL
  3. Start managing your streaming database from Claude, Cursor, or any MCP-compatible client

Who is this for?

  • Data Engineers — quickly verify streaming logic and inspect materialized views during development
  • Backend Developers — ingest test events and query tables directly from the code editor
  • Analytics Teams — explore available data sources and sinks to build real-time dashboards
streaming-databasereal-time-analyticssqlevent-ingestionmaterialized-views

6 tools expose this connector's capabilities to your AI agent.

execute_sql

Execute a SQL statement on RisingWave

ingest_events

Body can be a single JSON object or an array of objects. Ingest events into a RisingWave table

list_materialized_views

rw_materialized_views to list all materialized views. List materialized views in RisingWave

list_sinks

rw_sinks to list all data sinks. List sinks in RisingWave

list_sources

rw_sources to list all external data sources. List sources in RisingWave

list_tables

tables to list user tables. List tables in RisingWave

See how to talk to your AI agent using RisingWave (Streaming Database).

List all the materialized views currently active in RisingWave.

I've retrieved the catalog. You have 3 active materialized views: 'daily_sales_summary', 'user_login_stats', and 'realtime_inventory_levels'. Which one would you like to inspect?

Ingest this JSON event into the 'user_activity' table: {"user_id": 123, "action": "login"}.

I've successfully sent the event to the 'user_activity' table via the RisingWave Events API. The data is now available for streaming processing.

Show me all external data sinks configured in the system.

Querying the catalog... I found 2 configured sinks: 's3_archived_logs' (S3) and 'postgres_reporting_db' (JDBC).

Yes! Use the `execute_sql` tool to run any valid RisingWave SQL query. You can perform complex analytical queries or inspect the results of your real-time aggregations.

Related Connectors