将CSV文件转换为Siddhi事件

Question

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

我尝试使用' file‘作为源类型和' 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')) 

定义流字符串(纬度双精度，经度双精度，频率整数，天整数，时间间隔双精度，res_ratio双精度，client_id ProductionStream)；

我该怎么做呢？

Answer 1

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

请参考Product SP中提供的文件源/宿示例的CSV映射作为参考。