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:
from pymongo import MongoClient
try: # start example code here
# end example code here
client.admin.command("ping") print("Connected successfully")
# other application code
client.close()
except Exception as e: raise Exception( "The following error occurred: ", e)import asynciofrom pymongo import AsyncMongoClient
async def main(): try: # start example code here
# end example code here
await client.admin.command("ping") print("Connected successfully")
# other application code
await client.close()
except Exception as e: raise Exception( "The following error occurred: ", e)
asyncio.run(main())Conexão
As seções a seguir descrevem como se conectar a diferentes destinos, como uma instância local do MongoDB ou uma instância hospedada na nuvem no Atlas.
Sistemas locais
O código a seguir mostra como conectar a string de conexão para se conectar a uma implementação local do MongoDB . Selecione a aba Synchronous ou Asynchronous para ver o código correspondente:
uri = "mongodb://localhost:27017/"client = MongoClient(uri)uri = "mongodb://localhost:27017/"client = AsyncMongoClient(uri)Atlas
O código abaixo mostra a string de conexão para conectar a um sistema hospedado no Atlas. Selecione a aba Synchronous ou Asynchronous para ver o código correspondente:
uri = "<Atlas connection string>"client = MongoClient(uri, server_api=pymongo.server_api.ServerApi( version="1", strict=True, deprecation_errors=True))uri = "<Atlas connection string>"client = AsyncMongoClient(uri, server_api=pymongo.server_api.ServerApi( version="1", strict=True, deprecation_errors=True))Conjunto de réplicas
O código a seguir mostra a string de conexão para conectar a um conjunto de réplica. Selecione a aba Synchronous ou Asynchronous para ver o código correspondente:
uri = "mongodb://<replica set member>:<port>/?replicaSet=<replica set name>"client = MongoClient(uri)uri = "mongodb://<replica set member>:<port>/?replicaSet=<replica set name>"client = AsyncMongoClient(uri)Compactação de rede
As seções a seguir descrevem como se conectar ao MongoDB enquanto especifica algoritmos de compressão de rede.
Algoritmos de compressão
As seguintes guias demonstram como especificar todos os compressores disponíveis durante a conexão ao MongoDB:
client = pymongo.MongoClient("mongodb://<db_username>:<db_password>@<hostname>:<port>", compressors = "snappy,zstd,zlib")uri = ("mongodb://<db_username>:<db_password>@<hostname>:<port>/?" "compressors=snappy,zstd,zlib")client = pymongo.MongoClient(uri)client = pymongo.AsyncMongoClient("mongodb://<db_username>:<db_password>@<hostname>:<port>", compressors = "snappy,zstd,zlib")uri = ("mongodb://<db_username>:<db_password>@<hostname>:<port>/?" "compressors=snappy,zstd,zlib")client = pymongo.AsyncMongoClient(uri)Para aprender mais sobre como especificar algoritmos de compactação, consulte Compatibilidade de Versão no guia de Compactação de Rede.
zlibNível de compactação
As seguintes guias demonstram como especificar um nível de compressão para o compressor zlib :
client = pymongo.MongoClient("mongodb://<db_username>:<db_password>@<hostname>:<port>", compressors = "zlib", zlibCompressionLevel=<zlib compression level>)uri = ("mongodb://<db_username>:<db_password>@<hostname>:<port>/?" "compressors=zlib" "zlibCompressionLevel=<zlib compression level>")client = pymongo.MongoClient(uri)client = pymongo.AsyncMongoClient("mongodb://<db_username>:<db_password>@<hostname>:<port>", compressors = "zlib", zlibCompressionLevel=<zlib compression level>)uri = ("mongodb://<db_username>:<db_password>@<hostname>:<port>/?" "compressors=zlib" "zlibCompressionLevel=<zlib compression level>")client = pymongo.AsyncMongoClient(uri)Para aprender mais sobre como definir o nível de compactação zlib, consulte Compatibilidade de Versão no guia de Compactação de Rede.
Seleção do Servidor
O código a seguir mostra uma string de conexão que especifica uma função de seleção de servidor . Selecione a aba Synchronous ou Asynchronous para ver o código correspondente:
client = pymongo.MongoClient("mongodb://<db_username>:<db_password>@<hostname>:<port>", server_selector=<selector function>)client = pymongo.AsyncMongoClient("mongodb://<db_username>:<db_password>@<hostname>:<port>", server_selector=<selector function>)Para saber mais sobre como personalizar a seleção do servidor, consulte Personalizar seleção de servidor do MongoDB.
Stable API
O código a seguir mostra como especificar as configurações da API estável para uma conexão.Selecione a guia Synchronous ou Asynchronous para ver o código correspondente:
from pymongo.server_api import ServerApi
client = pymongo.MongoClient("mongodb://<db_username>:<db_password>@<hostname:<port>", server_api=ServerApi("<Stable API version>"))from pymongo.server_api import ServerApi
client = pymongo.AsyncMongoClient("mongodb://<db_username>:<db_password>@<hostname:<port>", server_api=ServerApi("<Stable API version>"))Para saber mais sobre a stable API, consulte stable API.
Limitar o tempo de execução do servidor MongoDB
bloqueio de tempo limite
O seguinte código mostra como definir um tempo limite do lado do cliente usando o método timeout():
with pymongo.timeout(<timeout length>): # perform operations herePara saber mais sobre os tempos limite do lado do cliente, consulte Limitar o tempo de execução do servidor MongoDB.
Opção de conexão timeoutMS
As seguintes guias demonstram como definir um tempo limite do lado do cliente usando a opção de conexão do timeoutMS:
client = pymongo.MongoClient("mongodb://<db_username>:<db_password>@<hostname@:<port>", timeoutMS=<timeout length>)uri = "mongodb://<db_username>:<db_password>@<hostname:<port>/?timeoutMS=<timeout length>"client = pymongo.MongoClient(uri)client = pymongo.AsyncMongoClient("mongodb://<db_username>:<db_password>@<hostname@:<port>", timeoutMS=<timeout length>)uri = "mongodb://<db_username>:<db_password>@<hostname:<port>/?timeoutMS=<timeout length>"client = pymongo.AsyncMongoClient(uri)Para saber mais sobre os tempos limite do lado do cliente, consulte Limitar o tempo de execução do servidor MongoDB.