Elija un destino de conexión

Overview

En esta guía, puedes aprender cómo utilizar una cadena de conexión y MongoClient objeto para conectarse a diferentes tipos de implementaciones de MongoDB.

Atlas

Para conectarte a una implementación de MongoDB en Atlas, incluye los siguientes elementos en tu cadena de conexión:

• URL de tu clúster de Atlas

• Nombre de usuario de MongoDB

• Contraseña de MongoDB

Luego, pase la cadena de conexión al constructor MongoClient.

Cuando se conecte a Atlas, se recomienda utilizar la opción de cliente de Stable API para evitar cambios disruptivos al actualizar a una nueva versión de MongoDB Server en Atlas. Para obtener más información sobre la funcionalidad Stable API, consulta Página API estable.

El siguiente código muestra cómo utilizar PyMongo para conectarse a un clúster de Atlas. El código también utiliza la opción server_api para especificar una Stable API. Selecciona el Synchronous o la pestaña Asynchronous para ver el código correspondiente:

from pymongo import MongoClient
from pymongo.server_api import ServerApi
# Replace the placeholder with your Atlas connection string
uri = "<connection string>"
# Create a MongoClient with a MongoClientOptions object to set the Stable API version
client = MongoClient(uri, server_api=ServerApi(
    version='1', strict=True, deprecation_errors=True))
try:
    # Connect the client to the server (optional starting in v4.7)
    client.connect()
    # Send a ping to confirm a successful connection
    client.admin.command({'ping': 1})
    print("Pinged your deployment. You successfully connected to MongoDB!")
finally:
    # Ensures that the client will close when you finish/error
    client.close()

import asyncio
from pymongo import AsyncMongoClient
from pymongo.server_api import ServerApi
async def main():
    # Replace the placeholder with your Atlas connection string
    uri = "<connection string>"
    # Create a MongoClient with a MongoClientOptions object to set the Stable API version
    client = AsyncMongoClient(uri, server_api=ServerApi(
        version='1', strict=True, deprecation_errors=True))
    try:
        # Send a ping to confirm a successful connection
        await client.admin.command({'ping': 1})
        print("Pinged your deployment. You successfully connected to MongoDB!")
    finally:
        # Ensures that the client will close when you finish/error
        await client.close()
asyncio.run(main())

Implementaciones locales

Para conectarse a una implementación local de MongoDB, use localhost como el nombre de host. Por defecto, el proceso mongod se ejecuta en el puerto 27017, aunque puedes personalizarlo para tu implementación.

El siguiente código muestra como usar PyMongo para conectarse a una implementación local de MongoDB. Selecciona la pestaña Synchronous o Asynchronous para ver el código correspondiente:

from pymongo import MongoClient
uri = "mongodb://localhost:27017/"
client = MongoClient(uri)

from pymongo import AsyncMongoClient
uri = "mongodb://localhost:27017/"
client = AsyncMongoClient(uri)

Sets de réplicas

Para conectar a un set de réplicas, especifique los nombres de host (o direcciones IP) y los números de puerto de los miembros del set de réplicas en su cadena de conexión.

El siguiente código muestra cómo usar PyMongo para conectarse a un conjunto de réplicas que contiene tres hosts. Seleccione la pestaña Synchronous o Asynchronous para ver el código correspondiente:

from pymongo import MongoClient
client = MongoClient("mongodb://host1:27017,host2:27017,host3:27017")

from pymongo import AsyncMongoClient
client = AsyncMongoClient("mongodb://host1:27017,host2:27017,host3:27017")

Si no puede proporcionar una lista completa de hosts en el conjunto de réplicas, puede especificar uno o más de ellos e indicarle a PyMongo que realice la detección automática para encontrar los demás. Para indicarle al controlador que realice la detección automática, realice una de las siguientes acciones:

• Especifique el nombre del set de réplicas como el valor del parámetro replicaSet.

• Especifique false como el valor del parámetro directConnection.

• Especifica más de un host en el conjunto de réplicas.

En el siguiente ejemplo, el driver utiliza un URI de conexión de muestra para conectarse al set de réplicas de MongoDB sampleRS, que se ejecuta en el puerto 27017 de tres hosts diferentes, incluido host1. Selecciona la pestaña Synchronous o Asynchronous para ver el código correspondiente:

from pymongo import MongoClient
uri = "mongodb://host1:27017/?replicaSet=sampleRS"
client = MongoClient(uri)

from pymongo import AsyncMongoClient
uri = "mongodb://host1:27017/?replicaSet=sampleRS"
client = AsyncMongoClient(uri)

PyMongo distribuye uniformemente las operaciones entre las implementaciones accesibles dentro del localThresholdMS valor del cliente. Para obtener más información sobre cómo PyMongo distribuye las operaciones entre varias implementaciones de MongoDB, consulte la guía "Personalizar la selección del servidor".

from pymongo import MongoClient
client = MongoClient("mongodb://<hostname>:<port>",
                     directConnection=True)

from pymongo import MongoClient
uri = ("mongodb://<hostname>:<port>/?"
       "directConnection=true")
client = MongoClient(uri)

from pymongo import AsyncMongoClient
client = AsyncMongoClient("mongodb://<hostname>:<port>",
                           directConnection=True)

from pymongo import AsyncMongoClient
uri = ("mongodb://<hostname>:<port>/?"
       "directConnection=true")
client = AsyncMongoClient(uri)

Detección de servicios DNS

Para utilizar el descubrimiento de servicios DNS para buscar el registro DNS SRV del servicio al que te estás conectando, deber especificar el formato de conexión SRV en tu cadena de conexión. Además, si habilitas el formato de conexión SRV, PyMongo vuelve a buscar automáticamente nuevos hosts sin necesidad de cambiar la configuración del cliente.

El siguiente código muestra una cadena de conexión que utiliza el formato de conexión SRV:

uri = "mongodb+srv://<hostname>/"

Para aprender más sobre el formato de conexión SRV, consulta la entrada Formato de conexión SRV en el manual de MongoDB Server.

Solución de problemas

pymongo.errors.ConfigurationError: Server at localhost:27017 reports wire version 6, but this version of PyMongo requires at least 7 (MongoDB 4.0).

File "/Library/Python/2.7/site-packages/pymongo/collection.py", line 1560, in count
  return self._count(cmd, collation, session)
  File "/Library/Python/2.7/site-packages/pymongo/collection.py", line 1504, in _count
  with self._socket_for_reads() as (connection, slave_ok):
  File "/System/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/contextlib.py", line 17, in __enter__
  return self.gen.next()
  File "/Library/Python/2.7/site-packages/pymongo/mongo_client.py", line 982, in _socket_for_reads
  server = topology.select_server(read_preference)
  File "/Library/Python/2.7/site-packages/pymongo/topology.py", line 224, in select_server
  address))
  File "/Library/Python/2.7/site-packages/pymongo/topology.py", line 183, in select_servers
  selector, server_timeout, address)
  File "/Library/Python/2.7/site-packages/pymongo/topology.py", line 199, in _select_servers_loop
  self._error_message(selector))
pymongo.errors.ServerSelectionTimeoutError: localhost:27017: timed out

Documentación de la API

Para aprender más sobre cómo crear un objeto MongoClient en PyMongo, consulta la siguiente documentación de API:

• MongoClient