Мне нужна помощь, потому что я не знаю, почему мой агрегат очень медленный.
У меня есть одна база данных с 2 коллекциями:
пользователей (идентификатор, имя, адрес электронной почты) с 40 000 элементов
сообщений (идентификатор, автор, контент) с 39 000 элементов
Я хочу знать все сообщения, опубликованные пользователем. Я использую Casbah, и это мой код:
val aggregationOptions = AggregationOptions(AggregationOptions.CURSOR)
val content_return =
MongoClient("localhost", 27017)("Blog")("users").aggregate(
List(MongoDBObject("$lookup" -> MongoDBObject("from" -> "posts", "localField" -> "name", "foreignField" -> "author", "as" -> "posts")),
MongoDBObject("$unwind" -> "$posts")),
aggregationOptions)
Если у кого-то есть идея, большое спасибо!