Fork me on GitHub

No.2 Python与数据库--Redis

字数统计: 1.8k字   |   阅读时长≈ 7分

Redis是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库。它是一种非关系型数据库，经常用过缓存，拥有丰富的数据类型：字符串、哈希、列表、集合和有序集合。

2.1. Redis的安装与连接测试

  • 直接安装：sudo apt-get install redis-server，该安装只是Linux的稳定版本，如果想安装Redis官方稳定版本需要采用源码安装
  • 源码安装：
    • 官网redis.io下载稳定的最新版本，比如redis-5.0.7.tar.gz
    • 安装tcl：sudo apt-get install tcl
    • 解压下载的安装包，将解压后的文件放至指定的安装目录，sudo mv redis-5.0.7 /usr/local/redis cd /usr/local/redis
    • 编译安装：sudo make——>sudo make test——>sudo make install
    • 测试：/usr/local/redis/src/redis-server——>/usr/local/redis/src/redis-cli——>set name lajos——>get name
    • 创建相关目录：sudo makdir /etc/redis(配置文件路径)——>sudo mkdir /var/lib/redis(redis数据库存储路径)
    • 安装服务：cd /usr/local/redis/utils——>sudo ./install_server.sh
    • 重启服务：ps ajx | grep redis——>sudo kill -9 对应的进程号
    • 测试：redis-server——>redis-cli
    • 配置文件：cd /etc/redis——>sudo vim /etc/redis/6379.conf——>可以修改bind、daemonize、requirepass——>然后重启服务
    • 直接开启客户机：redis-cli
  • 连接测试
    • 检查服务是否启动：ps aux(ajx, -ef) | grep redis
    • 连接：redis-cli -h 主机 -p 端口 -a 密码
    • 退出：quit
  • 密码管理：默认没有密码，若设置密码，需要通过auth认证
    • 单次有效：
      • 获取密码：config get requirepass
      • 设置密码：config set requirepass 123456
      • 密码认证：auth 123456
    • 永久有效：修改配置文件/etc/redis/redis.conf
      • 将requirepass xxxxx行修改设置的密码
      • 重新启动redis服务

2.2. Redis命令

  • 常用
1
2
3
4
5
6
7
8
9
10
11
12
ping：测试连接情况，回复PONG表示OK
quit：退出连接
auth：密码认证
select：选择库，总共有16个，序号0~15，默认是第0个
info：查看服务器信息
command：查看支持的命令
flushdb：清空当前库
flushall：清空所有库
save：前台进行持久化存储
bgsave：后台进行持久化存储
exists：判断指定键是否存在
del：删除键
  • 字符串(string)
1
2
3
4
5
6
7
8
9
10
set：设置
get：获取
getset：获取之后再设置
mset：设置多个
mget：获取多个
incr：加1
decr：减1
incrby：加指定的值
decrby：减指定的值
append：追加内容
  • 哈希(hash)
1
2
3
4
5
6
7
8
9
10
hset：设置单个属性
hget：获取单个属性
hmset：设置多个属性
hmget：获取多个属性
hgetall：获取所有属性
hdel：删除键值对
hexists：判断指定键的指定字段是否存在
hkeys：获取指定键的所有属性名
hvals：获取指定键的所有属性值
hlen：获取指定键的属性个数
  • 列表(list)
1
2
3
4
5
6
7
8
lpush：从左边(头部)插入数据
lpop：从左边(头部)删除数据
lrange：获取指定区间范围内的数据，0 -1表示所有
lindex：根据索引获取元素
llen：获取列表长度(元素个数)
rpush：从右边(尾部)插入数据
rpop：从右边(尾部)删除数据
lrem：移除指定个数的指定元素
  • 集合(set)
1
2
3
4
5
6
7
8
9
10
11
sadd：添加元素
scard：统计元素个数
sdiff：求差集
sinter：求交集
smembers：获取指定集合的所有成员
sismember：判断是否在集合中
smove：移动元素
spop：随机的删除一个元素
srandmember：随机获取指定个数的元素
srem：移除元素
sunion：求并集
  • 有序集合(sorted set)
1
2
3
4
5
6
7
8
zadd：添加元素
zcard：统计个数
zcount：指定分数区间内的元素数量
zrange：返回指定索引范围内的元素
zrangebyscore：返回指定分数区间的元素
zrank：返回指定成员的索引值
zrem：移除元素
zscore：获取指定元素的排序指标(分数)

2.3. Python操作Redis

redis扩展库中有两个类，Redis和StrictRedis，StrictRedis实现了官方的命令，Redis是它的子类，兼容老版本。扩展库没有实现select方法，可以通过连接时指定使用的库。

  • 安装扩展：pip install redis

2.3.1. 简单连接

  • redis.Redis(host='localhost', port=6379, db=0, password=None, socket_timeout=None, socket_connect_timeout=None,socket_keepalive=None, socket_keepalive_options=None, connection_pool=None, unix_socket_path=None,encoding='utf-8', encoding_errors='strict', charset=None, errors=None, decode_responses=False, retry_on_timeout=False, ssl=False, ssl_keyfile=None, ssl_certfile=None, ssl_cert_reqs='required', ssl_ca_certs=None, max_connections=None, single_connection_client=False, health_check_interval=0)：db表示选定的数据库，decode_response表示解码返回
1
2
3
4
5
import redis
# 创建连接对象，所有的命令在代码中都是Redis对象的方法
r = redis.Redis(host='localhost', port=6379, db=0, password=None, decode_response=True)
r.set('name', 'lajos')
print(r.get('name))

2.3.2. 连接池

多个redis对象使用同一个连接池进行连接，避免了多次连接、断开等操作的系统开销。默认，每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池，然后作为参数Redis，这样就可以实现多个Redis实例共享一个连接池。

1
2
3
4
5
6
7
8
9
import redis

# 创建连接池
pool = redis.ConnectionPool(host='localhost', port=6379, db=0, decode_responses=True)

# 创建Redis对象
r = redis.Redis(connection_pool=pool)
r.set('name', 'lajos')
print(r.get('name'))

2.3.3. 详细操作命令

redis详细操作命令

2.3.4. 管道(pipeline)

  • 可以记录多个操作，然后一次将操作发送至数据库，避免了多次连接、断开等操作的系统开效

  • 多个操作可以依次进行保存，然后发送，也可以进行连贯操作

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
import redis

# 创建连接池
pool = redis.ConnectionPool(host='localhost', port=6379, db=0, decode_responses=True)
# 创建Redis对象
r = redis.Redis(connection_pool=pool)
# 创建管道, 默认支持事务(transaction=True)
pipe = r.pipeline()
# 记录命令
pipe.set('name', 'lajos')
pipe.set('age', 20)
pipe.set('message', 'lajos is a handsome man')
dic = {'a': 'aaa', 'b': 'bbb'}
pipe.hmset('myhash', dic)
# 执行操作
pipe.execute()
print(r.get('message'))
print(r.hget('myhash', 'b'))

2.3.5. 发布和订阅

Redis发布订阅(pub/sub)是一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import redis

class RedisHelper(object):

    def __init__(self, channel=None):
        self.__connection = redis.Redis(host='127.0.0.1', port=6379, decode_responses=True)
        self.channel = 'lajos'
    # 定义发布方法
    def publish(self, msg):
        self.__connection.publish(self.channel, msg)
        return True
    # 定义订阅方法
    def subscribe(self):
        pub = self.__connection.pubsub()
        pub.subscribe(self.channel)
        pub.parse_response()
        return pub
  • 发送者
1
2
3
4
5
6
7
8
9
10
from pythonRedis import RedisHelper

pub = RedisHelper()
while True:
    msg = input('发布者：')
    pub.publish(msg)
# 运行结果
>>> 发布者：hello
发布者：world
发布者：
  • 订阅者
1
2
3
4
5
6
7
8
9
10
11
from pythonRedis import RedisHelper

sub = RedisHelper()
redis_sub = sub.subscribe()

while True:
    msg = redis_sub.parse_response()
    print(msg)
# 运行结果
>>> ['message', 'lajos', 'hello']
['message', 'lajos', 'world']

2.4 常见问题

  • 在使用源码安装redis时，当在/usr/local/redis/utils下执行sudo ./install_server.sh时出现：

    1
    2
    3
    4
    5
    Welcome to the redis service installer
    This script will help you easily set up a running redis server

    This systems seems to use systemd.
    Please take a look at the provided example service unit files in this directory, and adapt and install them. Sorry!

    此时，需要去修改/usr/local/redis/utils/install_server.sh这个文件，将下面的内容注释掉，然后重新执行sudo ./install_server.sh就可以正常安装。

    1
    2
    3
    4
    5
    6
    7
    8
    #bail if this system is managed by systemd
    #_pid_1_exe="$(readlink -f /proc/1/exe)"
    #if [ "${_pid_1_exe##*/}" = systemd ]
    #then
    #       echo "This systems seems to use systemd."
    #       echo "Please take a look at the provided example service unit files in this directory, and adapt and install them. Sorry!"
    #       exit 1
    #fi
赏

谢谢你请我吃糖果

支付宝
微信

扫一扫，分享到微信

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia-plus根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

主要涉及技术：
Python web开发、爬虫研究
Linux、Django、Script

很惭愧

只做了一点微小的工作
谢谢大家