2015-04-24 2 views
3

Я хотел бы удалить файл после того, как все строки в файле обработаны. Мои потоки выглядят какУдалите файл после обработки всех строк в файле

source (file --fixedDelay=0 --outputType=text/plain --dir=XXX) | 
    splitter --expression=payload.split('\\n') | 
    transform -> filter -> sink 

Мои файлы хранятся в каталоге, который наблюдает модуль файла. Я хотел бы, чтобы каждый файл был удален после его обработки.

Спасибо.

ответ

1

Действительно удивительно, что источник файла не имеет возможности для удаления файла после обработки, что может быть подтверждено просмотром файла конфигурации в xd/modules/source/file/config/file.xml (as версии 1.1.0).

Хотя источник файла не имеет этой опции, источник sftp имеет его. Следовательно, вы можете использовать источник sftp. Для этого потребуется сервер ssh на машине, на которой установлена ​​пружина xd. Помогает ли это?

Вы также можете добавить свой собственный исходный модуль, настроив файловый трансформатор. Файловые трансформаторы поддерживают опцию delete-files="true":

http://docs.spring.io/spring-integration/reference/html/files.html

Смежные вопросы