WSO2 Stream Processor JSON解析失败问题求助

常见原因及排查步骤 #

• 校验输入JSON格式合法性
  命令行输入的JSON必须严格遵循语法规范：

  • 所有字符串、键名必须用双引号（"）包裹，禁止使用单引号（'）或无引号
  • 避免末尾多余逗号，比如{"a":1, "b":2,}这类格式会直接触发解析失败
  • 可通过本地JSON校验工具验证输入内容的有效性

• 匹配Siddhi流定义结构
  确认输入JSON与应用中流的定义完全对齐：

  • 字段名大小写严格匹配（Siddhi默认区分大小写）
  • 字段类型对应，比如流定义为int类型的字段，输入不能是字符串格式的数字
  • 不能缺少流定义中的必填字段，也不能添加未定义的额外字段（除非流配置允许）

• 规范命令行输入方式
  若用curl等工具触发事件，需确保JSON参数传递正确：

  • 用-d参数传递JSON时，需将整个JSON用双引号包裹，Linux环境下注意转义内部双引号（用\"）
  • 示例正确命令：curl -X POST -H "Content-Type: application/json" -d "{\"temperature\": 28}" http://localhost:9090/stream/YourStreamName

• 检查Siddhi应用输入流配置
  确认应用输入流的@source注解配置正确：

  • 需指定@map(type="json")，且无错误配置参数
  • 排查是否存在自定义JSON映射规则，导致输入格式不匹配

快速验证方案 #

1. 先搭建最简Siddhi应用测试：

@App:name("TestApp")
define stream TestStream (temperature int);

@sink(type="log")
define stream OutputStream (temperature int);

from TestStream
select *
insert into OutputStream;

2. 用合法JSON触发事件：{"temperature": 25}
3. 若测试正常运行，说明问题出在原应用的流定义或输入JSON匹配上；若仍报错，检查WSO2 SP的环境配置或版本兼容性

内容的提问来源于stack exchange，提问作者Casper Andersen