У меня есть работа, которая намечается каждый день. Ниже перечислены функции задания:
- Считыватель будет считывать данные из базы данных с помощью считывателя JDBCPaging.
- ItemProcessor обработает данные, выполнив вызов API, который возвращает некоторые обновленные данные.
- Writer записывает данные обратно в базу данных.
Проблема в том, что существует оперативная обработка, которая считывает определенную строку, обрабатывает и обновляет ее.
Я хочу поддерживать согласованность таким образом, чтобы обновлять данные, которые являются последними обработанный. Поскольку считыватель, процессор и запись выполняются отдельным способом, как взять и обработать блокировку. Я использую postgresql базу данных.