欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Python操作redis和mongoDB

程序员文章站 2024-02-02 19:14:28
一、操作redis redis是一个key-value存储系统,value的类型包括string(字符串),list(链表),set(集合),zset(有序集合),hash(哈希类型)。为了保证效率,数据都是缓冲在内存中,在处理大规模数据读写的场景下运用比较多。 备注:默认redis有16个数据库, ......

一、操作redis

redis是一个key-value存储系统,value的类型包括string(字符串),list(链表),set(集合),zset(有序集合),hash(哈希类型)。为了保证效率,数据都是缓冲在内存中,在处理大规模数据读写的场景下运用比较多。

备注:默认redis有16个数据库,即db0~db15, 一般存取数据如果不指定库的话,默认都是存在db0中。 

resid提供2种连接方式:直接连接、连接池连接

1、直接连接示例:

import redis                          # pip3 install redis

# 创建redis连接对象
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)    # 指定数据库

    
# 插入值,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))

连接池的原理是, 通过预先创建多个连接, 当进行redis操作时, 直接获取已经创建的连接进行操作, 而且操作完成后, 不会释放, 用于后续的其他redis操作,这样就达到了避免频繁的redis连接创建和释放的目的, 从而提高性能。

redis模块采用connectionpool来管理对redis server的所有连接。

2、连接池连接示例:

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')

二、操作mongodb

1、mongodb 是一个非关系型数据库(nosql),介于关系数据库和非关系数据库之间的产品。拥有很多优秀特性,例如高性能、高可用、支持丰富的查询语句、无需预定义数据模型和水平可伸缩等。

2、mongodb是非关系数据库当中功能最丰富,最像关系数据库的。它支持的数据结构非常松散,是类似json的bson格式,因此可以存储比较复杂的数据类型。

3、mongodb最大的特点是它支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且还支持对数据建立索引。

4、mongodb 的适用场景为:数据不是特别重要(例如通知,推送)、数据表结构变化较为频繁、数据量特别大、数据的并发性特别高、数据结构比较特别(例如地图的位置坐标),

这些情况下用 mongodb , 其他情况就还是用mysql ,这样组合使用就可以达到最大的效率。
import pymongo                        # pip3 install pymongo

# 创建mongo连接对象
def init_mongo():
    
    global mongo_conn
    mongo_conn = pymongo.mongoclient(host="172.29.0.14", port=27017)
    admin = mongo_conn.admin
    admin.authenticate('root', '')


# 数据操作    
def get_mongo_key_value(token_id):
    db = mongo_conn['device_center']                          # 创建数据库"device_center",命名为"db"
    col = db['token_info']                                    # 创建集合"token_info",命名为"col"

    mydict = {"name": "zhuyu", "alexa": "160", "sex": "male"}
    col.insert_one(mydict)                                    # 插入一条数据
    
    mylist = [
    {"name": "ating", "alexa": "168", "sex": "male"},
    {"name": "liang", "alexa": "165", "sex": "female"},
    {"name": "libai", "alexa": "156", "sex": "female"}
    ]
    col.insert_one(mylist)                                        # 插入一组数据
    
    query1 = col.find_one()                                # 查询一条数据
    
    query2 = col.find({},{"alexa": 1})                     # 查询指定字段的数据
    
    query3 = col.find()                                    # 查询集合中的所有数据
    
    query4 = col.find({"name": "ating"})                   # 根据指定条件查询
    
    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 开头的 name 字段,并将匹配到所有记录的 alexa 字段修改为 123
    
    query5 = col.find().sort("alexa")                      # sort() 方法第一个参数为要排序的字段,第二个字段指定排序规则,1 为升序,-1 为降序,默认为升序
    for x in query5 :
        print(x)
    # 结果
    {"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)
    # 结果
    {"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" }                         # 删除一条数据
    mycol.delete_one(myquery3)
    
    myquery4 = { "name": {"$regex": "^l"} }                # 删除多个数据
    x1 = mycol.delete_many(myquery4)
    print(x1.deleted_count, "个文档已删除")                # 2个文档已删除
    
    x2 = mycol.delete_many({})                             # 删除集合中的所有数据
    print(x2.deleted_count, "个文档已删除")                # 4个文档已删除
    
        
# 断开mongo连接    
def disconnect_mongo():
    mongo_conn.disconnect()