Acessar dados de um cursor

Visão geral

Neste guia, você pode aprender como acessar dados de um cursor com o PyMongo.

Um cursor é um mecanismo que retorna os resultados de uma operação de leitura em lotes iteráveis. Como um cursor contém apenas um subconjunto de documentos a qualquer momento, os cursores reduzem o consumo de memória e o uso da largura de banda da rede.

Sempre que o PyMongo executa uma operação de leitura que retorna vários documentos, ele retorna automaticamente esses documentos em um cursor.

Acesse o conteúdo do cursor iterativamente

Para iterar sobre o conteúdo de um cursor, use um loop for , conforme mostrado no exemplo a seguir:

results = collection.find()
for document in results:
    print(document)

Recuperar documentos individualmente

Recupere documentos de um cursor individualmente chamando o método next() .

O exemplo a seguir encontra todos os documentos em "Dunkin' Donuts" name com um valor de . Em seguida, ele imprime o primeiro documento no cursor chamando o método next() .

results = collection.find({ "name": "Dunkin' Donuts" })
print(results.next())

{'_id': ObjectId('...'), 'address': { ... }, 'borough': 'Bronx', 'cuisine': 'Donuts', 'grades': [...], 'name': "Dunkin' Donuts", 'restaurant_id': '40379573'}

Recuperar todos os documentos

Para recuperar todos os documentos de um cursor, converta o cursor em um list como mostrado no seguinte exemplo:

results = collection.find({ "name": "Dunkin' Donuts" })
all_results = list(results)
for document in all_results:
    print(document)

Fechar um cursor

Por padrão, o MongoDB fecha um cursor quando o cliente esgota todos os resultados no cursor. Para fechar explicitamente um cursor, chame o método close() como mostrado no exemplo a seguir:

results = collection.find()
...
results.close()

Cursores persistentes

Ao fazer query em uma capped collection, você pode usar um cursor tailable que permanece aberto depois que o cliente esgota os resultados em um cursor. Para criar um cursor tailable com capped collection, especifique CursorType.TAILABLE_AWAIT na opção cursor_type de um método find() .

O exemplo a seguir usa um cursor tailable para rastrear o oplog de um membro do conjunto de réplicas:

oplog = client.local.oplog.rs
first = oplog.find().sort('$natural', pymongo.ASCENDING).limit(-1).next()
print(first)
ts = first['ts']
while True:
    cursor = oplog.find({'ts': {'$gt': ts}},
                        cursor_type=pymongo.CursorType.TAILABLE_AWAIT)
    while cursor.alive:
        for doc in cursor:
            ts = doc['ts']
            print(doc)
        # You end up here if the find() method returns no documents, or if
        # no new documents are added to the collection for more than 1 second.
        time.sleep(1)

Para saber mais sobre cursores tailable, consulte o guia Cursores tailable no manual do MongoDB Server .

Solução de problemas

Exception ignored in: <function Cursor.__del__ at 0x1048129d8>
...
AttributeError: 'Cursor' object has no attribute '_Cursor__killed'
...
TypeError: __init__() got an unexpected keyword argument '<argument>'