Ответы, комментарии, мнения на вопрос.

Да вопрос очень интересный давайте обсудим и вместе найдем ответ кто что знает или думает?

Знаете ответ на этот вопрос? Опубликуйте его ваше мнение будет интересно другим пользователям!

2 комментария на ««Как нескольким worker’ам последовательно (в рамках topic) брать записи из таблицы сообщений?»»

1. 

   Ответ:

   Дамир

   Тут могла бы быть ваша ссылка подробнее в личном кабинете.

   30 сентября, 2024

   Для того чтобы нескольким worker’ам последовательно брать записи из таблицы сообщений в рамках определенного topic, можно использовать механизм блокировки, чтобы каждый worker мог получить доступ к записям только после завершения работы предыдущего worker’а.

   К примеру, можно создать столбец в таблице сообщений, который будет отмечать, была ли запись обработана каким-либо worker’ом. Перед тем как взять следующую запись, worker должен установить блокировку на эту запись, чтобы другие worker’ы не смогли ее обработать. После завершения обработки записи блокировка снимается, и следующий worker может взять следующую доступную запись.

   Таким образом, каждый worker будет последовательно обрабатывать записи из таблицы сообщений в рамках заданного topic, без возможности конфликтов и повторной обработки одной и той же записи.

   Ответить
2. 

   Ответ:

   Саабшь

   Тут могла бы быть ваша ссылка подробнее в личном кабинете.

   30 сентября, 2024

   Для того чтобы нескольким worker’ам последовательно брать записи из таблицы сообщений в рамках одного topic, можно воспользоваться методом блокировки записей. Каждый worker будет блокировать записи, которые он собирается обработать, чтобы предотвратить их обработку другими worker’ами. После обработки записи блокировка будет снята, и другой worker сможет взять следующую доступную запись.

   Также можно использовать отдельную таблицу для отслеживания статуса обработки каждой записи worker’ами. Каждый worker будет помечать записи, которые он собирается обработать, и проверять эту таблицу перед тем как взять следующую запись.

   Наконец, можно использовать очередь сообщений, где каждый worker будет брать сообщения из очереди по одному и обрабатывать их. Это обеспечит последовательную обработку записей worker’ами в рамках одного topic.

   Ответить