从MongoDB读取数据

本页内容

概述

示例应用程序
查找一个
查找多个
在集合中计数文档
从查询中返回的文档计数
估计文档计数
检索不同值
监控数据变更

概述

在本页中，您可以查看可复制的代码示例，展示了您可以使用 PyMongo 获取文档的常见方法。

提示

要了解更多关于本页上展示的任何方法的信息，请参阅每个部分提供的链接。

要使用本页上的示例，将代码示例复制到示例应用程序或您自己的应用程序中。确保用您的 MongoDB 部署的相关值替换代码示例中的所有占位符，例如<连接字符串 URI>。

示例应用程序

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

确保您已安装 PyMongo。
复制以下代码并将其粘贴到新的 .py 文件中。
从本页复制一个代码示例并将其粘贴到文件中指定的行。

1 import pymongo
2 from pymongo import MongoClient
3 
4 try:
5     uri = "<connection string URI>"
6     client = MongoClient(uri)
7 
8     database = client["<database name>"]
9     collection = database["<collection name>"]
10 
11     # start example code here
12 
13     # end example code here
14 
15     client.close()
16 
17 except Exception as e:
18     raise Exception(
19         "The following error occurred: ", e)

查找单个

results = collection.find_one({ "<field name>" : "<value>" })
print(results)

要了解更多关于 find_one() 方法的信息，请参阅检索单个文档在检索数据指南中。

查找多个

results = collection.find({ "<field name>" : "<value>" })
for document in results:
    print(document)

要了解更多关于 find() 方法的知识，请参阅 Retrieve Data 指南中的查找多个文档。

在集合中计数文档

count = collection.count_documents({})
print(count)

要了解更多关于 count_documents() 方法的知识，请参阅获取准确计数指南。

查询返回的文档计数

count = collection.count_documents({ "<field name>": "<value>" })
print(count)

要了解更多关于 count_documents() 方法的知识，请参阅获取准确计数指南。

估算文档数量

count = collection.estimated_document_count()
print(count)

要了解更多关于 estimated_document_count() 方法的知识，请参阅获取估算数量指南。

检索唯一值

results = collection.distinct("<field name>")
for document in results:
    print(document)

要了解更多关于 distinct() 方法的知识，请参阅检索唯一字段值指南。

监控数据变更

with collection.watch() as stream:
    for change in stream:
        print(change)

要了解更多关于 watch() 方法的知识，请参阅监控数据变更指南。

事务

查询

1	import pymongo
2	from pymongo import MongoClient
3
4	try:
5	uri = "<connection string URI>"
6	client = MongoClient(uri)
7
8	database = client["<database name>"]
9	collection = database["<collection name>"]
10
11	# start example code here
12
13	# end example code here
14
15	client.close()
16
17	except Exception as e:
18	raise Exception(
19	"The following error occurred: ", e)