Разделите результаты запроса на изменение данных между многими сеансами

Question

Итак, у меня есть служба, которая должна выполнять длительные вычисления каждый раз, когда пользователь делает вызов REST API. В настоящий момент обработчик http переносит некоторые данные в таблицу в RethinkDB, а фоновая работа использует changefeed для извлечения данных и выполнения вычислений.

данных: { id: RethinkDB's UUID, payload: ... }

Теперь я хочу:

• Сделать фоном протеканию процесса параллельно на нескольких машинах
• Используйте фантазии ReQL для отправки различных задач на разных машинах
• Избегайте дублирующих расчетов

---

Одна идеи у меня есть это:

1. Дайте каждый процесс отдельной PROCESS_ID (1,2,3 ..)
2. Карты Дейты ID ряда (num_id)
3. Использовать Changefeed в каждом процессе и ждать данных, где num_id% max_process_id is process_id

У кого-нибудь есть идея?

Есть ли какой-либо канонический способ автоматической отправки запроса на замену на несколько машин?

Answer 1

Я думаю, что идея, которую вы описали, звучит как хороший способ сделать это. У Changefeeds нет встроенного способа отправки нескольким работникам.