import {CartSchema, ICartSchema} from "../models/shop/Cart"; CartSchema.post("remove", (doc: ICartSchema) => { console.log(doc._id); }); const cart = await Cart.findOne({ _id: cartId }); await cart.remove(); почему я не попадаю в мидлваре

https://docs.mongodb.com/manual/reference/operator/aggregation/filter/#mongodb-expression-exp.-filter

Подскажите как обозначается оператор или?

а как отфильтровать элементы в массиве, где нет опрределённого поля? ```db.sales.aggregate([ { $project: { items: { $filter: { input: "$items", as: "item", cond: { $ne: [ "$$item.price", null ] } } } } } ])``` не работает

привет, как долго устанавливается mongodb?

уже 40 минут идёт

всем привет! текущая реализация (опустил куски кода с транзакциями): (все при помощи транзакций) const dataProduct = await Product.findOneAndUpdate( { _id: productId }, { $inc: { countActivate: 1 } }, { session, new: true } ); if (countActivate >= 5000) { // пользователь не может купить продукт, т.к. его уже купили 5 тысяч раз // аборт транзакции и завершении сессии // говорим пользователю что товар раскупили } // Если все в порядке, то пользователь купил продукт await ProductBuy.create( [ { userId, productId } ], { session } ); // говорим что пользователь успешно купил товар товары быстро разбирают, максимально быстро около 200-300 RPS пользователи встречают writeConflict (здесь все понятно), можно повторить транзакцию N раз вопрос как можно увеличить скорость покупки товара? может есть иные решения? сейчас при 200-300 RPS около 10 пользователей купят, остальные получат writeConflict хотелось бы избежать повтора транзакций и ускорить процесс покупки

всем привет! текущая реализация (опустил куски кода с транзакциями): (все при помощи транзакций) const dataProduct = await Product.findOneAndUpdate( { _id: productId }, { $inc: { countActivate: 1 } }, { session, new: true } ); if (countActivate >= 5000) { // пользователь не может купить продукт, т.к. его уже купили 5 тысяч раз // аборт транзакции и завершении сессии // говорим пользователю что товар раскупили } // Если все в порядке, то пользователь купил продукт await ProductBuy.create( [ { userId, productId } ], { session } ); // говорим что пользователь успешно купил товар товары быстро разбирают, максимально быстро около 200-300 RPS пользователи встречают writeConflict (здесь все понятно), можно повторить транзакцию N раз вопрос как можно увеличить скорость покупки товара? может есть иные решения? сейчас при 200-300 RPS около 10 пользователей купят, остальные получат writeConflict хотелось бы избежать повтора транзакций и ускорить процесс покупки

всем привет! текущая реализация (опустил куски кода с транзакциями): (все при помощи транзакций) const dataProduct = await Product.findOneAndUpdate( { _id: productId }, { $inc: { countActivate: 1 } }, { session, new: true } ); if (countActivate >= 5000) { // пользователь не может купить продукт, т.к. его уже купили 5 тысяч раз // аборт транзакции и завершении сессии // говорим пользователю что товар раскупили } // Если все в порядке, то пользователь купил продукт await ProductBuy.create( [ { userId, productId } ], { session } ); // говорим что пользователь успешно купил товар товары быстро разбирают, максимально быстро около 200-300 RPS пользователи встречают writeConflict (здесь все понятно), можно повторить транзакцию N раз вопрос как можно увеличить скорость покупки товара? может есть иные решения? сейчас при 200-300 RPS около 10 пользователей купят, остальные получат writeConflict хотелось бы избежать повтора транзакций и ускорить процесс покупки

да, делать retry это наиболее корректное решение вашей проблемы при таких условиях

Если вам необходимо соблюдать порядок, чтоб «честно» распределить заказы между пользователями, то в этом случае вам нужна линеаризация заказов на покупку

Т.е. нет варианта ускорить мою конструкцию? Есть конечно вариант, использовать редис для инкремента и проверок числа Конечно, понятно, что документ лочится транзакцией и другая транзакция не может ничего сделать и поможет только retry (бесконечный или N раз), но хотелось бы избежать этого

Если вам необходимо соблюдать порядок, чтоб «честно» распределить заказы между пользователями, то в этом случае вам нужна линеаризация заказов на покупку

т.е. важно разделить проблемы: наличие конфликта и производительность

а «длительное» это в каком диапазоне?

на мой взгляд, наиболее продуктивно будет сначала оценить какие задержки возникают при retry

есть ещё второй вариант: вы можете заранее создать пустые заказы по числу доступных позиций товара

есть ещё второй вариант: вы можете заранее создать пустые заказы по числу доступных позиций товара

попробую данный вариант выглядит неплохо

а есть тут админы которые разворачивали шаред кластер? поделитесь ресурсами где step-by-step расписано толково, а то мне не хватает офф доки

попробуйте сначала понять насколько сильно retry влияет

Можно ли в монге сделать процедуру/функцию мне нужно сделать каскадное удаление, для многих сервисов, и делать сервис не вижу смысла, а если встраивать функционал в другие сервисы, то получится дублирование кода и сложно поддерживать в случае изменений

Работу с бд обычно выносят в отдельный слой в котором ты делаешь нужное тебе удаление И да, в таком дублировании ничего страшного нет

привет. подскажите, пожалуйста, не работает unique: true для String поля phoneNumber в схеме. все уже перепробовал и перечитал - не помогает. прикол в том, что в другом проекте у меня это идеально работает с String полем email. я не понимаю, что я мог упустить. реализация идентичная

Это понятно. Просто сервисов более десятка, которые будут использовать. Плюс не все поддерживаются моей командой. В классической базе я бы написал процедуру и не парился. А в монге что то не могу найти похожий функционал.

Ну не все реляционные базы поддерживают процедуры, это раз Во-вторых, в монге можно в аггрегации функции использовать https://docs.mongodb.com/manual/reference/operator/aggregation/function/ И я не очень понял про число сервисов. У тебе есть сущность a для которой есть коллекция в монге и для работы с этой коллекцией ты делаешь слой, который потом используешь там, где нужно Хочешь в 1 сервисе, хочешь в 100 сервисах Плюс, если ты через монгус работаешь (на ноде), то можешь виртуальные методы использовать

Мне надо каскадное удаление. которое будут использовать много сервисов

В монге нет каскада в принципе. И ты же понимаешь, что "мне нужно каскадное удаление" - это абстрактная вещь Например, у меня есть коллекция А, которая ссылается на коллекцию Б, и есть коллекция В, которая ссылается на коллекцию Г. И если я удаляю Б, я должен удалять А, а если удаляю Г, то должен удалять В. И мне для этого придется 2 функции писать в моем коде, которые это удаление производят.

я знаю. у меня есть около 10 запросов на удаление. хочется оптимизировать.

В монге нет каскада в принципе. И ты же понимаешь, что "мне нужно каскадное удаление" - это абстрактная вещь Например, у меня есть коллекция А, которая ссылается на коллекцию Б, и есть коллекция В, которая ссылается на коллекцию Г. И если я удаляю Б, я должен удалять А, а если удаляю Г, то должен удалять В. И мне для этого придется 2 функции писать в моем коде, которые это удаление производят.

можно ничего не удалять)) и данные сохраняются на случай чего, а если ссылки на них потеряны, можно и не парится)

Я ответил на вопрос)

Это другой подход, иногда бизнес требует физического удаления

нет. Вопрос в том что бы сделать процедуру)) если все эти закидывать в код, сложно поддерживать)

это была неудачная шутеечка)

я специально сейчас передал поле на email. и все работает. с телефоном нет. может ли быть дело в том, что поле email не имеет пробелов, а phoneNumber имеет?

нет. он не создает у меня индексов для phoneNumber, а для email создает и все работает.. как можно решить это?

const userSchema = new mongoose.Schema( { name: { type: String, required: true, }, phoneNumber: { type: String, required: true, unique: true, }, socialLinks: { type: [ { type: String, }, ], default: [], }, avatar: { type: String, }, }, { versionKey: false, timestamps: true } );

это была неудачная шутеечка)