用途:RisingWave 是流式 SQL 数据库,实现 PostgreSQL 线协议,核心链路为 Source(摄取)→ Materialized View(持续计算)→ Sink(输出)。本技能用于在编写 RisingWave SQL、建流、CDC 与排障时提供指导。
主要能力:支持 Kafka 等连接器摄取、物化视图持续计算、Sink 输出、PostgreSQL/MySQL CDC(Debezium、Maxwell、Canal)、时间窗口(TUMBLE、HOP)、系统目录查询与 MCP 服务器(100+ 工具,含查询执行、模式探索、流任务监控、CDC 进度、Kafka 延迟、Hummock 存储分析)。
使用方式:SQL 端口为 4566(非 5432),Dashboard 为 5691。本地连接:psql -h localhost -p 4566 -d dev -U root;连接串 postgresql://root:@localhost:4566/dev。单节点 Docker:docker run -it --pull=always -p 4566:4566 -p 5691:5691 risingwavelabs/risingwave:latest single_node。任何 PostgreSQL 兼容客户端均可使用。MCP 服务器需克隆 https://github.com/risingwavelabs/risingwave-mcp.git 并安装依赖,通过环境变量 RISINGWAVE_CONNECTION_STR 配置。
关键限制:SOURCE 不持久化数据,CDC 必须用 CREATE TABLE ... FROM source;EMIT ON WINDOW CLOSE 需先定义 WATERMARK;大表回填需 SET BACKGROUND_DDL = true;Sink 加 snapshot = false 可跳过历史回填;RisingWave 2.8+ 中 TABLE 上的 watermark 要求 APPEND ONLY;SESSION 窗口在 2.x 仅批模式支持。文档更新快,不确定时查 docs.risingwave.com 或 SHOW CREATE。