Python操作 RabbitMQ、Redis、Memcache、SQLAlchemy
<div id="cnblogs_post_body" class="blogpost-body"> MemcachedMemcached 是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻数据库负载。它通过在内存中缓存数据和对象来减少读取数据库的次数,从而提高动态、数据库驱动网站的速度。Memcached基于一个存储键/值对的。其(daemon )是用写的,但是客户端可以用任何语言来编写,并通过memcached协议与守护进程通信。 Memcached安装和基本使用 Memcached安装: |
启动Memcached
Memcached命令
Python操作Memcached
安装API
1、第一次操作
2、天生支持集群
python-memcached模块原生支持集群操作,其原理是在内存维护一个主机列表,且集群中主机的权重值和主机在列表中重复出现的次数成正比
如果用户根据如果要在内存中创建一个键值对(如:k1 = "v1"),那么要执行一下步骤:
- 根据算法将 k1 转换成一个数字
- 将数字和主机列表长度求余数,得到一个值 N( 0 <= N < 列表长度 )
- 在主机列表中根据 第2步得到的值为索引获取主机,例如:host_list[N]
- 连接 将第3步中获取的主机,将 k1 = "v1" 放置在该服务器的内存中
代码实现如下:
3、add
添加一条键值对,如果已经存在的 key,重复执行add操作异常
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="python comments">#!/usr/bin/env python
<div class="line number2 index1 alt1"><code class="python comments"># -- coding:utf-8 --
<div class="line number3 index2 alt2"><code class="python keyword">import
<code class="python plain">memcache
<div class="line number4 index3 alt1">
<div class="line number5 index4 alt2"><code class="python plain">mc
<code class="python keyword">=
<code class="python plain">memcache.Client([
<code class="python string">'10.211.55.4:12000'
<code class="python plain">],debug
<code class="python keyword">=
<code class="python color1">True
<code class="python plain">)
<div class="line number6 index5 alt1"><code class="python plain">mc.add(
<code class="python string">'k1'
<code class="python plain">,
<code class="python string">'v1'
<code class="python plain">)
<div class="line number7 index6 alt2"><code class="python comments"># mc.add('k1','v2') # 报错,对已经存在的key重复添加,失败!!!
</td>
</tr>
</table>
4、replace
replace 修改某个key的值,如果key不存在,则异常
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="python comments">#!/usr/bin/env python
<div class="line number2 index1 alt1"><code class="python comments"># -- coding:utf-8 --
<div class="line number3 index2 alt2"><code class="python keyword">import
<code class="python plain">memcache
<div class="line number4 index3 alt1">
<div class="line number5 index4 alt2"><code class="python plain">mc
<code class="python keyword">=
<code class="python plain">memcache.Client([
<code class="python string">'10.211.55.4:12000'
<code class="python plain">],debug
<code class="python keyword">=
<code class="python color1">True
<code class="python plain">)
<div class="line number6 index5 alt1"><code class="python comments"># 如果memcache中存在kkkk,则替换成功,否则一场
<div class="line number7 index6 alt2"><code class="python plain">mc.replace(
<code class="python string">'kkkk'
<code class="python plain">,
<code class="python string">'999'
<code class="python plain">)
</td>
</tr>
</table>
5、set 和 set_multi
set 设置一个键值对,如果key不存在,则创建,如果key存在,则修改
set_multi 设置多个键值对,如果key不存在,则创建,如果key存在,则修改
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="python comments">#!/usr/bin/env python
<div class="line number2 index1 alt1"><code class="python comments"># -- coding:utf-8 --
<div class="line number3 index2 alt2"><code class="python keyword">import
<code class="python plain">memcache
<div class="line number4 index3 alt1">
<div class="line number5 index4 alt2"><code class="python plain">mc
<code class="python keyword">=
<code class="python plain">memcache.Client([
<code class="python string">'10.211.55.4:12000'
<code class="python plain">],debug
<code class="python keyword">=
<code class="python color1">True
<code class="python plain">)
<div class="line number6 index5 alt1">
<div class="line number7 index6 alt2"><code class="python plain">mc.
<code class="python functions">set
<code class="python plain">(
<code class="python string">'key0'
<code class="python plain">,
<code class="python string">'wupeiqi'
<code class="python plain">)
<div class="line number8 index7 alt1">
<div class="line number9 index8 alt2"><code class="python plain">mc.set_multi({
<code class="python string">'key1'
<code class="python plain">:
<code class="python string">'val1'
<code class="python plain">,
<code class="python string">'key2'
<code class="python plain">:
<code class="python string">'val2'
<code class="python plain">})
</td>
</tr>
</table>
6、delete 和 delete_multi
delete 在Memcached中删除指定的一个键值对
delete_multi 在Memcached中删除指定的多个键值对
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="python comments">#!/usr/bin/env python
<div class="line number2 index1 alt1"><code class="python comments"># -- coding:utf-8 --
<div class="line number3 index2 alt2"><code class="python keyword">import
<code class="python plain">memcache
<div class="line number4 index3 alt1">
<div class="line number5 index4 alt2"><code class="python plain">mc
<code class="python keyword">=
<code class="python plain">memcache.Client([
<code class="python string">'10.211.55.4:12000'
<code class="python plain">],debug
<code class="python keyword">=
<code class="python color1">True
<code class="python plain">)
<div class="line number6 index5 alt1">
<div class="line number7 index6 alt2"><code class="python plain">mc.delete(
<code class="python string">'key0'
<code class="python plain">)
<div class="line number8 index7 alt1"><code class="python plain">mc.delete_multi([
<code class="python string">'key1'
<code class="python plain">,
<code class="python string">'key2'
<code class="python plain">])
</td>
</tr>
</table>
7、get 和 get_multi
get 获取一个键值对
get_multi 获取多一个键值对
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="python comments">#!/usr/bin/env python
<div class="line number2 index1 alt1"><code class="python comments"># -- coding:utf-8 --
<div class="line number3 index2 alt2"><code class="python keyword">import
<code class="python plain">memcache
<div class="line number4 index3 alt1">
<div class="line number5 index4 alt2"><code class="python plain">mc
<code class="python keyword">=
<code class="python plain">memcache.Client([
<code class="python string">'10.211.55.4:12000'
<code class="python plain">],debug
<code class="python keyword">=
<code class="python color1">True
<code class="python plain">)
<div class="line number6 index5 alt1">
<div class="line number7 index6 alt2"><code class="python plain">val
<code class="python keyword">=
<code class="python plain">mc.get(
<code class="python string">'key0'
<code class="python plain">)
<div class="line number8 index7 alt1"><code class="python plain">item_dict
<code class="python keyword">=
<code class="python plain">mc.get_multi([
<code class="python string">"key1"
<code class="python plain">,
<code class="python string">"key2"
<code class="python plain">,
<code class="python string">"key3"
<code class="python plain">])
</td>
</tr>
</table>
8、append 和 prepend
append 修改指定key的值,在该值 后面 追加内容
prepend 修改指定key的值,在该值 前面 插入内容
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="python comments">#!/usr/bin/env python
<div class="line number2 index1 alt1"><code class="python comments"># -- coding:utf-8 --
<div class="line number3 index2 alt2"><code class="python keyword">import
<code class="python plain">memcache
<div class="line number4 index3 alt1">
<div class="line number5 index4 alt2"><code class="python plain">mc
<code class="python keyword">=
<code class="python plain">memcache.Client([
<code class="python string">'10.211.55.4:12000'
<code class="python plain">],debug
<code class="python keyword">=
<code class="python color1">True
<code class="python plain">)
<div class="line number6 index5 alt1"><code class="python comments"># k1 = "v1"
<div class="line number7 index6 alt2">
<div class="line number8 index7 alt1"><code class="python plain">mc.append(
<code class="python string">'k1'
<code class="python plain">,
<code class="python string">'after'<code class="python plain">)<div class="line number9 index8 alt2"><code class="python comments"># k1 = "v1after"
<div class="line number10 index9 alt1">
<div class="line number11 index10 alt2"><code class="python plain">mc.prepend(<code class="python string">'k1'<code class="python plain">,<code class="python string">'before'<code class="python plain">)
<div class="line number12 index11 alt1"><code class="python comments"># k1 = "beforev1after"
</td>
</tr>
</table>
9、decr 和 incr
incr 自增,将Memcached中的某一个值增加 N ( N默认为1 )
decr 自减,将Memcached中的某一个值减少 N ( N默认为1 )
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="python comments">#!/usr/bin/env python
<div class="line number2 index1 alt1"><code class="python comments"># -- coding:utf-8 --
<div class="line number3 index2 alt2"><code class="python keyword">import <code class="python plain">memcache
<div class="line number4 index3 alt1">
<div class="line number5 index4 alt2"><code class="python plain">mc <code class="python keyword">= <code class="python plain">memcache.Client([<code class="python string">'10.211.55.4:12000'<code class="python plain">],debug<code class="python keyword">=<code class="python color1">True<code class="python plain">)
<div class="line number6 index5 alt1"><code class="python plain">mc.<code class="python functions">set<code class="python plain">(<code class="python string">'k1'<code class="python plain">,<code class="python string">'777'<code class="python plain">)
<div class="line number7 index6 alt2">
<div class="line number8 index7 alt1"><code class="python plain">mc.incr(<code class="python string">'k1'<code class="python plain">)
<div class="line number9 index8 alt2"><code class="python comments"># k1 = 778
<div class="line number10 index9 alt1">
<div class="line number11 index10 alt2"><code class="python plain">mc.incr(<code class="python string">'k1'<code class="python plain">,<code class="python value">10<code class="python plain">)
<div class="line number12 index11 alt1"><code class="python comments"># k1 = 788
<div class="line number13 index12 alt2">
<div class="line number14 index13 alt1"><code class="python plain">mc.decr(<code class="python string">'k1'<code class="python plain">)
<div class="line number15 index14 alt2"><code class="python comments"># k1 = 787
<div class="line number16 index15 alt1">
<div class="line number17 index16 alt2"><code class="python plain">mc.decr(<code class="python string">'k1'<code class="python plain">,<code class="python value">10<code class="python plain">)
<div class="line number18 index17 alt1"><code class="python comments"># k1 = 777
</td>
</tr>
</table>
10、gets 和cas
如商城商品剩余个数,假设改值保存在memcache中,product_count = 900
A用户刷新页面从memcache中读取到product_count = 900
B用户刷新页面从memcache中读取到product_count = 900
如果A、B用户均购买商品
A用户修改商品剩余个数 product_count=899
B用户修改商品剩余个数 product_count=899
如此一来缓存内的数据便不在正确,两个用户购买商品后,商品剩余还是 899
如果使用python的set和get来操作以上过程,那么程序就会如上述所示情况!
如果想要避免此情况的发生,只要使用 gets 和 cas 即可,如:
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="python comments">#!/usr/bin/env python
<div class="line number2 index1 alt1"><code class="python comments"># -- coding:utf-8 --
<div class="line number3 index2 alt2"><code class="python keyword">import <code class="python plain">memcache
<div class="line number4 index3 alt1"><code class="python plain">mc <code class="python keyword">= <code class="python plain">memcache.Client([<code class="python string">'10.211.55.4:12000'<code class="python plain">],debug<code class="python keyword">=<code class="python color1">True<code class="python plain">,cache_cas<code class="python keyword">=<code class="python color1">True<code class="python plain">)
<div class="line number5 index4 alt2">
<div class="line number6 index5 alt1"><code class="python plain">v <code class="python keyword">= <code class="python plain">mc.gets(<code class="python string">'product_count'<code class="python plain">)
<div class="line number7 index6 alt2"><code class="python comments"># ...
<div class="line number8 index7 alt1"><code class="python comments"># 如果有人在gets之后和cas之前修改了product_count,那么,下面的设置将会执行失败,剖出异常,从而避免非正常数据的产生
<div class="line number9 index8 alt2"><code class="python plain">mc.cas(<code class="python string">'product_count'<code class="python plain">,<code class="python string">"899"<code class="python plain">)
</td>
</tr>
</table>
Ps:本质上每次执行gets时,会从memcache中获取一个自增的数字,通过cas去修改gets的值时,会携带之前获取的自增值和memcache中的自增值进行比较,如果相等,则可以提交,如果不想等,那表示在gets和cas执行之间,又有其他人执行了gets(获取了缓冲的指定值), 如此一来有可能出现非正常数据,则不允许修改。
Redis
redis是一个key-value。和Memcached类似,它支持存储的value类型相对更多,包括string(字符串)、list()、set(集合)、zset(sorted set --有序集合)和hash(哈希类型)。这些都支持push/pop、add/remove及取交集并集和差集及更丰富的操作,而且这些操作都是原子性的。在此基础上,redis支持各种不同方式的排序。与memcached一样,为了保证效率,数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件,并且在此基础上实现了master-slave(主从)同步。
1(1) 速度快,因为数据存在内存中,类似于HashMap,HashMap的优势就是查找和操作的时间复杂度都是O(1<span style="color: #000000;">)(2<span style="color: #000000;">) 支持丰富数据类型,支持string,list,set,sorted set,hash
(3<span style="color: #000000;">) 支持事务,操作都是原子性,所谓的原子性就是对数据的更改要么全部执行,要么全部不执行
(4<span style="color: #000000;">) 丰富的特性:可用于缓存,消息,按key设置过期时间,过期后将会自动删除
2<span style="color: #000000;">. redis相比memcached有哪些优势?
(1<span style="color: #000000;">) memcached所有的值均是简单的字符串,redis作为其替代者,支持更为丰富的数据类型
(2<span style="color: #000000;">) redis的速度比memcached快很多
(3<span style="color: #000000;">) redis可以持久化其数据
3<span style="color: #000000;">. redis常见性能问题和解决方案:
(1<span style="color: #000000;">) Master最好不要做任何持久化工作,如RDB内存快照和AOF日志文件
(2<span style="color: #000000;">) 如果数据比较重要,某个Slave开启AOF备份数据,策略设置为每秒同步一次
(3<span style="color: #000000;">) 为了主从复制的速度和连接的稳定性,Master和Slave最好在同一个局域网内
(4<span style="color: #000000;">) 尽量避免在压力很大的主库上增加从库
(5) 主从复制不要用图状结构,用单向链表结构更为稳定,即:Master <- Slave1 <- Slave2 <-<span style="color: #000000;"> Slave3...
这样的结构方便解决单点故障问题,实现Slave对Master的替换。如果Master挂了,可以立刻启用Slave1做Master,其他不变。
4<span style="color: #000000;">. MySQL里有2000w数据,redis中只存20w的数据,如何保证redis中的数据都是热点数据
相关知识:redis 内存数据集大小上升到一定大小的时候,就会施行数据淘汰策略。redis 提供 6种数据淘汰策略:
voltile-<span style="color: #000000;">lru:从已设置过期时间的数据集(server.db[i].expires)中挑选最近最少使用的数据淘汰
volatile-<span style="color: #000000;">ttl:从已设置过期时间的数据集(server.db[i].expires)中挑选将要过期的数据淘汰
volatile-<span style="color: #000000;">random:从已设置过期时间的数据集(server.db[i].expires)中任意选择数据淘汰
allkeys-<span style="color: #000000;">lru:从数据集(server.db[i].dict)中挑选最近最少使用的数据淘汰
allkeys-<span style="color: #000000;">random:从数据集(server.db[i].dict)中任意选择数据淘汰
no-<span style="color: #000000;">enviction(驱逐):禁止驱逐数据
5<span style="color: #000000;">. Memcache与Redis的区别都有哪些?
1<span style="color: #000000;">)、存储方式
Memecache把数据全部存在内存之中,断电后会挂掉,数据不能超过内存大小。
Redis有部份存在硬盘上,这样能保证数据的持久性。
2<span style="color: #000000;">)、数据支持类型
Memcache对数据类型支持相对简单。
Redis有复杂的数据类型。
3<span style="color: #000000;">),value大小
redis最大可以达到1GB,而memcache只有1MB
6<span style="color: #000000;">. Redis 常见的性能问题都有哪些?如何解决?
1<span style="color: #000000;">).Master写内存快照,save命令调度rdbSave函数,会阻塞主线程的工作,当快照比较大时对性能影响是非常大的,会间断性暂停服务,所以Master最好不要写内存快照。
2<span style="color: #000000;">).Master AOF持久化,如果不重写AOF文件,这个持久化方式对性能的影响是最小的,但是AOF文件会不断增大,AOF文件过大会影响Master重启的恢复速度。Master最好不要做任何持久化工作,包括内存快照和AOF日志文件,特别是不要启用内存快照做持久化,如果数据比较关键,某个Slave开启AOF备份数据,策略为每秒同步一次。
3<span style="color: #000000;">).Master调用BGREWRITEAOF重写AOF文件,AOF在重写的时候会占大量的CPU和内存资源,导致服务load过高,出现短暂服务暂停现象。
4<span style="color: #000000;">). Redis主从复制的性能问题,为了主从复制的速度和连接的稳定性,Slave和Master最好在同一个局域网内
7<span style="color: #000000;">,redis 最适合的场景
Redis最适合所有数据in-momory的场景,虽然Redis也提供持久化功能,但实际更多的是一个disk-<span style="color: #000000;">backed的功能,跟传统意义上的持久化有比较大的差别,那么可能大家就会有疑问,似乎Redis更像一个加强版的Memcached,那么何时使用Memcached,何时使用Redis呢?
如果简单地比较Redis与Memcached的区别,大多数都会得到以下观点:
</span>1 、Redis不仅仅支持简单的k/<span style="color: #000000;">v类型的数据,同时还提供list,set,zset,hash等数据结构的存储。
</span>2 、Redis支持数据的备份,即master-<span style="color: #000000;">slave模式的数据备份。
</span>3<span style="color: #000000;"> 、Redis支持数据的持久化,可以将内存中的数据保持在磁盘中,重启的时候可以再次加载进行使用。
(1<span style="color: #000000;">)、会话缓存(Session Cache)
最常用的一种使用Redis的情景是会话缓存(session cache)。用Redis缓存会话比其他存储(如Memcached)的优势在于:Redis提供持久化。当维护一个不是严格要求一致性的缓存时,如果用户的购物车信息全部丢失,大部分人都会不高兴的,现在,他们还会这样吗?
幸运的是,随着 Redis 这些年的改进,很容易找到怎么恰当的使用Redis来缓存会话的文档。甚至广为人知的商业平台Magento也提供Redis的插件。
(2<span style="color: #000000;">)、全页缓存(FPC)
除基本的会话token之外,Redis还提供很简便的FPC平台。回到一致性问题,即使重启了Redis实例,因为有磁盘的持久化,用户也不会看到页面加载速度的下降,这是一个极大改进,类似PHP本地FPC。
再次以Magento为例,Magento提供一个插件来使用Redis作为全页缓存后端。
此外,对WordPress的用户来说,Pantheon有一个非常好的插件 wp-<span style="color: #000000;">redis,这个插件能帮助你以最快速度加载你曾浏览过的页面。
(3<span style="color: #000000;">)、队列
Reids在内存存储引擎领域的一大优点是提供 list 和 set 操作,这使得Redis能作为一个很好的消息队列平台来使用。Redis作为队列使用的操作,就类似于本地程序语言(如Python)对 list 的 push/<span style="color: #000000;">pop 操作。
如果你快速的在Google中搜索“Redis queues”,你马上就能找到大量的开源项目,这些项目的目的就是利用Redis创建非常好的后端工具,以满足各种队列需求。例如,Celery有一个后台就是使用Redis作为broker,你可以从这里去查看。
(4),排行榜/<span style="color: #000000;">计数器
Redis在内存中对数字进行递增或递减的操作实现的非常好。集合(Set)和有序集合(Sorted Set)也使得我们在执行这些操作的时候变的非常简单,Redis只是正好提供了这两种数据结构。所以,我们要从排序集合中获取到排名最靠前的10个用户–我们称之为“user_scores”,我们只需要像下面一样执行即可:
当然,这是假定你是根据你用户的分数做递增的排序。如果你想返回用户及用户的分数,你需要这样执行:
ZRANGE user_scores 0 10<span style="color: #000000;"> WITHSCORES
Agora Games就是一个很好的例子,用Ruby实现的,它的排行榜就是使用Redis来存储数据的,你可以在这里看到。
(5)、发布/<span style="color: #000000;">订阅
最后(但肯定不是最不重要的)是Redis的发布/订阅功能。发布/订阅的使用场景确实非常多。我已看见人们在社交网络连接中使用,还可作为基于发布/订阅的脚本触发器,甚至用Redis的发布/<span style="color: #000000;">订阅功能来建立聊天系统!(不,这是真的,你可以去核实)。
Redis提供的所有特性中,我感觉这个是喜欢的人最少的一个,虽然它为用户提供如果此多功能。
一、Redis安装和基本使用
启动服务端
启动客户端
get foo
二、Python操作Redis
API使用
redis-py 的API的使用可以分类为:
- 连接方式
- 连接池
- 操作
- String 操作
- Hash 操作
- List 操作
- Set 操作
- Sort Set 操作
- 管道
- 发布订阅
1、操作模式
redis-py提供两个类Redis和StrictRedis用于实现Redis的命令,StrictRedis用于实现大部分官方的命令,并使用官方的语法和命令,Redis是StrictRedis的子类,用于向后兼容旧版本的redis-py。
2、连接池
redis-py使用connection pool来管理对一个redis server的所有连接,避免每次建立、释放连接的开销。默认,每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池,然后作为参数Redis,这样就可以实现多个Redis实例共享一个连接池。
举例
= redis.ConnectionPool(host=,port=6379)
django.shortcuts app01.pool
= redis.Redis(connection_pool=POOL)
HttpResponse(<span style="color: #0000ff;">def<span style="color: #000000;"> home(request):
pool = redis.Redis(connection_pool=<span style="color: #000000;">POOL)
<span style="color: #0000ff;">return HttpResponse(<span style="color: #800000;">'<span style="color: #800000;">ok<span style="color: #800000;">')
3、Django-redis组件
CACHES =: : :
django.core.cache ] = conn =<span style="color: #000000;"> django_redis.get_redis_connection()
conn.set(<span style="color: #800000;">'<span style="color: #800000;">b<span style="color: #800000;">',<span style="color: #800000;">'<span style="color: #800000;">666<span style="color: #800000;">')
4、字符串(Srting)操作
String操作,r
set(name,value,ex=None,px=None,nx=False,xx=False)
setnx(name,value)
setex(name,time)
psetex(name,time_ms,value)
mset(*args,**kwargs)
get(name)
mget(keys,*args)
getset(name,value)
getrange(key,start,end)
setrange(name,offset,value)
setbit(name,value)