Upload mongo.py

mongo.py

@@ -0,0 +1,20 @@
+import pymongo
+
+def get_mongo_col(col="config_beta"):
+    """
+    获取操作mongo集合
+    """
+    mongo_3012 = "mongodb://dashboard:9qRV71M%25Trx1CI@m3012.hw.mongos.m.com:3012/dashboard?authSource=dashboard"
+    client = pymongo.MongoClient(mongo_3012, maxPoolSize=500)
+    db = client["dashboard"]
+    col = db[col]  # data_package(7234543961263854561)  goods_feature("7234800834201014260")
+    return col
+
+# 拿到 collection 对象
+col = get_mongo_col()  # 默认 col="config_beta"
+
+db = col.database  # 或者直接用 client["dashboard"]
+
+# 列出所有集合名
+collections = db.list_collection_names()
+print("当前 database 下的集合：", collections)