Описание тега changestream
В качестве функции MongoDB потоки изменений позволяют приложениям получать доступ к изменениям данных в базе данных в реальном времени.
1
ответ
Может ли MongoDB changeStreams прослушивать коллекции системного уровня?
Из-за ограниченной документации, доступной по потокам изменений MongoDB, которую они представили в версии 3.6 и выше, я не могу прийти к выводу, позволят ли потоки изменений MongoDB прослушивать изменения коллекции системы. В настоящее время меня ин…
12 авг '18 в 05:53
1
ответ
Какова хорошая стратегия горизонтального масштабирования для считывателя потока изменений MongoDB?
Я думаю о реализации считывателя потока изменений MongoDB, и я хочу убедиться, что я делаю это правильно. Существует множество простых примеров того, как реализовать реальный код читателя, включая официальную документацию, и я не слишком обеспокоен …
21 янв '19 в 17:29
0
ответов
Соединитель Debezium + MongoDB против потока изменений MongoDB
Я пытаюсь использовать функцию потока изменений в mongodb для прослушивания изменений данных и публикации события в моей очереди сообщений (rabbitmq). Однако недавно я нашел debezium, решение для сбора данных изменений на основе журнала. Одно из огр…
11 фев '19 в 10:35
1
ответ
Является ли MongoDB ChangeStream ResumeToken уникальным во всем мире?
Как говорится в документе ( https://docs.mongodb.com/manual/changeStreams/), мы можем возобновить получение события из MongoDB с помощью resumeToken. Я буду хранить недавнее резюме в общем хранилище, но я не уверен, является ли этот токен резюме гло…
24 авг '18 в 02:54
1
ответ
Каково поведение драйвера java, когда токен возобновления для потоков изменений mongodb устарел?
При просмотре потока изменений в коллекции я могу указать токен возобновления (с resumeAfter), чтобы получать изменения после этого токена в журнале операций. Что происходит, если этот токен не может быть найден в журнале операций (например, клиент …
05 июн '18 в 07:01
0
ответов
Как следить за изменениями в определенных полях в потоке изменений MongoDB с помощью Spring Data Mongodb
В соответствии с документацией файла изменений mongodb, я могу следить за обновлениями в определенных полях сбора: const changeStream = collection.watch( [{ $match: { $and: [ { "updateDescription.updatedFields.a": { $exists: true } }, { operationTyp…
04 июн '18 в 08:30
0
ответов
MongoDB обрабатывает изменения потоков с использованием Apache Spark
Можно ли обрабатывать потоки изменений MongoDB с помощью Apache Spark? Я искал и обнаружил, что есть разъемы для чтения и записи в mongoDB, но, к сожалению, я не смог найти упоминаний об изменениях потоков. В моем случае я должен обрабатывать потоки…
01 авг '18 в 08:41
0
ответов
Docker, контейнеры MongoDb change-streams --- наблюдение за контейнерами
У меня есть приложение, работающее на нескольких док-контейнерах. Каждый API имеет свой собственный контейнер. Мы используем MongoDB в качестве нашей базы данных на нашем сервере Node.js и хотели бы использовать поток изменений для прослушивания изм…
19 май '18 в 02:35
6
ответов
Mongo Change Streams, запущенные несколько раз (вид): приложение Node, работающее несколько экземпляров
Приложение My Node использует потоки изменений Mongo, и приложение запускает более 3 экземпляров в рабочем состоянии (в конечном итоге, так как это будет увеличиваться по мере роста). Таким образом, когда происходит изменение в функциональности пото…
24 авг '18 в 15:36
1
ответ
MongoDB изменить поток отображения только выбранные поля
Я пытаюсь понять поток изменений в MongoDB. Я пытаюсь отобразить только некоторые поля обновленного документа. Так я и сделал: option={ 'full_document':'updateLookup' } collection.watch([{"$match" : { "operationType" : "update" }}] , **option) котор…
07 мар '18 в 13:38
0
ответов
Отправка отдельного объекта на каждое событие потока изменений
В настоящее время я возвращаю поток изменений клиенту с сервера и хотел бы отправить объект для каждого события. Есть какой-либо способ сделать это? Объект имеет тип, отличный от класса, используемого для потока изменений. Вот часть моего текущего к…
13 ноя '18 в 18:19
0
ответов
MongoDB/Spring: подписка на изменения коллекции
Я работаю с приложением Spring Boot. Я пытаюсь реализовать уведомление о событии на основе обратного вызова для модификации коллекции в MongoDB. У меня заканчиваются идеи, так как я попробовал следующее: Классический опрос - избыточный, поскольку су…
21 дек '18 в 01:13
0
ответов
Как смотреть изменения потока в mongoDB и отправлять обновления на вызов ajax?
Я использую новую функцию MongoDB 3.6 watch () для отправки обновлений базы данных с сервера узла на ajax на стороне клиента. Я создал веб-сервис, периодически запрашиваемый Ajax-вызовом. Между двумя последовательными вызовами ajax, я хочу, чтобы вт…
20 апр '18 в 15:21
1
ответ
Могу ли я создать собственный токен резюме (на основе времени) для потоков изменений mongodb?
В потоках изменений я могу предоставить токен resumeAfter, который я могу получить из предыдущего изменения, открыв change._id, Могу ли я создать свой собственный токен, основанный на метке времени?
25 июл '18 в 09:47
1
ответ
C# - Изменить потоки в MongoDB с $match
Я пытаюсь сузить потоки изменений в MongoDB до конкретного документа, соответствующего _id документа, поскольку у меня много документов в одной коллекции. Кто-нибудь знает, как это сделать в C# ? Вот последнее, что я пытался безрезультатно: { var us…
07 июн '18 в 04:53
1
ответ
Ошибка: метод где (String) не определен при использовании весенней загрузки mongodb
Я добавил зависимости mongodb в мое приложение весенней загрузки, однако получаю неопределенную ошибку в методе "где": ChangeStreamRequest<Person> request = ChangeStreamRequest.builder() .collection("person") .filter(newAggregation(Person.clas…
11 ноя '18 в 10:10
0
ответов
Поток изменений не публикуется при редактировании данных с помощью MongoDB Compass
Как следует из заголовка, когда я делаю изменения в данных с использованием компаса MongoDB, изменения не публикуются в потоке изменений. У меня есть сервис Node.js, который слушает поток изменений.
28 фев '19 в 05:48
0
ответов
Как использовать Node.js API драйвера MongoDB Метод класса ChangeStream hasNext(обратный вызов)
Я новичок в Node.js и пытаюсь использовать API-интерфейс накопителя Mongodb Node.js changeStream ( https://mongodb.github.io/node-mongodb-native/3.0/api/ChangeStream.html). Я не знаю, как поступить с Nodejs и вернуть Promise. Мой код, как показано н…
04 дек '18 в 16:07
2
ответа
MongoDB меняет время ожидания потока, если база данных не работает в течение некоторого времени
Я использую поток изменений mongoDB в nodejs, все работает нормально, но если база данных не работает, потребовалось более 10 5 секунд, чтобы подняться, ошибка истечения времени ожидания выброса потока изменений, вот мой код наблюдателя потока измен…
10 фев '19 в 08:43
1
ответ
Монго изменения метки времени
При отслеживании оплога я вижу метку времени для каждого события. У потоков изменений есть преимущества по сравнению с непосредственным отслеживанием оплога, поэтому я бы хотел их использовать. Тем не менее, я не могу найти способ выяснить, когда пр…
22 апр '18 в 22:44