我正在将 asyncmongo 与 Tornado + gen.engine 一起使用,只是想知道等效于的语法是什么db.collection.distinct("mykey")
?
我认为它类似于
result, error = yield gen.Task(settings.DB.my_data.find, {}, distinct=[("key","mykey")])
但这行不通。无论出于何种原因,我都无法在网上找到任何此类示例。
谢谢。
问题是,“distinct”不是查询的选项,它是一个单独的命令:
http://www.mongodb.org/display/DOCS/Aggregation#Aggregation-Distinct
所以使用 AsyncMongo 的 command() 方法:
>>> from tornado.ioloop import IOLoop
>>> import asyncmongo
>>> db = asyncmongo.Client(pool_id='mydb', host='127.0.0.1', port=27017, maxcached=10, maxconnections=50, dbname='test')
>>> def callback(result, error):
... print result
... IOLoop.instance().stop()
...
>>> db.command('distinct', 'my_data', key='my_key', callback=callback)
>>> IOLoop.instance().start()
{u'stats': {u'cursor': u'BasicCursor', u'timems': 0, u'nscannedObjects': 5, u'nscanned': 5, u'n': 5}, u'values': [1.0, 2.0], u'ok': 1.0}
您需要的数据在 result['values'] 中。
更多使用 AsyncMongo 命令的示例在其测试套件中:
https://github.com/bitly/asyncmongo/blob/master/test/test_command.py
以及有关 MongoDB 命令的一般信息(示例使用 PHP,但即使对于像我们这样的 Python 编码人员也很容易理解):
http://www.kchodorow.com/blog/2011/01/25/why-command-helpers-suck/
原来我将切换到 Motor,它支持 distinct() 作为查询,加上http://emptysquare.net/motor/pymongo/api/motor/generator_interface.html#generator-interface非常方便等待在触发回调之前完成多个查询。