Мой пример использования следующий: у меня есть коллекция документов в mongoDB, которую я должен отправить для анализа. Формат документов следующий:

{_id: ObjectId ("517e769164702dacea7c40d8") , Дата:"1359911127494", статус:"имеется в наличии", other_fields ...}

У меня есть процесс чтения, который выбирает первые 100 документов сСтатус: в наличии отсортировано поДата и модифицирует ихСтатус: обработка, ReaderProcess отправляет документы на анализ. После завершения анализастатус изменено наобработанный.

В настоящее время читатель обрабатывает первые 100 документов, отсортированных поДата а затем обновитьстатус вобработка для каждого документа в цикле. Есть ли лучшее / эффективное решение для этого случая?

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

насыпнойfindAndModify (с ограничением) решил бы все эти проблемы. Но, к сожалению, в MongoDB его пока нет. Есть ли решение этой проблемы?