Python操作redis和mongoDB的方法

import redis             # pip3 install redis
# 創(chuàng)建redis連接對(duì)象
def init_redis():
  redis_config = {
    "host": "172.29.0.17",
    "port": 6379
  }
  global Redis_Conn
  Redis_Conn = redis.Redis(**redis_config)
  # Redis_Conn = redis.Redis(host='172.29.0.17', port=6379, db=1)  # 指定數(shù)據(jù)庫(kù)
  
# 插入值，Value為str類型為例
def insert_redis_key_value(key,value):  
  Redis_Conn.set("name","Zhu")
# 獲取值，Value為str類型為例
def get_redis_key_value(key):
  global Redis_Conn
  print("redis key value: %s" % Redis_Conn.get(key))

import redis
pool = redis.ConnectionPool(host='172.29.0.17', port=6379,db=1) 
red = redis.Redis(connection_pool=pool) 
red.set('key1', 'value1') 
red.set('key2', 'value2')

import pymongo            # pip3 install pymongo
# 創(chuàng)建mongo連接對(duì)象
def init_mongo():
  global Mongo_Conn
  Mongo_Conn = pymongo.MongoClient(host="172.29.0.14", port=27017)
  admin = Mongo_Conn.admin
  admin.authenticate('root', '')
# 數(shù)據(jù)操作  
def get_mongo_key_value(token_id):
  db = Mongo_Conn['device_center']             # 創(chuàng)建數(shù)據(jù)庫(kù)"device_center"，命名為"db"
  col = db['token_info']                  # 創(chuàng)建集合"token_info"，命名為"col"
  mydict = {"name": "Zhuyu", "alexa": "160", "sex": "male"}
  col.insert_one(mydict)                  # 插入一條數(shù)據(jù)
  mylist = [
  {"name": "ating", "alexa": "168", "sex": "male"},
  {"name": "Liang", "alexa": "165", "sex": "female"},
  {"name": "Libai", "alexa": "156", "sex": "female"}
  ]
  col.insert_one(mylist)                    # 插入一組數(shù)據(jù)
  query1 = col.find_one()                # 查詢一條數(shù)據(jù)
  query2 = col.find({},{"alexa": 1})           # 查詢指定字段的數(shù)據(jù)
  query3 = col.find()                  # 查詢集合中的所有數(shù)據(jù)
  query4 = col.find({"name": "ating"})          # 根據(jù)指定條件查詢
  myquery1 = { "alexa": "160" }
  newvalues1 = { "$set": { "alexa": "161" } }
  col.update_one(myquery1, newvalues1)           # 修改匹配到的第一條記錄
  myquery2 = { "name": { "$regex": "^L" } }
  newvalues2 = { "$set": { "alexa": "123" } }
  col.update_many(myquery2, newvalues2)          # 修改所有匹配到的記錄，將查找所有以 L 開(kāi)頭的 name 字段，并將匹配到所有記錄的 alexa 字段修改為 123
  query5 = col.find().sort("alexa")           # sort() 方法第一個(gè)參數(shù)為要排序的字段，第二個(gè)字段指定排序規(guī)則，1 為升序，-1 為降序，默認(rèn)為升序
  for x in query5 :
    print(x)
  # 結(jié)果
  {"name": "Libai", "alexa": "156", "sex": "female"}
  {"name": "Zhuyu", "alexa": "160", "sex": "male"}
  {"name": "Liang", "alexa": "165", "sex": "female"}
  {"name": "ating", "alexa": "168", "sex": "male"}
  query6 = col.find().sort("alexa",-1)          # 降序
  for x in query6:
    print(x)
  # 結(jié)果
  {"name": "ating", "alexa": "168", "sex": "male"}
  {"name": "Liang", "alexa": "165", "sex": "female"}
  {"name": "Zhuyu", "alexa": "160", "sex": "male"}
  {"name": "Libai", "alexa": "156", "sex": "female"}
  myquery3 = { "name": "Libai" }             # 刪除一條數(shù)據(jù)
  mycol.delete_one(myquery3)
  myquery4 = { "name": {"$regex": "^L"} }        # 刪除多個(gè)數(shù)據(jù)
  x1 = mycol.delete_many(myquery4)
  print(x1.deleted_count, "個(gè)文檔已刪除")        # 2個(gè)文檔已刪除
  x2 = mycol.delete_many({})               # 刪除集合中的所有數(shù)據(jù)
  print(x2.deleted_count, "個(gè)文檔已刪除")        # 4個(gè)文檔已刪除
# 斷開(kāi)mongo連接  
def disconnect_mongo():
  Mongo_Conn.disconnect()