「自动化实战」从零开始Python对redis作为消息队列的使用

释放双眼,带上耳机,听听看~!

昨天的文章我们聊了python对于mongo的基础使用和场景、及优势。

今天幕客给大家讲讲python如何使用redis及我们用redis的作为消息队列,我们该怎么使用。
「自动化实战」从零开始Python对redis作为消息队列的使用

首先,我们来介绍下redis服务,及连接:

一、Redis 服务

1、安装

yum install redis

2、 python安装支持模块

/opt/python2.7.13/bin/pip install redis

3、 和redis的简单直接交互

In [1]: import redis

In [2]: rc = redis.Redis(host='192.168.8.237',port=6379,decode_responses=True)

In [5]: rc.set('imoocc','jeson')

Out[5]: True

In [7]: rc.get('imoocc')

Out[7]: u'jeson'

二、Redis简单操作

对于和Redis的交互, Redis的类中提供了连接池的方式,我们可以通过连接池管理并操作Redis。

1、连接池建立,利用连接池连接

In [8]: connpool = redis.ConnectionPool(host='192.168.8.237',port=6379,decode_responses=True)

In [9]: rc = redis.Redis(connection_pool=connpool)

In [10]: rc.set('imooccp','1234566')

Out[10]: True

In [11]: rc.get('imooccp')

Out[11]: u'1234566'

2、redis中DB ,指定数据存取的DB

redis.conf中设置了db的数量,那么redis的数据库名也为0 到15,如下:

databases 16

指定使用那个数据库名,我们通过如下的方式,就可以了:

In [29]: connpool = redis.ConnectionPool(host='192.168.8.237',port=6379,decode_responses=True,db=3)

In [30]: rc.set('test2','lllll')

Out[30]: True

这样就将数据库写入到db3了,如何验证呢?我们从服务端来认证最直接,如下:

用redis-cli(redis自带的工具)登录服务端,查看写入的key。

127.0.0.1:6379> SELECT 3

OK

127.0.0.1:6379[3]> KEYS * //查看db 3这个库下所有的key

1) “imooccc”

那么 接下来介绍redis详细项目使用的内容,大家不要觉得幕客介绍的内容扩散太大。

原因是不能一时之间完全的了解到,及时你能了解,那么幕客也没法一下把python对redis的操作通过一篇博客记录下来:

幕客最近在作一个任务系统,任务写入是不定时的,我们需要用一个程序去定期消费这些任务,必须是有先后顺序的,而且是

前一个任务确认执行完后,才会去执行下一个。

怎么办呢?用队列啊,对吧!用什么队列,怎么用?

幕客介绍下为什么要用redis来作消息处理:

简单说,redis支持两种消费模式,一种发布-订阅模式,及一个消息会被多个消费者处理(简单说类似是一个广播消息,所有人都会接收)。很明显我得系统中不需要这么用,幕客的系统里边就需要队列模式,及先到的任务优先处理。那么对队列用什么类型得数据库结构来作呢?

四、先得聊聊list

list 这个数据类型,在python里是一个列表,在redis里就是一个有序队列(或者说数据链表)了。

类型图示如下:

「自动化实战」从零开始Python对redis作为消息队列的使用
大家看了这个结构就可以清楚了,我们可以利用list的数据接口模式,设计从左端和右端都可以对list进元素的同向处理(满足队列的特性先到先出)。

1、从左端插入元素

In [10]: rc.lpush(‘tasklist’,1,2,3)

Out[10]: 3L

打印输出内容,如下:

In [17]: print(rc.lrange(‘tasklist’,0,2))

[u’3′, u’2′, u’1′]

类似的从左测插入的方法还有lpushx(name,value),区别只有当name存在才将value插入到最左边。

2、从右边插入元素

In [21]: rc.rpush(‘tasklist’,’5′)

Out[21]: 5L

In [22]: print(rc.lrange(‘tasklist’,0,4))

[u’4′, u’3′, u’2′, u’1′, u’5′]

3、从左边取出元素怎么取呢?

In [23]: rc.lpop(“tasklist”)

Out[23]: u’4′

In [24]: rc.lpop(“tasklist”)

Out[24]: u’3′

In [25]: print(rc.lrange(‘tasklist’,0,4))

[u’2′, u’1′, u’5′]

我们会看到从左侧已经取出了两个元素了。剩下来[u’2′, u’1′, u’5′]

4、从右侧呢?

当然就是rc.rpop()了

python对于redis的基础使用和Redis作为队列的简单使用就介绍这些,

python的工程里边如何更好封装redis库的连接和方法,

及python很多的知识内容,大家可以关注我,我将提供更多的内容!

「自动化实战」从零开始Python对redis作为消息队列的使用
课程介绍:https://coding.imooc.com/class/160.html
课程问答区:https://coding.imooc.com/learn/qa/160.html

【转自慕课】https://www.imooc.com

Python

python基础,很详尽!!!(4)

2022-3-3 12:55:29

Python

将函数作为参数, map函数(接收1个参数),reduce函数(接收2个参数),filter

2022-3-3 12:55:41

搜索