Visão geral
Esta página contém exemplos de código que mostram como conectar seu aplicativo Python ao MongoDB com várias configurações.
Dica
Para saber mais sobre as opções de conexão nesta página, consulte o link fornecido em cada seção.
Para usar um exemplo de conexão desta página, copie o exemplo de código no aplicativo de exemplo ou em seu próprio aplicativo. Certifique-se de substituir todos os espaços reservados nos exemplos de código, como <hostname>, pelos valores relevantes para sua implantação do MongoDB.
Aplicativo de amostra
Você pode usar o seguinte aplicativo de exemplo para testar os exemplos de código nesta página. Para usar o aplicativo de amostra, execute as seguintes etapas:
Verifique se o PyMongo está instalado.
Copie o seguinte código e cole-o em um novo arquivo
.py.Copie um exemplo de código desta página e cole-o nas linhas especificadas no arquivo.
Selecione a aba Synchronous ou Asynchronous para ver o código correspondente:
import pymongofrom pymongo import MongoClient
try: uri = "<connection string URI>" client = MongoClient(uri)
database = client["<database name>"] collection = database["<collection name>"]
# start example code here
# end example code here
client.close()
except Exception as e: raise Exception( "The following error occurred: ", e)import asyncioimport pymongofrom pymongo import AsyncMongoClient
async def main(): try: uri = "<connection string URI>" client = AsyncMongoClient(uri)
database = client["<database name>"] collection = database["<collection name>"]
# start example code here
# end example code here
await client.close()
except Exception as e: raise Exception( "The following error occurred: ", e)
asyncio.run(main())insertOne
result = collection.insert_one({ "<field name>" : "<value>" })
print(result.acknowledged)result = await collection.insert_one({ "<field name>" : "<value>" })
print(result.acknowledged)Para saber mais sobre o método insert_one() , consulte o guia Inserir documentos .
Inserir vários
document_list = [ { "<field name>" : "<value>" }, { "<field name>" : "<value>" }]
result = collection.insert_many(document_list)
print(result.acknowledged)document_list = [ { "<field name>" : "<value>" }, { "<field name>" : "<value>" }]
result = await collection.insert_many(document_list)
print(result.acknowledged)Para saber mais sobre o método insert_many() , consulte o guia Inserir documentos .
UpdateOne
query_filter = { "<field to match>" : "<value to match>" }update_operation = { "$set" : { "<field name>" : "<value>" }}result = collection.update_one(query_filter, update_operation)
print(result.modified_count)query_filter = { "<field to match>" : "<value to match>" }update_operation = { "$set" : { "<field name>" : "<value>" }}result = await collection.update_one(query_filter, update_operation)
print(result.modified_count)Para saber mais sobre o método update_one() , consulte o guia Atualizar documentos .
Atualizar vários
query_filter = { "<field to match>" : "<value to match>" }update_operation = { "$set" : { "<field name>" : "<value>" }}result = collection.update_many(query_filter, update_operation)
print(result.modified_count)query_filter = { "<field to match>" : "<value to match>" }update_operation = { "$set" : { "<field name>" : "<value>" }}result = await collection.update_many(query_filter, update_operation)
print(result.modified_count)Para saber mais sobre o método update_many() , consulte o guia Atualizar documentos .
replaceOne
query_filter = { "<field to match>" : "<value to match>" }replace_document = { "<new document field name>" : "<new document value>" }
result = collection.replace_one(query_filter, replace_document)
print(result.modified_count)query_filter = { "<field to match>" : "<value to match>" }replace_document = { "<new document field name>" : "<new document value>" }
result = await collection.replace_one(query_filter, replace_document)
print(result.modified_count)Para saber mais sobre o método replace_one() , consulte o guia Substituir documentos .
Excluir um
query_filter = { "<field to match>" : "<value to match>" }
result = collection.delete_one(query_filter)
print(result.deleted_count)query_filter = { "<field to match>" : "<value to match>" }
result = await collection.delete_one(query_filter)
print(result.deleted_count)Para saber mais sobre o método delete_one() , consulte o guia Excluir documentos .
Excluir vários
query_filter = { "<field to match>" : "<value to match>" }
result = collection.delete_many(query_filter)
print(result.deleted_count)query_filter = { "<field to match>" : "<value to match>" }
result = await collection.delete_many(query_filter)
print(result.deleted_count)Para saber mais sobre o método delete_many() , consulte o guia Excluir documentos .
Gravação em massa
operations = [ pymongo.InsertOne( { "<field name>" : "<value>" } ), pymongo.UpdateMany( { "<field to match>" : "<value to match>" }, { "$set" : { "<field name>" : "<value>" }}, ), pymongo.DeleteOne( { "<field to match>" : "<value to match>" } ),]
result = collection.bulk_write(operations)
print(result)operations = [ pymongo.InsertOne( { "<field name>" : "<value>" } ), pymongo.UpdateMany( { "<field to match>" : "<value to match>" }, { "$set" : { "<field name>" : "<value>" }}, ), pymongo.DeleteOne( { "<field to match>" : "<value to match>" } ),]
result = await collection.bulk_write(operations)
print(result)Para saber mais sobre o método bulk_write() , consulte o guia de escrita em massa .
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).