Upload check_mogo.py
Browse files- check_mogo.py +15 -0
check_mogo.py
ADDED
|
@@ -0,0 +1,15 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
+
import pymongo
|
| 2 |
+
|
| 3 |
+
def get_mongo_col(col="config_beta"):
|
| 4 |
+
"""
|
| 5 |
+
获取操作mongo集合
|
| 6 |
+
"""
|
| 7 |
+
mongo_3012 = "mongodb://dashboard:9qRV71M%25Trx1CI@m3012.hw.mongos.m.com:3012/dashboard?authSource=dashboard"
|
| 8 |
+
client = pymongo.MongoClient(mongo_3012, maxPoolSize=500)
|
| 9 |
+
db = client["dashboard"]
|
| 10 |
+
col = db[col] # data_package(7234543961263854561) goods_feature("7234800834201014260")
|
| 11 |
+
return col
|
| 12 |
+
|
| 13 |
+
# 拿到 collection 对象
|
| 14 |
+
collection = get_mongo_col()
|
| 15 |
+
print(collection)
|