_id: { $in: [id1, id2, id3]}

Всем привет! Подскажите есть ли какой-то параметр, чтобы коннекты примерно ровно распределялись по инстансам? То есть у меня мастер и 2 реплики, на каждой max/incomingConnection 100, но может быть на одной 100 коннектов, на другой ноде 40, на 3 - 10. Хочется чтобы на каждом было ~50.

Всем привет! Подскажите есть ли какой-то параметр, чтобы коннекты примерно ровно распределялись по инстансам? То есть у меня мастер и 2 реплики, на каждой max/incomingConnection 100, но может быть на одной 100 коннектов, на другой ноде 40, на 3 - 10. Хочется чтобы на каждом было ~50.

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

в https://stackoverflow.com/questions/68228694/getting-error-unexpected-js-yaml-js-output-while-parsing-config-from-mongodb интересная причина озвучена, что с выделенными ресурсами?

Всем привет! Подскажите есть ли какой-то параметр, чтобы коннекты примерно ровно распределялись по инстансам? То есть у меня мастер и 2 реплики, на каждой max/incomingConnection 100, но может быть на одной 100 коннектов, на другой ноде 40, на 3 - 10. Хочется чтобы на каждом было ~50.

Подскажите, если использовать транзакции, нужно базу в каком-то специальном режиме запускать, параметры какие-то добавлять?

MongoServerError: The body function must be specified. Привет, использую следующий пайплайн для аггрегаций: [ { $lookup: { from: `${customerAnonymisedModel.modelName}s`, localField: '_id', foreignField: '_id', as: 'anonymised', }, }, { $unwind: { path: '$anonymised', preserveNullAndEmptyArrays: true, }, }, { $redact: { $cond: { if: { $eq: [ { $function: { body: function (customer: CustomerDocument, anonymisedCustomer: CustomerDocument): boolean { return ( JSON.stringify(_.pick(anonymiseCustomer(customer.toJSON()), customerFields)) !== JSON.stringify(_.pick(anonymisedCustomer.toJSON(), customerFields)) ); }, args: ['$$ROOT', '$anonymised'], lang: 'js', }, }, true, ], }, then: '$$KEEP', else: '$$PRUNE', }, }, }, ] И получаю ошибку: MongoServerError: The body function must be specified. Поискал инфу и нашел что-то о том, что нужно использовать строковую функцию, хотя в документации явно приводятся примеры с использованием именно функции

если актуально то уберите все типы в объявлении функции, там чистый js без всего

Добрый день коллеги! Подскажите как быть. Ситуация такая: Существует база данных 800 гигабайт, к которой подключаются клиенты и простоя быть не должно не говоря уже о потере данных. Вылетел единственный secondary. Т.к. данных были потеряны на нём из за raid0, пришлось заново синкать, но т.к. данных очень много, судя по всему оплога в 44 гига не хватает. Приняли решения увеличить до 150 гигабайт, запустили еще раз синк, но ситуация повторилась. Заметил что оба синка вылетали через 15 часов, очень странно. Последний вывод перед ресинком: ``` I REPL [repl writer worker 4] Finished cloning data: OK. Beginning oplog replay. I REPL [replication-344] Applying operations until { : Timestamp(1684830885, 8074) } before initial sync can complete. (starting at { : Timestamp(1684777533, 2061) }) NETWORK [repl writer worker 4] SocketException: remote: (NONE):0 error: SocketException socket exception [RECV_TIMEOUT] server [replexec-15] Error in heartbeat (requestId: 66042690) to server:27017, response status: NetworkInterfaceExceededTimeLimit: Couldn't get a connection within the time limit [repl writer worker 4] network error while attempting to run command 'isMaster' on host [NetworkInterfaceASIO-Replication-0] Ending connection to host server:27017 due to bad connection status; 0 connections to that host remain open [NetworkInterfaceASIO-RS-0] Ending idle connection to host server:27017 because the pool meets constraints; 2 connections to that host remain open I REPL [replication-344] Finished fetching oplog during initial sync: CallbackCanceled: oplog fetcher shutting down. Last fetched optime and hash: { ts: Timestamp(1684830887, 5467), t: 17 }[-6398059575360367928] ``` Сорян, логи не по порядку. Версия монги 3.6

Решили проблему?

Да, сегодня засинкалась реплика. Чуть позже скину как решили

Да, сегодня засинкалась реплика. Чуть позже скину как решили

Мне интересно, может быть там есть какой-то config

Всем, привет. Для обновления 5 млн документов целесобразно ли использовать updatemany() или лучше делать в курсоре/в цикле ?

ели можете логику изменения уложить в update то его и лучше использовать. На курсоре имеет смысл делать если вы не можете себе позволить нагрузку на монгу пока идет этот апдейт и нужно контролировать отзывчивость монги

Народ всем привет! Подскажите какую er диаграмму посоветуете для проектирование БД для mongo? видел hackolade, но на данный момент не доступна

Всех приветствую! Помогите пожалуйста поправить запрос. Как можете видеть, я достаю документы с помощью aggregate, так же присутствуют два $lookup. Первый $lookup достает документ из коллекции users и возвращает массив из обьекта. Нужно чтобы он возвращал обьект. Второй $lookup достает документы из коллекции answer-for-reviews и возвращает массив answers в котором обьект с ключом count. Нужно чтобы он возвращал только answersCount. На скрине можете увидеть нужный результать. Если есть советы по оптимизаций можете написать, у меня немного опыта с монго.

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

Рили? Он шарит монго????

конечно

Всем привет, есть кто шарит в kafka+debezium+mongo связке? Собсна проблема следующая: Нужно настроить коннектор к монге из кафки с плагинами дебезиума, чтобы данные читались только с одной конкретной ноды (бэкап скрытая реплика), чтоб не аффектить весь остальной кластер. Перепробовал кучу вариантов, меняя "mongodb.hosts", "mongodb.connection.string" и прочие параметры кафки, но по итогу ничего не изменилось, снапшот идет сниматься с мастер ноды, а чтение уходит на реплики основного кластера. При этом в логах кафки появляются строки а-ля Server hidden_replica:27017 is no longer a member of the replica set Либо такая ошибка, либо Unable to connect to primary node of Подскажите, кто делал что-то подобное, мой вариант вообще реально сделать - чтобы и снапшот и чтение шло только с нужной реплики и ниоткуда больше?

скорее всего вам нужно подключаться напрямую к hidden ноде, без указания всех seed hosts в uri. В противном случае клиенты не могут использовать hidden ноды для чтения вне зависимости от readPreference, так как в этом и есть смысл hidden флага

Буквально час тыкаюсь с бэком, при отправке выдает 404, мне кажется что у меня может быть не подключена бд к серверу. Скажите пожалуйста туда ли я копаю и может подскажите решение

404 это не найдена страница. Это ни как с бд не связано

404 это не найдена страница. Это ни как с бд не связано

Можете подсказать с чем может быть связана эта ошибка? неправильно написан middleware или схема или все сразу? ( звучу глупо, но мне нужно просто прикрутить регистрацию и какую-то легкую бд к проекту, и 20 минут туториала уже 2 с чем-то часа пытаюсь решить )

Приветствую, какую асинхронную ODM посоветуйте на python?

Beanie выглядит прикольно на первый взгляд, но по факту pycharm будет пестреть ошибками типизации А сама ODM строит сомнительные по производительности запросы (там может выйти такая вложенность lookup`ов, что можно застрелиться)

С pycharm вообще нет проблем, в нем и пишу сейчас. А по поводу запросов и прочего, ну конечно надо смотреть, тем более любое преобразование str->json—>куча классов, объектов - у вас просядет производительность.

Вообще, субъективно не люблю все эти орм, одм, но решил попробовать beanie -> https://beanie-odm.dev/ И то из-за того что Fastapi, pydantic.

Любое использование ссылок (Link), убивает тайпчекер, потому что он считает, что это объект типа link, а не то, на что он ссылается Про просадки я говорил именно про то, как строятся запросы

Не очень понял, у меня «строгий» подходит к тайпхинтам и тайпингу в целом, ничего красного в pycharme нет

Пусть объект User имеет поле вида field: Link[AnyModel] (так никто делать не будет, но для примера) Тогда запрос вида User.field.{свойство}, будет светиться желтым, ибо pycharm не понимает, что нужно смотреть в AnyModel, а не Link

Доброй ночи! Помогите с монго кластером. Не получается сделать rs.initiate указав members dns имя хоста. mongo-0 - нормально mongo-0.example.com - не работает..... как можно обойти кроме как внесением записей в /etc/hosts?