1

在 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
4

1 回答 1

0

使用当前版本的 siddhi CSV 映射器，文件元数据不会从 siddhi-io-file 传递。我要做的是编写一个自定义的 siddhi-io-file 实现，它将元数据传递给我的自定义映射器。

于 2019-03-27T11:27:59.683 回答