В настоящее время мы разрабатываем приложение, которое читает файлы из файловой системы/ftp/http и загружает эти файлы в mongodb. После этого мы хотим проанализировать эти файлы и записать проанализированные документы в mongodb. Требования к этому процессу:
- Загрузка и анализ в режиме реального времени.
- Обработка сбоев и перезапуск процесса.
- Возможность повторного анализа файлов.
Как правильно организовать этот процесс в Spring XD? В каких случаях мы должны использовать потоки или пакетные задания? Если кто-нибудь может рассказать о лучших методах использования потоков вместо пакетных заданий и наоборот, это очень ценится.