Как отсортировать mongodb с пимонго

164

Я пытаюсь использовать функцию сортировки при запросе моего mongoDB, но это не удается. Тот же запрос работает в консоли MongoDB, но не здесь. Код выглядит следующим образом:

import pymongo

from  pymongo import Connection
connection = Connection()
db = connection.myDB
print db.posts.count()
for post in db.posts.find({}, {'entities.user_mentions.screen_name':1}).sort({u'entities.user_mentions.screen_name':1}):
    print post

Я получаю следующую ошибку:

Traceback (most recent call last):
  File "find_ow.py", line 7, in <module>
    for post in db.posts.find({}, {'entities.user_mentions.screen_name':1}).sort({'entities.user_mentions.screen_name':1},1):
  File "/Library/Python/2.6/site-packages/pymongo-2.0.1-py2.6-macosx-10.6-universal.egg/pymongo/cursor.py", line 430, in sort
  File "/Library/Python/2.6/site-packages/pymongo-2.0.1-py2.6-macosx-10.6-universal.egg/pymongo/helpers.py", line 67, in _index_document
TypeError: first item in each key pair must be a string

В другом месте я нашел ссылку, в которой говорилось, что мне нужно поместить 'u' перед ключом при использовании pymongo, но это тоже не сработало. Кто-нибудь еще заставит это работать или это ошибка.

WildBill
источник

Ответы:

302

.sort()Пимонго, принимает keyи directionкак параметры.

Итак, если вы хотите отсортировать, скажем, idто вы должны.sort("_id", 1)

Для нескольких полей:

.sort([("field1", pymongo.ASCENDING), ("field2", pymongo.DESCENDING)])
Бен
источник
124
.sort([("field1",pymongo.ASCENDING), ("field2",pymongo.DESCENDING)])сортировать несколько полей.
Ричардр
4
Для тех, кто ищет подробности, здесь есть ссылка на документацию по сортировке с помощью pymongo api.mongodb.org/python/current/api/pymongo/…
Шейн Рустл
21
ПРИМЕЧАНИЕ: по возрастанию: 1, по убыванию -1
Martlark
2
Есть идеи, почему они вырезали такую ​​простую нотацию JSON {"field1": 1, "field2": 1}?
Нико
2
@Nico - см. Ответ ромуломаду ниже
Bajal
34

Вы можете попробовать это:

db.Account.find().sort("UserName")  
db.Account.find().sort("UserName",pymongo.ASCENDING)   
db.Account.find().sort("UserName",pymongo.DESCENDING)  
новый Свет
источник
17

Это также работает:

db.Account.find().sort('UserName', -1)
db.Account.find().sort('UserName', 1)

Я использую это в своем коде, пожалуйста, прокомментируйте, если я делаю что-то не так, спасибо.

Снехал Пармар
источник
Вы должны использовать: ASCENDINGи DESCENDINGот pymongo. :)
Sn0pY
7

Почему python использует список кортежей вместо dict?

В python вы не можете гарантировать, что словарь будет интерпретирован в указанном вами порядке.

Таким образом, в оболочке mongo вы можете это сделать, .sort({'field1':1,'field2':1})и интерпретатор должен отсортировать field1 на первом уровне и field 2 на втором уровне.

Если этот синтаксис использовался в python, есть шанс отсортировать field2 на первом уровне. С кортежом риска нет.

.sort([("field1",pymongo.ASCENDING), ("field2",pymongo.DESCENDING)])
romulomadu
источник
1
.sort([("field1",pymongo.ASCENDING), ("field2",pymongo.DESCENDING)])

Python использует ключ, направление. Вы можете использовать вышеуказанный способ.

Так что в вашем случае вы можете сделать это

for post in db.posts.find().sort('entities.user_mentions.screen_name',pymongo.ASCENDING):
        print post
Ash Upadhyay
источник
0

TLDR: конвейер агрегации быстрее по сравнению с обычным .find().sort().

Теперь переходим к реальному объяснению. Есть два способа выполнить операции сортировки в MongoDB:

  1. Использование .find()и .sort().
  2. Или используя конвейер агрегации.

Как предлагают многие .find (). Sort () - самый простой способ выполнить сортировку.

.sort([("field1",pymongo.ASCENDING), ("field2",pymongo.DESCENDING)])

Однако это медленный процесс по сравнению с конвейером агрегации.

Подходя к методу агрегации трубопроводов. Шаги для реализации простого конвейера агрегации, предназначенного для сортировки:

  1. $ match (необязательный шаг)
  2. $ сортировать

ПРИМЕЧАНИЕ. По моему опыту, конвейер агрегации работает немного быстрее, чем .find().sort()метод.

Вот пример конвейера агрегации.

db.collection_name.aggregate([{
    "$match": {
        # your query - optional step
    }
},
{
    "$sort": {
        "field_1": pymongo.ASCENDING,
        "field_2": pymongo.DESCENDING,
        ....
    }
}])

Попробуйте этот метод самостоятельно, сравните скорость и дайте мне знать об этом в комментариях.

Редактировать: не забудьте использовать allowDiskUse=Trueпри сортировке по нескольким полям, иначе это вызовет ошибку.

Анудж Гупта
источник
0

Скажем, вы хотите отсортировать по полю «selected_on», тогда вы можете сделать так,

.sort('{}'.format('created_on'), 1 if sort_type == 'asc' else -1)
Г-жа Танвир Райхан
источник