Руби драйвер для eventmachine всю жизнь посылал запросы мультиплексированно через один коннект. И если есть уверенность, что запросы все быстрые, это выигрышная стратегия. Но если один запрос затормозит весь хвост, будет не приятно :-(

Смотри, с позиции драйвера нет «запросов». Есть дубовый wire протокол (по сути реализует логические фреймы) в котором payload — bson документы. Формат документов описывается поддерживаемыми командами.

Раньше там были разные типы фреймов, но их всех свели к одному M_MSG

Я сейчас могу врать, но насколько я помню сам протокол — request / response. Из-за этого например Bulk запрос это по сути один сгруппированный запрос и на него будет один ответ.

С этим связанны сложности с отслеживанием статуса конкретного запроса из bulk

Но мои знания актуальны на 2.8 – 3.0, там в последнее время кучу всего перепилили

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

Ты можешь почитать спеки

The OP_MSG message is essentially a request-response protocol, one message per turn. However, setting the moreToCome flag indicates to the recipient that the sender is not ready to give up his turn and will send another message.

https://github.com/mongodb/specifications/blob/master/source/message/OP_MSG.rst

https://docs.mongodb.com/ecosystem/drivers/specs/ от сюда можно начинать обзор

Можешь ещё в жире поискать

Можешь написать Emily, которая руби драйвер пилит

В твиттере @EmStoflo

Я уже успел попробовать em-mongo драйвер. Он старенький, но еще работает. И корректно мультиплексирует. И монга корректно отрабатывает. Но если с одного коннекта запросы обрабатываются строго по очереди, это резко уменьшает полезность мультиплексирования. Товарищ говорит, что эксперимент с killOp подтверждает, что это так, т.к. killOp посланный в тот же коннект не убивает запрос. Про OP_MSG я успел почитать до того, как сюда писать. Если приглядитесь, хедер фрейма остается прежним, а requestid и responsefor живёт именно в заголовке фрейма, и от типа фрейма не зависит. Т.е. "новый" протокол имеет те же возможности мультиплексирования, что и "старый" (т.к. это по сути тот же протокол).

Можешь написать Emily, которая руби драйвер пилит

у рубистов популярно монгу вместо редиса юзать

у рубистов популярно монгу вместо редиса юзать

Это на основании чего такое заявление?

Я уже успел попробовать em-mongo драйвер. Он старенький, но еще работает. И корректно мультиплексирует. И монга корректно отрабатывает. Но если с одного коннекта запросы обрабатываются строго по очереди, это резко уменьшает полезность мультиплексирования. Товарищ говорит, что эксперимент с killOp подтверждает, что это так, т.к. killOp посланный в тот же коннект не убивает запрос. Про OP_MSG я успел почитать до того, как сюда писать. Если приглядитесь, хедер фрейма остается прежним, а requestid и responsefor живёт именно в заголовке фрейма, и от типа фрейма не зависит. Т.е. "новый" протокол имеет те же возможности мультиплексирования, что и "старый" (т.к. это по сути тот же протокол).

Ты уверен что он честно мультиплексирует?

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

у рубистов популярно монгу вместо редиса юзать

и не только у рубистов…

Ты уверен что он честно мультиплексирует?

Я посмотрел на него strace -ом

Послал пять запросов. Он их все одним writev в сокет плюнкл.

Ответы пришли корректно тем колбэкам, что их ожидали.

Это на основании чего такое заявление?

просто работал с 8 командами рубистов

чтот им редис всем не нравится, монгу говорят вместо него

сочетание правда mongo+postgre интересное

просто работал с 8 командами рубистов

Рубисты которых я консультировал используют монгу по назначению. ¯\_(ツ)_/¯

Рубисты которых я консультировал используют монгу по назначению. ¯\_(ツ)_/¯

ну. если тебе нужен редис который будет в 4 разных дц, выбор ток на монге ?

Слабоумие и отвага

ну. если тебе нужен редис который будет в 4 разных дц, выбор ток на монге ?

Смотря какие задачи. Под локальный кеш редис явно быстрее.

Но вообще, живые рубисты. ?

Денег зарабатывают, а чо.

Да хз, последний живой рубист, которого я знал, давно пишет на JS.

Плохой рубист значит

Вон, @funny_falcon так вообще у нас кучу полезностей в руби накомитил

Вон, @funny_falcon так вообще у нас кучу полезностей в руби накомитил

Мой вклад заметно переоценен.

Да хз, последний живой рубист, которого я знал, давно пишет на JS.

про JS значная шутка

так и ксс можно в отдельный язык сделать

так и ксс можно в отдельный язык сделать

И btrfs в разряд стабильных, ага

хрыч и тут троллит

Если я правильно понял, то так: collection.find({}, 'city') Такой запрос вернёт все города, которые есть в БД

нето что я хочу. Там пользователь может нажать кнопку все города а может нажать на один город. У меня в фильтре много параметров. И тут мне надо будет делать if else conditions. Если "всe" то в фильтр не вклчаем параметр города если один город "Chicago" то включаем параметр города. А я не хочу убирать этот параметр. Пусть он всегда будет стоять. Просто надо будет менять значение в зависимости от города. Типа collection.find({'city':'all'}) collection.find({'city':'Chicago'})

Просто не передавай параметры, find({})

подскажите, плз, есть модель, содержащая поля field1 и date { "field1": "One", "date": "some date1" }, { "field1": "Two", "date": "some date2" }, { "field1": "Three", "date": "some dat3" }, { "field1": "Four", "date": "some date4" } как можно обновить поле date у нескольких записей, если есть массив типа [ {"field1": "One", "date": "new date"}, {"field1": "Three", "date": "one more date"} ] Поле field1 проиндексировано.

а вот так должно работать? Model.updateMany({}, { $set: { date: new Date() } });

подскажите, плз, есть модель, содержащая поля field1 и date { "field1": "One", "date": "some date1" }, { "field1": "Two", "date": "some date2" }, { "field1": "Three", "date": "some dat3" }, { "field1": "Four", "date": "some date4" } как можно обновить поле date у нескольких записей, если есть массив типа [ {"field1": "One", "date": "new date"}, {"field1": "Three", "date": "one more date"} ] Поле field1 проиндексировано.

Никак. Делать несколько запросов

Никак. Делать несколько запросов

а как обновить updatedAt ? пробую так, но не работает )) Source.updateMany({}, { $currentDate: { lastModified: true } }, { multi: true }); $set какой-нибудь обязательно делать?

Никак. Делать несколько запросов

Как это никак

Multi в апдейте зачем?

а как обновить updatedAt ? пробую так, но не работает )) Source.updateMany({}, { $currentDate: { lastModified: true } }, { multi: true }); $set какой-нибудь обязательно делать?

Вот был бы отформатирован текст, сделал бы пример.

Вот был бы отформатирован текст, сделал бы пример.

в смысле? ))

Как это никак

Во так — никак. Установить в два разных документа разные значения в одном апдейте нельзя

Во так — никак. Установить в два разных документа разные значения в одном апдейте нельзя

Так речь же об одном поле, дейт, и значение вродь как труе

В оригинальном вопросе два документа и две даты.

а как обновить updatedAt ? пробую так, но не работает )) Source.updateMany({}, { $currentDate: { lastModified: true } }, { multi: true }); $set какой-нибудь обязательно делать?

Это к драйверу вопрос

Но вообще да, нужно указать $set

В оригинальном вопросе два документа и две даты.

Ок тогда никаг.

подскажите, плз, есть модель, содержащая поля field1 и date { "field1": "One", "date": "some date1" }, { "field1": "Two", "date": "some date2" }, { "field1": "Three", "date": "some dat3" }, { "field1": "Four", "date": "some date4" } как можно обновить поле date у нескольких записей, если есть массив типа [ {"field1": "One", "date": "new date"}, {"field1": "Three", "date": "one more date"} ] Поле field1 проиндексировано.

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

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

читаю rss из нескольких источников в разных часовых поясах. надо обновить запись каждого источника с указанием последнего pubDate из rss. field1 - uid источника. Второй массив, это массив обновленных rss

Но, перечитав ТЗ, склоняюсь к тому, что проще завести одну запить с UTC и ее апдейтить при каждом дергании rss

Если хотите делать один большой запрос, то можете посмотреть в сторону bulkWrite https://docs.mongodb.com/manual/reference/method/db.collection.bulkWrite/

Если хотите делать один большой запрос, то можете посмотреть в сторону bulkWrite https://docs.mongodb.com/manual/reference/method/db.collection.bulkWrite/

Но это может быть больно. Проще и надежней несуолько мелких.

Но это может быть больно. Проще и надежней несуолько мелких.

Напримеп чем больно?

Нагрузочка подрастет и не упадет, например.

Гуглит

Нагрузочка подрастет и не упадет, например.

Один коннект с 5 запросами и нагрузочка подрастет, а 5 коннектов с 5 запросами не подрастет?

А зачем тебе в каждый запрос - коннект?

Всем привет

А зачем тебе в каждый запрос - коннект?

я не так выразился, но думаю ты понял что я имею ввиду

Нет не понял.

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

Напримеп чем больно?

единственное чем больно — ошибок запросов не будет видно

Охайо, немного оффтопа - есть чатик по nodejs/express?

https://t.me/nodejs_ru - чистая нода есть

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

Что

Как с этим могут сложности то возникнуть.

Какой ЯП то хоть?

Документацию смотрели?

Ну ошибки это уже походу к драйверу, т.к. Апсерты в булках вполне себе выдают ошибки по каждому апдейту, если были например дубли по юник индексам. Java драйвер если что. И да требуется обходить массив ошибок, но вполне приемлемо

https://t.me/nodejs_ru - чистая нода есть

аригато)

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

с помощью оператора =, если он есть в используемом языке

с помощью оператора =, если он есть в используемом языке

у мня NodeJS и mongoose и я не могу найти в интернете инфу как это сделать

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

Колбэк, .then

Может есть пример кода где через = можно переменной присвоить переенной результать findOne ?

Может есть пример кода где через = можно переменной присвоить переенной результать findOne ?

асинхронная функция, в консоль выведи результат = будет "pending"

Может есть пример кода где через = можно переменной присвоить переенной результать findOne ?

https://stackoverflow.com/questions/12818051/how-to-perform-findone-query-in-mongoose

Может есть пример кода где через = можно переменной присвоить переенной результать findOne ?

http://mongoosejs.com/docs/index.html обратите внимание на коллбеки

http://mongoosejs.com/docs/index.html обратите внимание на коллбеки

User.find({}, callback); console.log(callback); User.find({}, callback); ^ ReferenceError: callback is not defined

вот что пишет

User.find({}, callback); console.log(callback); User.find({}, callback); ^ ReferenceError: callback is not defined

callback - это должна быть функция

User.find({}).then(function(users){ console.log(users) })

User.find({}, callback); console.log(callback); User.find({}, callback); ^ ReferenceError: callback is not defined

вы не определили callback, им может быть любая функция, она должна принимать два агрумента, первый - статус ошибки, вторым аргументом идет то, что вам нужно

тут можно найти больше примеров по findOne - http://mongoosejs.com/docs/api.html#model_Model.findOne

вы не определили callback, им может быть любая функция, она должна принимать два агрумента, первый - статус ошибки, вторым аргументом идет то, что вам нужно

А как проверить что результать не пустой и сделать повторный запрос с другими параметрами?