csv - 将 CSV 文件转换为 Siddhi 事件

Question

我想使用 WSO2 流处理器将 CSV 文件转换为一组 Siddhi 事件，以便使用该 CSV 文件来训练 kmeansIncremental 模型。

我尝试使用“文件”作为源类型和“csv”作为地图类型来获取该 csv 文件，但是我不能这样做。

@source(type='file',file.uri='file:///home/Documents/Project%20Documents/logs/access.csv', @map(type='csv', header.present='true', event-grouping-enabled='true')) 

定义流ProductionStream（纬度双精度，经度双精度，频率整数，日期整数，时间间隔双精度，res_ratio双精度，client_id字符串）；

我怎样才能做到这一点？

Answer 1

你得到的错误是什么。与完整的 Siddhi 应用程序一起共享完整的堆栈跟踪。

请参考产品 SP中提供的带有文件源/接收器示例的 CSV 映射作为参考。