wso2 - 如何使用 Siddhi 解析数组数组
问题描述
我正在尝试使用 WSO2 Streaming Integrator / Siddhi 解析 JSON 事件流,但似乎无法将事件正确地放入流中。我正在使用 dockerimagewso2/streaming-integrator:1.0.0
来运行它。
我将以下输入流发送到 SiddhiApp(作为 HTTP POST 到 Siddhi 端点):
[
[ 1502942400000, "4261.480" ],
[ 1503982400000, "1010.312" ]
]
我的流定义如下:
@source(type='http', receiver.url='http://0.0.0.0:5010/stream', @map(type='json', @attributes(
timestamp = "[0]", sensorvalue = "[1]"
)))
define stream SensorAlertsStream (
timestamp long,
sensorvalue double,
我正在使用邮递员将数据发送到 WSO2 Streaming Integrator,但我得到的只是错误或根本没有响应。
我尝试了以下属性配置,均未成功:
- timestamp = "$.[0]", sensorvalue = "$.[1]"
- timestamp = "$[0]", sensorvalue = "$[1]"
- timestamp = "$[0][0]", sensorvalue = "$[0][1]"
- timestamp = "[0]", sensorvalue = "[1]"
我是否在源定义或映射属性中遗漏了某些内容,或者我是否应该得出结论认为这个数组输入结构是无法使用 siddhi-json 映射解析的?
如果有帮助;这是我简化的应用程序定义:
@App:name("SO-SensorApp")
@source(type='http', receiver.url='http://0.0.0.0:5010/stream', @map(type='json', enclosing.element="$[0]", @attributes( timestamp = "[0]", sensorvalue = "[1]" )) )
define stream SensorAlertsStream ( timestamp long, sensorvalue double );
@sink(type='log', @map(type='json'))
define stream log_values( sensorvalue double );
from SensorAlertsStream select sensorvalue insert into log_values;
解决方案
我在 Siddhi Tooling 5.1.2 中使用 siddhi-map-json-5.0.6 对此进行了测试,以下配置将解决该问题,enclosure.element-'$',timestamp = "[0]",sensorvalue = "[1]"
@source(type = 'http', receiver.url = 'http://0.0.0.0:8007/stream',
@map(type = 'json', enclosing.element = "$",
@attributes( timestamp = "[0]", sensorvalue = "[1]" )) )
@sink(type = 'log')
define stream SensorAlertsStream1 ( timestamp long, sensorvalue double );
推荐阅读
- kotlin - 如何在调试中修复 ClassNotFoundException: kotlinx.coroutines.debug.AgentPremain?
- unity3d - 如何在统一 2d 中删除游戏对象对撞机的一小部分
- .net - MassTransit UseCluster 导致应用程序失败
- python - 以字节为单位获取 Python 中的图像对象大小 - Azure 中的 BadRequest 错误
- react-native - 未使用 try/catch 块处理承诺拒绝(Firebase verifyPhoneNumber)
- c++ - C ++整数值的最小大小是什么意思?
- jquery - 在 PHP 中的特定按钮之间切换
- node.js - 如何使用节点 js 向 xlsx 文件上的单元格添加新值
- python - python web scrape如何抓取需要点击展开的内容
- r - Kernlab:需要 TRUE/FALSE 的缺失值?