在WSO2SP中,有一种使用CSV文件生成事件的方法。例如ReceiveEventsFromFile示例。在此示例中,我可以将文件放入文件夹,扩展程序将读取文件并生成事件。
当我定义输入流时,我想知道是否有一种方法可以将原始文件(输入文件)名称作为参数,例如INPUT_FILE_NAME
是否有功能实现类似于下面的示例。
dir.uri='file:/wso2sp-4.3.0/samples/artifacts/ReceiveEventsFromFile/files/new',
action.after.process='move',
tailing='false',
move.after.process='file:/wso2sp-4.3.0/samples/artifacts/ReceiveEventsFromFile/files/consumed',
@map(type='csv', @attributes(ALERT_ID = "1", file = 'file.name')))
@sink(type='log')
define stream BatchFileStream (ALERT_ID string, file string);```
thanks in advance
使用当前版本的siddhi CSV映射器,文件metedata不会从siddhi-io文件传递。我要做的是编写一个自定义的siddhi-io文件实现,将metedata传递给我的自定义映射器。