组团学

Python对Redis操作

阅读 (216161)

一、连接Redis数据库

作用:redis模块用于调用操作redis,而redis是一个基于内存的高性能key-value的存储系统,支持存储的类型有string、list、set、zset和hash。在处理大规模数据读写或高效的缓存的场景下运用比较多

安装:pip install redis

说明:redis模块中允许两种连接方式直接连接和连接池连接

直接连接

  • 使用默认方式连接到数据库

    import redis try: r = redis.StrictRedis(host="8.8.8.8", port=6379, password="zutuanxue_com", db=0) except: print("连接Redis失败")
  • 使用url方式连接到数据库

    格式 说明
    redis://[:password]@host:port/db TCP连接
    rediss://[:password]@host:port/db Redis TCP+SSL 连接
    unix://[:password]@/path/to/socket.sock?db=db Redis Unix Socket 连接
    import redis try: r = redis.StrictRedis.from_url('redis://:zutuanxue_com@8.8.8.8:6379/0') except: print("连接Redis失败")

连接池连接

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

  • 使用默认方式连接到数据库

    import redis pool = redis.ConnectionPool(host='8.8.8.8', port=6379, password="zutuanxue_com", db=0) try: r = redis.StrictRedis(connection_pool=pool) except: print("连接Redis失败")
  • 使用url方式连接到数据库

    格式 说明
    redis://[:password]@host:port/db TCP连接
    rediss://[:password]@host:port/db Redis TCP+SSL 连接
    unix://[:password]@/path/to/socket.sock?db=db Redis Unix Socket 连接
    import redis pool = redis.ConnectionPool.from_url('redis://:zutuanxue_com@8.8.8.8:6379/0') try: r = redis.StrictRedis(connection_pool=pool) except: print("连接Redis失败")

二、数据操作

根据数据类型的不同,调用相应的方法,完成读写

import redis pool = redis.ConnectionPool.from_url('redis://:zutuanxue_com@8.8.8.8:6379/0') try: r = redis.StrictRedis(connection_pool=pool) except: print("连接Redis失败") r.set("zutuanxue_com", "good") print(r.get("zutuanxue_com"))

问题:一条数据操作一次数据库,访问频繁效率低

pipline方式访问数据库

优点:缓冲多条命令,然后依次执行,减少服务器-客户端之间的TCP数据包,从而提高效率

import redis pool = redis.ConnectionPool.from_url('redis://:zutuanxue_com@8.8.8.8:6379/0') try: r = redis.StrictRedis(connection_pool=pool) except: print("连接Redis失败") pipe = r.pipeline() pipe.set("aa", "111") pipe.set("bb", "222") pipe.set("cc", "333") pipe.set("dd", "444") pipe.execute()
需要 登录 才可以提问哦