【发布时间】:2015-09-15 23:04:17
【问题描述】:
我对 mongodb distinct 查询有一个奇怪的行为。目前,我使用的是 2.6.10 版本。 好的,让我们创建一个简单的集合进行测试,并附上解释。
from pymongo import MongoClient
import random
client = MongoClient('127.0.0.1', 27017)
client.DBTEST.random.remove({})
value = 0
BATCH_LEN = 16384
BATCH = []
for i in xrange(0, 500000):
BATCH.append({
"product": "value_uniq_1",
"number": value
})
if random.randint(0, 100) <= 1:
value = i
if len(BATCH) > BATCH_LEN:
client.DBTEST.random.insert(BATCH)
BATCH = []
client.DBTEST.random.insert(BATCH)
BATCH = []
好的,它将创建包含这样的文档的集合chich
╔══════════════╦════════╗
║ product ║ number ║
╠══════════════╬════════╣
║ value_uniq_1 ║ 1 ║
║ value_uniq_1 ║ 1 ║
║ value_uniq_1 ║ 1 ║
║ value_uniq_1 ║ 56 ║
║ value_uniq_1 ║ 56 ║
║ value_uniq_1 ║ 56 ║
║ ... ║ ... ║
║ value_uniq_1 ║ 150054 ║
║ value_uniq_1 ║ 150054 ║
║ value_uniq_1 ║ 150054 ║
╚══════════════╩════════╝
现在,product 只有 1 个唯一值,但在不久的将来(1 周),它将增加到近 30 个不同的字符串值,如下所示:
╔══════════════╦════════╗
║ product ║ number ║
╠══════════════╬════════╣
║ value_uniq_1 ║ 1 ║
║ value_uniq_1 ║ 1 ║
║ value_uniq_1 ║ 1 ║
║ value_uniq_1 ║ 56 ║
║ value_uniq_1 ║ 56 ║
║ value_uniq_1 ║ 56 ║
║ ... ║ ... ║
║ value_uniq_1 ║ 150054 ║
║ value_uniq_1 ║ 150054 ║
║ value_uniq_1 ║ 150054 ║
║ value_uniq_2 ║ 987 ║
║ value_uniq_2 ║ 987 ║
║ value_uniq_2 ║ 987 ║
╚══════════════╩════════╝
好的,我完成了我的数据结构,现在让我们看一下 mongodb 查询。
我的主要目标是为某些product 获取number 的所有唯一值。
我是这样做的:
db.random.distinct("number", {product: "value_uniq_1"})
好的,这对于调试来说不是很冗长,我将在接下来的几行中使用db.runCommand。但是,现在,让我们避免对 stats 部分的不同和外观使用查询:
db.runCommand({distinct: 'random', key:'number'})
"stats" : {
"n" : 500000,
"nscanned" : 500000,
"nscannedObjects" : 500000,
"timems" : 479,
"cursor" : "BasicCursor"
},
没关系,因为我们还没有创建索引,让我们添加number字段:
db.random.createIndex({number: 1})
重新运行之前的查询:
db.runCommand({distinct: 'random', key:'number'})
"stats" : {
"n" : 10005,
"nscanned" : 10005,
"nscannedObjects" : 0,
"timems" : 83,
"cursor" : "DistinctCursor"
},
太好了,它使用索引,一切正常! 0 nscannedObjects!!!
好的,让我们为 distinct 添加查询:
db.runCommand({distinct: 'random', key:'number', query: {product: "value_uniq_1"}})
"stats" : {
"n" : 500000,
"nscanned" : 500000,
"nscannedObjects" : 500000,
"timems" : 694,
"cursor" : "BasicCursor"
},
这不是我们所期望的(“nscannedObjects”:500000),但是,没有产品索引,让我们创建一个:
db.random.createIndex({product: 1, number: -1})
方向没有区别,任意组合 product: 1, number -1 OR product -1, number 1, OR product: 1, number: 1 给出相同的行为。我检查了所有组合。
db.runCommand({distinct: 'random', key:'number', query: {product: "value_uniq_1"}})
"stats" : {
"n" : 500000,
"nscanned" : 500000,
"nscannedObjects" : 500000,
"timems" : 968,
"cursor" : "BtreeCursor product_1_number_-1"
},
WTF 正在进行吗? 为什么要使用索引扫描所有集合? 目前,整个集合仅包含一个产品价值,我无法猜测不同产品会是什么。为什么常见的不同查询这么慢? 1秒太慢了……
我不想为每个product 使用单独的集合,这太疯狂且效率低下,因为我需要在所有产品之间共享查询。我的真实数据库中每个产品包含超过 500 万个数字,并且此查询需要 3 秒以上。
【问题讨论】:
标签: mongodb distinct mongodb-query mongodb-indexes