1

在此处使用此答案https://stackoverflow.com/a/43570730/7626649

我想用烧瓶-pymongo 来做这件事。

具体来说，我想在 flask-pymongo 和/或 pymongo 中执行以下查询（看起来如果它可以在一个中完成，那么它可以在另一个中完成..我希望）：

db.things.aggregate([
  {"$project":{"arrayofkeyvalue":{"$objectToArray":"$$ROOT"}}},
  {"$unwind":"$arrayofkeyvalue"},
  {"$group":{"_id":null,"allkeys":{"$addToSet":"$arrayofkeyvalue.k"}}}
])

这是我到目前为止所做的：

@app.route('/reports/<site>/<system>/<data_type>', methods=['GET'])
def get_keys_for_collection(site, system, data_type):
    pipeline = [
        {"$project":{"arrayofkeyvalue":{"$objectToArray":"$$ROOT"}}},   
        {"$unwind":"$arrayofkeyvalue"},
        {"$group":{"_id": None,"allkeys":{"$addToSet":"$arrayofkeyvalue.k"}}}   
    ]
    db, options = get_db_handle(site)
    collection = "%s_%s" % (system, data_type)
    pp.pprint(db.command('aggregate', collection, pipeline=pipeline, explain=True))
    return jsonify({'results': list(db.collection.aggregate(pipeline))})

我已经验证“db”是一个活动的 Flask-Pymongo 连接到包含被查询集合的数据库。这是 db.command() 的输出，explain=True：

{   'ok': 1.0,
'stages': [   {   '$cursor': {   'query': {},
                                 'queryPlanner': {   'indexFilterSet': False,
                                                     'namespace': 'MYDB.collection',
                                                     'parsedQuery': {},
                                                     'plannerVersion': 1,
                                                     'rejectedPlans': [],
                                                     'winningPlan': {   'direction': 'forward',
                                                                        'stage': 'COLLSCAN'}}}},
              {   '$project': {   '_id': True,
                                  'arrayofkeyvalue': {   '$objectToArray': [   '$$ROOT']}}},
              {'$unwind': {'path': '$arrayofkeyvalue'}},
              {   '$group': {   '_id': {'$const': None},
                                'allkeys': {   '$addToSet': '$arrayofkeyvalue.k'}}}]}

我省略了实际的数据库和集合名称，并将它们替换为上面的 MYDB.collection。db.command() 证明 db.connection 是一个有效的连接，问题不在于查询那部分的语法。

结果我得到一个空列表，没有错误。该 URL 已修改为不显示某些信息。查看 db.command() 结果以证明 db 连接和集合存在并且正在正确连接。

curl http://0.0.0.0:5000/reports/site/system/data_type
{
   "results": []
}

我正在使用什么：

Python 3.6.5
MongoDB shell version v3.6.5
PyMongo v3.4.0
Flask-Pymongo v0.5.2
4

1 回答 1

0

聚合命令存在语法问题：

db.collection.aggregate(pipeline)

应该

db[collection].aggregate(pipeline)
于 2018-07-11T17:32:09.373 回答