Как реализовать функцию с использованием MongoDB?

Question

[Вадим Казаков]

Я только недавно стал изучать MongoDB.
Решил написать функцию, которая каждый час из базы данных вытаскивает массив объектов пользователей, сравнивает по значению, которое ранее указано, и если значение превысило пороговую отметку, то совершает действие: повышает уровень и вычитает пороговое значение из переменной пользователя, отвечающее за опыт пользователя.

Суть вопроса: "Как реализовать это более оптимизированно, чтобы совершалось как можно меньше запросов к БД?"
Предполагаемая логика функции:
Вытащить массив с объектами пользователей,
Сверить с пороговым значением опыт каждого пользователя,
Если выше порогового, то повысить уровень на один, а у пользователя вычесть пороговое значение опыта.

Код, который я написал, он оказался нерабочим. К ChatGPT не отправляйте, он использует старую версию MongoDB - 4.2. В версии 5.2 метод save() является устаревшим и нерабочим.

Код:

spoiler

let users = await await acc.find({});
users.forEach(async user => {
    const requiredExperience = levelCurve[user.level];
    if (user.exp >= requiredExperience) {
        user.level += 1;
        user.exp -= requiredExperience;
        await acc.insert(user);
    }
});

Comments

[Василий Банников]

А почему это должно происходить именно по времени?
Если я правильно понял логику, то логичнее уровень либо вычислять динамически зная сумму опыта, либо увеличивать в том месте, где опыт начисляется.

[Вадим Казаков]

Василий Банников, я правильно понял, что сверять требуемое количество опыта именно в момент начисления?

[Вадим Казаков]

Василий Банников, весь факап в том, что у меня есть функция, которая без такой системы точно не обойдется: награды с ежедневного босса. Я не представляю как иначе можно реализовать данное. Данная функция будет работать по той же системе, что и описано в посте.

[Александр Романов]

Вам нужно делать не insert а updateOne
и лучше использовать bulk operations (собрали в кучку и выполнили одним запросом)
Если levelCurve хранится в базе, то агрегацией можно получить только те записи которые подходят по критерии (смотреть на $lookup stage)

[Вадим Казаков]

Александр Романов, если делать через update one, то будет обновлять исходный документ, а мне нужно именно только отдельных пользователей. По остальному посмотрю, хоть и не особо понял куда копать.

[Алексей]

Если юзаешь ChatGPT, попроси просто чтоб он под твою версию написал

Yes, I am familiar with MongoDB version 5.2. It was released on October 7, 2019. Some of the features and improvements in version 5.2 include:

Support for multi-document transactions
Improved performance for operations on sharded clusters
Support for the WiredTiger storage engine
Improved indexing and querying capabilities
New administrative and diagnostic tools
and many more.
Please let me know if you want more information about a specific feature or if you have any other question.

[Александр Романов]

ligedark_general, тогда как минимум надо менять "_id" в этом коде "_id" не меняется, а коллекция та же самая

[Василий Банников]

ligedark_general, а что босс сам по себе пробеждается? Считай во время начисления

[Василий Банников]

Алексей, chatgpt всё-таки не ИИ, а языковая модель. Может и не знать о существовании новой версии

[Алексей]

Василий Банников, я для кого цитату то привел из gpt ?

Do you know .save() method in MongoDB version 5.2 ?

Yes, I am familiar with the .save() method in MongoDB version 5.2. The save() method is used to update or insert a document in a MongoDB collection.

The save() method is used in the following way:

db.collection.save(document)

`collection` is the name of the collection where you want to save the document.
`document` is the document you want to save.
If the document does not contain an _id field, the save() method will insert the document as a new document in the collection. If the document contains an _id field, the save() method will update the existing document with the same _id.

It's worth noting that the `save()` method is now Deprecated in MongoDB and it is recommended to use `updateOne()` or `updateMany()` method with the upsert: true option instead.

The `save()` method might be slower than other methods as it will first check whether the document already exist by _id, and then perform the appropriate insert or update operation. And also it will require a lock for the whole collection during the execution.

I hope this helps! Let me know if you have any other questions.

Она явно говорит, что надо юзать updateOne или many

[Алексей]

You can replace the `.save()` method with the `.updateMany()` method in MongoDB 5.2 by using the `upsert: true` option. The `upsert: true` option tells MongoDB to insert a new document if no documents match the filter, or update the matching documents.

Here is an example of how you can use the `.updateMany()` method with the upsert: true option to replace the .save() method:

db.collection.updateMany(
{ _id: document._id },
{ $set: document },
{ upsert: true }
)

`collection` is the name of the collection where you want to save the document.
`{ _id: document._id }` is the filter that matches the documents that you want to update or insert.
`{ $set: document }` is the update operation that sets the fields of the matched documents to the values of the document variable.
`{ upsert: true }` is the option that tells MongoDB to insert a new document if no documents match the filter.
With this method, MongoDB will check for the `_id` of the `document` and update the existing one if it exists or insert the new one if it does not exist. This way you can have the same behavior as the `save()` method but with better performance as it will only lock the document that is being updated, not the whole collection.

You can also use `.updateOne()` method if you know that you only want to update one document with a specific filter.

Keep in mind that the `updateMany()` method will update all the documents that match the filter and `updateOne()` will only update the first one it finds, so be careful when using the filter.

[Вадим Казаков]

Василий Банников, расчёт наград происходит за минуту до появления нового босса. В фиксированное время.

Answer 1

[Вадим Казаков]

Крч, я послушал всех, но временно сделал по-своему. Спасибо всем за помощь.

Решил данный вопрос гениально просто:

spoiler

let users = await await acc.find({});
    users.forEach(async user => {
    const requiredExperience = levelCurve[user.level];
         if (user.exp >= requiredExperience) {
              wait acc.updateOne({ _id: user._id}, { $inc: { level: 1, exp: -(requiredExperience)}});
          }
     });

UPD: Больше таким не страдаю. Если и проверять опыт, то сразу же при начислении. Так максимально сокращается кол-во запросов к бд.