У нас есть сценарий, в котором мы должны обрабатывать каждую запись данных в таблице базы данных. Но это должно быть инициировано пользователем, когда он решит начать обработку.
Мы довольны потоковой обработкой, поскольку мы можем разделить каждый этап процесса на потоковые приложения и масштабировать их по мере необходимости. Другой вариант, который у нас есть, - просто сделать это задачей с помощью пакетного задания.
Если мы должны сделать это через поток, мы думаем о подходе, чтобы иметь источник http (для получения триггера) -> источник / процессор jdbc (для получения каждой записи) -> процессор приложений (для обработки каждой записи) -> приемник jdbc (для сохранения в db)
Есть ли элегантное решение или другой способ сделать это с помощью весеннего облачного потока и весеннего облачного потока данных?
