Как вы проверяете, действительно ли клиент для экземпляра MongoDB?

Ответ 1

Параметр ключевого слова serverSelectionTimeoutMS pymongo.mongo_client.MongoClient определяет, как долго драйвер попытается подключиться к серверу. Значение по умолчанию - 30 с.

Установите его на очень низкое значение, совместимое с типичным временем соединения¹, чтобы немедленно сообщить об ошибке. После этого вам нужно запросить БД, чтобы вызвать попытку подключения:

>>> maxSevSelDelay = 1 # Assume 1ms maximum server selection delay
>>> client = pymongo.MongoClient("someInvalidURIOrNonExistantHost",
                                 serverSelectionTimeoutMS=maxSevSelDelay)
//                               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
>>> client.server_info()

Это приведет к повышению pymongo.errors.ServerSelectionTimeoutError.

_{¹ Очевидно, что установка serverSelectionTimeoutMS - 0 может работать даже в конкретном случае, когда ваш сервер имеет очень низкую задержку (например, "локальный" сервер с очень легкой нагрузкой)}

Это зависит от вас, чтобы поймать это исключение и правильно обработать его. Что-то вроде этого:

try:
    client = pymongo.MongoClient("someInvalidURIOrNonExistantHost",
                                     serverSelectionTimeoutMS=maxSevSelDelay)
    client.server_info() # force connection on a request as the
                         # connect=True parameter of MongoClient seems
                         # to be useless here 
except pymongo.errors.ServerSelectionTimeoutError as err:
    # do whatever you need
    print(err)

отобразит:

No servers found yet

Ответ 2

Привет, чтобы узнать, что соединение установлено или нет, вы можете это сделать:

from pymongo import MongoClient
from pymongo.errors import ConnectionFailure
client = MongoClient()
try:
   # The ismaster command is cheap and does not require auth.
   client.admin.command('ismaster')
except ConnectionFailure:
   print("Server not available")

Ответ 3

serverSelectionTimeoutMS

Это определяет, как долго блокировать выбор сервера, прежде чем бросать исключение. Значение по умолчанию - 30 000 (миллисекунды). Это должно быть настраивается на уровне клиента. Он НЕ ДОЛЖЕН настраиваться на уровня объекта базы данных, объекта коллекции или уровня индивидуальный запрос.

Это значение по умолчанию было выбрано для типичного сервера первичные выборы для завершения. Поскольку сервер улучшает скорость выборов, это число может быть пересмотрено вниз.

Пользователи, которые могут переносить длительные задержки для выбора сервера, когда топология в потоке может установить это выше. Пользователи, которые хотят "провалиться" fast ", когда топология находится в потоке, может установить это на небольшое число.

СерверSelectionTimeoutMS нуля имеет значение в некоторых случаях водители; нулевое значение не определено в этой спецификации, но все драйверы СЛЕДУЕТ документировать значение нуля.

https://github.com/mongodb/specifications/blob/master/source/server-selection/server-selection.rst#serverselectiontimeoutms

# pymongo 3.5.1
from pymongo import MongoClient
from pymongo.errors import ServerSelectionTimeoutError

client = MongoClient("mongodb://localhost:27000/", serverSelectionTimeoutMS=10, connectTimeoutMS=20000)

try:
    info = client.server_info() # Forces a call.
except ServerSelectionTimeoutError:
    print("server is down.")

# If connection create a new one with serverSelectionTimeoutMS=30000

Ответ 4

serverSelectionTimeoutMS не работает для меня (Python 2.7.12, MongoDB 3.6.1, pymongo 3.6.0). A. Jesse Jiryu Davis предложил в вопрос GitHub, что мы сначала пытаемся подключиться к сокету как тест лакмусовой бумажки. Это делает трюк для меня.

def throw_if_mongodb_is_unavailable(host, port):
    import socket
    sock = None
    try:
        sock = socket.create_connection(
            (host, port),
            timeout=1) # one second
    except socket.error as err:
        raise EnvironmentError(
            "Can't connect to MongoDB at {host}:{port} because: {err}"
            .format(**locals()))
    finally:
        if sock is not None:
            sock.close()

# elsewhere...
HOST = 'localhost'
PORT = 27017
throw_if_mongodb_is_unavailable(HOST, PORT)
import pymongo
conn = pymongo.MongoClient(HOST, PORT)
print(conn.admin.command('ismaster'))
# etc.

Есть много проблем, которые не поймают, но если сервер не запущен или недоступен, это сразу покажет вам.