Query

Visão geral

Nesta página, você pode ver exemplos de código copiáveis que mostram métodos comuns que você pode usar para encontrar documentos com o PyMongo.

Para usar um exemplo desta página, copie o exemplo de código no aplicativo de amostra ou em seu próprio aplicativo. Certifique-se de substituir todos os espaços reservados nos exemplos de código, como <connection string URI>, pelos valores relevantes para sua implantação do MongoDB.

Selecione a aba Synchronous ou Asynchronous para ver o código correspondente:

1
import pymongo
2
from pymongo import MongoClient
3
4
try:
5
    uri = "<connection string URI>"
6
    client = MongoClient(uri)
7
8
    database = client["<database name>"]
9
    collection = database["<collection name>"]
10
11
    # start example code here
12
13
    # end example code here
14
15
    client.close()
16
17
except Exception as e:
18
    raise Exception(
19
        "The following error occurred: ", e)

1
import asyncio
2
import pymongo
3
from pymongo import AsyncMongoClient
4
5
async def main():
6
    try:
7
        uri = "<connection string URI>"
8
        client = AsyncMongoClient(uri)
9
10
        database = client["<database name>"]
11
        collection = database["<collection name>"]
12
13
        # start example code here
14
15
        # end example code here
16
17
        await client.close()
18
19
    except Exception as e:
20
        raise Exception(
21
            "The following error occurred: ", e)
22
23
asyncio.run(main())

encontrar um

results = collection.find_one({ "<field name>" : "<value>" })
print(results)

results = await collection.find_one({ "<field name>" : "<value>" })
print(results)

Para saber mais sobre o método find_one() , consulte Encontrar um documento no guia Recuperar dados.

Encontrar vários

results = collection.find({ "<field name>" : "<value>" })
for document in results:
    print(document)

results = collection.find({ "<field name>" : "<value>" })
async for document in results:
    print(document)

Para saber mais sobre o método find() , consulte Encontrar vários documentos no guia Recuperar dados.

Contagem de documentos em uma coleção

count = collection.count_documents({})
print(count)

count = await collection.count_documents({})
print(count)

Para saber mais sobre o método count_documents() , consulte o guia Recuperar uma contagem precisa .

Contagem de documentos retornados de uma query

count = collection.count_documents({ "<field name>": "<value>" })
print(count)

count = await collection.count_documents({ "<field name>": "<value>" })
print(count)

Para saber mais sobre o método count_documents() , consulte o guia Recuperar uma contagem precisa .

Contagem estimada de documentos

count = collection.estimated_document_count()
print(count)

count = await collection.estimated_document_count()
print(count)

Para saber mais sobre o método estimated_document_count() , consulte o guia Recuperar uma contagem estimada .

Retrieve Distinct Values

results = collection.distinct("<field name>")
for document in results:
    print(document)

results = await collection.distinct("<field name>")
for document in results:
    print(document)

Para saber mais sobre o método distinct() , consulte o guia Retrieve Distinct Field Values (Recuperar valores de campos distintos).

Monitorar alterações de dados

with collection.watch() as stream:
    for change in stream:
        print(change)

async with await collection.watch() as stream:
    async for change in stream:
        print(change)

Para saber mais sobre o método watch(), consulte o guia Monitorar dados com change streams.