У меня в базе лежат определенные граничные значения для разных метрик, например, бак с топливом должен быть не менее чем 100 литров. MQTT шлет мне постоянным потоком данные о том сколько сейчас литров в баке, буквально каждую секунду. Все это я сразу же сохраняю в MongoDB через Kafka Вопрос в том, что я не хочу писать какой-то сервис который будет вытягивать события которые я сохранил и сравнивать их с граничными значениями, а хочу чтобы это происходило прямо во время Insert'a в DB Например, из Kafka приходит Event что PetrolTankValue = 99, а в граничных значениях у меня лежит что PetrolTankValue должен быть не менее 100, в этом случае мне нужно создать новый документ в отдельной коллекции на моменте когда событие о наполнении бака с топливом только попало в базу

что дальше будет происходить по факту срабатывания триггера? создастся сообщение в кафку или запаись в базу или еще чтонить?

хорошо, тогда вот это пробуй: https://www.mongodb.com/docs/manual/changeStreams/ второй вариант, на уровне языка сделать "раздачу" из сектора памяти и стримить его куда нужно и в бд

Запись в базу только и все

тогда достаточно триггеров атласовских

тогда достаточно триггеров атласовских

триггер тут не подойдёт, потому что он написал, что не хочет потом читать из бд и ещё куда-то данные отправлять из бд, а хочет ещё сразу куда-то кроме бд отправлять

триггер тут не подойдёт, потому что он написал, что не хочет потом читать из бд и ещё куда-то данные отправлять из бд, а хочет ещё сразу куда-то кроме бд отправлять

Не совсем, я имел ввиду что не хочу читать из БД чтобы создать вот эту запись срабатывания

наоборот, чем проще БД тем реже в нее заглядываешь и решаешь всякие проблемы. Ну и размазывание бизнес логики на БД это уже давно признак плохого проектирования. Даже те же триггеры у человека выше это костыль, т.к. надо ставить детектирование на потоке из кафки и порождать записи в базу

наоборот, чем проще БД тем реже в нее заглядываешь и решаешь всякие проблемы. Ну и размазывание бизнес логики на БД это уже давно признак плохого проектирования. Даже те же триггеры у человека выше это костыль, т.к. надо ставить детектирование на потоке из кафки и порождать записи в базу

Тоесть лучше это делать на слое Kafka - Mongo?

Добрый день. Подскажите как остановить mongod. Оказалось что мой процессор не поддерживает avx инструкции. service mongod stop не работает у меня всегда показывает статус failed вместо inactive. И я не могу убить процесс mongod потому что он постоянно перезапускается с новым pid. Debian 11

ща бы бд без авторизации шарить, ее уже минут через 30 хакрут прогнав сканером ipv4

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

Так авторизация была, ало

Не могу разобраться с загрузкой простой картинки на бэк, вроде контроллер отрабатывает нормально ( 1 скрин ) получаю из response путь. Но банально не могу засунуть его в src(2скрин), подскажите что я делаю не так

Что за путь на 1 скрине?

Что за путь на 1 скрине?

по идеи мне его multer отдает

Так а в чем ошибка то?

Путь приходит, а как мне к нему обратиться я что-то не понимаю

Здравствуйте, подскажите как сделать сортировку по длине поля модели, только вот оператор project забирает все поля, я не хочу тупо переписывать все поля модели в project. есть способ сделать это как-то иначе?

Можно ли как-то сортировать по длине строки не используя для этого оператор project

Я удалил поле length а потом сортирую по нему)))

ну, в project я его исключил, не так ли?

кстати ещё интересный вопрос, хорошая ли практика собирать массив пайплайнов и потом с ним делать aggregate

Не разобрался как сделать условный unwind, то есть по условию исключить поле

Мне кажется фильтр это условия для самих полей документов, а у меня значение приходит из req.query, filter разве для этого подойдёт?

Да, мозги запутал

Фильтру можно в инпут передать внешнее значение которое приходит из req.query?