以下是一个示例,展示如何按照分组和聚合带有嵌套字段的数据:
from pymongo import MongoClient
# 连接到MongoDB数据库
client = MongoClient('mongodb://localhost:27017/')
db = client['mydatabase'] # 替换为你的数据库名称
# 创建一个示例文档
doc1 = {
'name': 'Alice',
'age': 25,
'address': {
'city': 'New York',
'country': 'USA'
}
}
doc2 = {
'name': 'Bob',
'age': 30,
'address': {
'city': 'London',
'country': 'UK'
}
}
doc3 = {
'name': 'Charlie',
'age': 35,
'address': {
'city': 'Paris',
'country': 'France'
}
}
# 将文档插入到集合中
collection = db['mycollection'] # 替换为你的集合名称
collection.insert_many([doc1, doc2, doc3])
# 按照嵌套字段进行分组和聚合
pipeline = [
{
'$group': {
'_id': '$address.city', # 按照城市进行分组
'count': {'$sum': 1}, # 统计每个城市的数量
'average_age': {'$avg': '$age'} # 计算每个城市的平均年龄
}
}
]
result = collection.aggregate(pipeline)
# 打印结果
for doc in result:
print(doc)
这个示例使用Python的pymongo库连接到MongoDB数据库,并在指定的集合中插入了几个文档。然后,使用聚合管道按照嵌套字段address.city
进行分组,并计算每个城市的数量和平均年龄。最后,打印结果。
上一篇:按照分组和卷积进行的sql排序
下一篇:按照分组和聚合的方式来消除记录