Как вставить оригинальное имя файла (входной файл) в определенный поток при использовании расширения siddhi-io-csv в siddhi при использовании WSO2SP - PullRequest
Новая
       11

Как вставить оригинальное имя файла (входной файл) в определенный поток при использовании расширения siddhi-io-csv в siddhi при использовании WSO2SP

1 голос
/ 25 марта 2019

В 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

1 Ответ

0 голосов
/ 27 марта 2019

В текущей версии средства отображения siddhi CSV метаданные файла не передаются из файла siddhi-io. Мне нужно было написать собственную реализацию файла siddhi-io-file, которая передавала бы метеданные моему пользовательскому преобразователю.

...