Docs 菜单
Docs 主页
/
语言
/
Python
/
Pymongo 驱动程序

连接至 MongoDB

在此页面上

  • Overview
  • 示例应用程序
  • 连接
  • 本地部署
  • Atlas
  • 副本集(Replica Set)
  • 网络压缩
  • 压缩算法
  • zlibCompressionLevel
  • 服务器选择
  • Stable API
  • 限制MongoDB Server执行时间
  • 超时块
  • timeoutMS 连接选项

Overview

本页包含的代码示例展示了如何使用各种设置将 Python 应用程序连接到 MongoDB。

提示

要了解有关此页面上的连接选项的更多信息，请参阅每个部分中提供的链接。

要使用此页面中的连接示例，请将代码示例复制到示例应用程序或您自己的应用程序中。 请务必将代码示例中的所有占位符（例如 <hostname> ）替换为 MongoDB 部署的相关值。

示例应用程序

您可以使用以下示例应用程序来测试本页上的代码示例。 要使用示例应用程序，请执行以下步骤：

  1. 确保已安装 PyMongo。

  2. 复制以下代码并将其粘贴到新的.py文件中。

  3. 从此页面复制代码示例，并将其粘贴到文件中的指定行。

1from pymongo import MongoClient
2
3try:
4    # start example code here
5
6    # end example code here
7
8    client.admin.command("ping")
9    print("Connected successfully")
10
11    # other application code
12
13    client.close()
14
15except Exception as e:
16    raise Exception(
17        "The following error occurred: ", e)

连接

本地部署

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

Atlas

uri = "<Atlas connection string>"
client = MongoClient(uri, server_api=pymongo.server_api.ServerApi(
 version="1", strict=True, deprecation_errors=True))

副本集(Replica Set)

uri = "mongodb://<replica set member>:<port>/?replicaSet=<replica set name>"
client = MongoClient(uri)

网络压缩

压缩算法

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)

要学习；了解有关指定压缩算法的更多信息，请参阅 指定压缩算法 网络压缩指南中的。

zlibCompressionLevel

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)

要了解有关设置 zlib 压缩级别的更多信息，请参阅网络压缩指南中的指定压缩算法。

服务器选择

client = pymongo.MongoClient("mongodb://<db_username>:<db_password>@<hostname>:<port>",
                             server_selector=<selector function>)

要了解有关自定义服务器选择的更多信息，请参阅自定义MongoDB Server选择。

Stable API

from pymongo.server_api import ServerApi
client = pymongo.MongoClient("mongodb://<db_username>:<db_password>@<hostname:<port>",
                             server_api=ServerApi("<Stable API version>"))

要了解有关stable API的更多信息，请参阅stable API 。

限制MongoDB Server执行时间

超时块

with pymongo.timeout(<timeout length>):
   # perform operations here

要了解有关客户端超时的更多信息，请参阅限制MongoDB Server执行时间。

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)

要了解有关客户端超时的更多信息，请参阅限制MongoDB Server执行时间。

后退

开始体验

来年

创建 MongoClient