2021-12-07 15:28:49 +08:00
|
|
|
"""
|
|
|
|
|
Mongo_tfse
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
import pymongo
|
|
|
|
|
|
2021-12-14 17:30:48 +08:00
|
|
|
client = pymongo.MongoClient('mongodb://{}:{}@{}:{}'.format('root', 'sromitdTW569kC#M', '116.63.130.34', 27018))
|
2021-12-07 15:28:49 +08:00
|
|
|
|
|
|
|
|
|
|
|
|
|
def find_threshold(param):
|
|
|
|
|
"""
|
|
|
|
|
根据行业查询阈值
|
|
|
|
|
Parameters:
|
|
|
|
|
param:
|
|
|
|
|
Returns:
|
|
|
|
|
threshold
|
|
|
|
|
"""
|
|
|
|
|
collection = client['模型']['财务指标阈值']
|
|
|
|
|
data = collection.find({"二级行业": param}, {'_id': False})
|
|
|
|
|
return list(data)
|
|
|
|
|
|
|
|
|
|
|
2021-12-10 15:52:38 +08:00
|
|
|
def conserve_data(**kwargs):
|
|
|
|
|
"""
|
|
|
|
|
保存数据
|
|
|
|
|
Parameters:
|
|
|
|
|
kwargs: 查询条件
|
|
|
|
|
Returns:
|
|
|
|
|
保存结果
|
|
|
|
|
"""
|
|
|
|
|
collection = client[kwargs['db']][kwargs['col']]
|
|
|
|
|
collection.update_one(kwargs['find'], {"$set": kwargs['insert_data']}, upsert=True)
|
|
|
|
|
return '保存成功'
|
