添加mongo类

utils/mongo_opera.py

+#!/usr/bin/env python
+# -*- coding:utf-8 -*-
+import pymongo
+
+from config import get_mongo_conf
+from urllib.parse import quote_plus
+
+
+class MongoOperator:
+
+    def __init__(self):
+        config = get_mongo_conf()
+        uri = 'mongodb://%s:%s@%s/%s' % (
+            quote_plus(config['user']), quote_plus(config['password']), config['host'], config['database'])
+        self.conn = pymongo.MongoClient(uri)
+        self.db = self.conn[config['database']]
+        self.collection = self.db["spu"]
+
+
+    def find_goods_data(self,data):
+
+        return self.collection.aggregate([{'$match': {"$or":data}}, {"$group": {"_id": "$spu_name", "num_tutorial": {"$sum": 1}}}])