Python-memcached的基本使用(python 中使用memcached简单示例)
2013-05-10 15:12
841 查看
1.memcached的安装
请参考另一文章windows/Linux 下安装和使用memcached
启动一个memcached实例:memcached
-m 10 -p 12000
2.Python-memcached安装
到ftp://ftp.tummy.com/pub/python-memcached/下载最新版本的API,并解压tar包
输入python
setup.py install命令进行安装(如果安装由于缺少“setuptools”导致安装失败,就先下载 ez_setup.py,然后运行安装即可)
3.小例子演示
将memcached.pyc拷贝到工作目录
输出得到bar
4.Python-memcached
API总结
整个memcache.py只有1241行,相当精简
主要方法如下:
@set(key,val,time=0,min_compress_len=0)
无条件键值对的设置,其中的time用于设置超时,单位是秒,而min_compress_len则用于设置zlib压缩(注:zlib是提供数据压缩用的函式库)
@set_multi(mapping,time=0,key_prefix='',min_compress_len=0)
设置多个键值对,key_prefix是key的前缀,完整的键名是key_prefix+key, 使用方法如下
>>>
mc.set_multi({'k1' : 1, 'k2' : 2}, key_prefix='pfx_') == []
>>>
mc.get_multi(['k1', 'k2', 'nonexist'], key_prefix='pfx_') == {'k1' : 1, 'k2' : 2}
@add(key,val,time=0,min_compress_len=0)
添加一个键值对,内部调用_set()方法
@replace(key,val,time=0,min_compress_len=0)
替换value,内部调用_set()方法
@get(key)
根据key去获取value,出错返回None
@get_multi(keys,key_prefix='')
获取多个key的值,返回的是字典。keys为key的列表
@delete(key,time=0)
删除某个key。time的单位为秒,用于确保在特定时间内的set和update操作会失败。如果返回非0则代表成功
@incr(key,delta=1)
自增变量加上delta,默认加1,使用如下
>>>
mc.set("counter", "20")
>>>
mc.incr("counter")
21
@decr(key,delta=1)
自减变量减去delta,默认减1
5._set方法
很多方法内部都调用了_set方法,其源码如下:
注: memcached 的客户端使用TCP链接与服务器通讯, 一个运行中的memcached服务器监视一些端口, 客户端连接这些端口,发送命令到服务器,读取回应,最后关闭连接。(具体命令请参考《Memcached
协议中文版》)
6.python-memcached线程安全
本部分转自http://weavesky.com/2009/01/22/is-python-memcached-threadsafe/
python-memcached是不是线程安全的
答案是肯定的,前提你在使用Python 2.4+和python-memcached 1.36+
为什么我们需要线程安全的memcached client,因为我们的实际应用一般是多线程的模型,例如cherrypy、twisted,如果python-memcached不是线程安全的话,引起的问题不仅仅是并发修改共享变量这么简单,是外部socket链接的数据流的混乱
python-memcached怎么实现线程安全的呢?查看源代码看到
很取巧的让Client类继承threading.local,也就是Client里面的每一个属性都是跟当前线程绑定的。实现虽然不太优雅,但是很实在。但是别以为这样就可以随便在线程里面用python-memcached了,因为这种thread
local的做法,你的应用必须要使用thread pool的模式,而不能不停创建销毁thread,因为每一个新线程的创建,对于就会使用一个全新的Client,也就是一个全新的socket链接,如果不停打开创建销毁thread的话,就会导致不停的创建销毁socket链接,导致性能大量下降。幸好,无论是cherrypy还是twisted,都是使用了thread pool的模式
原文链接:www.cnblogs.com/analyzer/articles/2104109.html
请参考另一文章windows/Linux 下安装和使用memcached
启动一个memcached实例:memcached
-m 10 -p 12000
2.Python-memcached安装
到ftp://ftp.tummy.com/pub/python-memcached/下载最新版本的API,并解压tar包
输入python
setup.py install命令进行安装(如果安装由于缺少“setuptools”导致安装失败,就先下载 ez_setup.py,然后运行安装即可)
3.小例子演示
将memcached.pyc拷贝到工作目录
#!/usr/bin/env python import memcache mc = memcache.Client(['127.0.0.1:12000'],debug=0) mc.set("foo","bar") value = mc.get("foo") print value
输出得到bar
4.Python-memcached
API总结
整个memcache.py只有1241行,相当精简
主要方法如下:
@set(key,val,time=0,min_compress_len=0)
无条件键值对的设置,其中的time用于设置超时,单位是秒,而min_compress_len则用于设置zlib压缩(注:zlib是提供数据压缩用的函式库)
@set_multi(mapping,time=0,key_prefix='',min_compress_len=0)
设置多个键值对,key_prefix是key的前缀,完整的键名是key_prefix+key, 使用方法如下
>>>
mc.set_multi({'k1' : 1, 'k2' : 2}, key_prefix='pfx_') == []
>>>
mc.get_multi(['k1', 'k2', 'nonexist'], key_prefix='pfx_') == {'k1' : 1, 'k2' : 2}
@add(key,val,time=0,min_compress_len=0)
添加一个键值对,内部调用_set()方法
@replace(key,val,time=0,min_compress_len=0)
替换value,内部调用_set()方法
@get(key)
根据key去获取value,出错返回None
@get_multi(keys,key_prefix='')
获取多个key的值,返回的是字典。keys为key的列表
@delete(key,time=0)
删除某个key。time的单位为秒,用于确保在特定时间内的set和update操作会失败。如果返回非0则代表成功
@incr(key,delta=1)
自增变量加上delta,默认加1,使用如下
>>>
mc.set("counter", "20")
>>>
mc.incr("counter")
21
@decr(key,delta=1)
自减变量减去delta,默认减1
5._set方法
很多方法内部都调用了_set方法,其源码如下:
def _set(self, cmd, key, val, time, min_compress_len = 0): self.check_key(key) server, key = self._get_server(key) if not server: return 0 self._statlog(cmd) store_info = self._val_to_store_info(val, min_compress_len) if not store_info: return(0) if cmd == 'cas': if key not in self.cas_ids: return self._set('set', key, val, time, min_compress_len) fullcmd = "%s %s %d %d %d %d\r\n%s" % ( cmd, key, store_info[0], time, store_info[1], self.cas_ids[key], store_info[2]) else: fullcmd = "%s %s %d %d %d\r\n%s" % ( cmd, key, store_info[0], time, store_info[1], store_info[2]) try: server.send_cmd(fullcmd) return(server.expect("STORED") == "STORED") except socket.error, msg: if isinstance(msg, tuple): msg = msg[1] server.mark_dead(msg) return 0
注: memcached 的客户端使用TCP链接与服务器通讯, 一个运行中的memcached服务器监视一些端口, 客户端连接这些端口,发送命令到服务器,读取回应,最后关闭连接。(具体命令请参考《Memcached
协议中文版》)
6.python-memcached线程安全
本部分转自http://weavesky.com/2009/01/22/is-python-memcached-threadsafe/
python-memcached是不是线程安全的
答案是肯定的,前提你在使用Python 2.4+和python-memcached 1.36+
为什么我们需要线程安全的memcached client,因为我们的实际应用一般是多线程的模型,例如cherrypy、twisted,如果python-memcached不是线程安全的话,引起的问题不仅仅是并发修改共享变量这么简单,是外部socket链接的数据流的混乱
python-memcached怎么实现线程安全的呢?查看源代码看到
try: # Only exists in Python 2.4+ from threading import local except ImportError: # TODO: add the pure-python local implementation class local(object): pass class Client(local):
很取巧的让Client类继承threading.local,也就是Client里面的每一个属性都是跟当前线程绑定的。实现虽然不太优雅,但是很实在。但是别以为这样就可以随便在线程里面用python-memcached了,因为这种thread
local的做法,你的应用必须要使用thread pool的模式,而不能不停创建销毁thread,因为每一个新线程的创建,对于就会使用一个全新的Client,也就是一个全新的socket链接,如果不停打开创建销毁thread的话,就会导致不停的创建销毁socket链接,导致性能大量下降。幸好,无论是cherrypy还是twisted,都是使用了thread pool的模式
原文链接:www.cnblogs.com/analyzer/articles/2104109.html
相关文章推荐
- 在python中使用c语言扩展模块的简单示例
- python中mechanize库的简单使用示例
- 使用python监控memcached基本信息
- 使用Python编写vim插件的简单示例
- 使用Python的Bottle框架写一个简单的服务接口的示例
- [UIA]Python使用UIA基本示例
- 03—小白学Python爬虫之urllib的基本和进阶使用及Get、Post示例
- Python简单定义与使用字典dict的方法示例
- Python中使用urllib2模块编写爬虫的简单上手示例
- OpenGl中使用着色器的基本步骤及GLSL渲染简单示例
- Python中atexit模块的基本使用示例
- python使用nsq简单示例
- PHP 使用memcached简单示例分享
- Python 正则表达式的简单使用示例
- 使用Python的Scrapy框架编写web爬虫的简单示例
- Python中使用urllib2模块编写爬虫的简单上手示例
- 使用Python编写简单的画图板程序的示例教程
- Python-memcached的基本使用
- [转]Python-memcached的基本使用
- Python-memcached的基本使用 - Flynewton成长点滴 - 开源中国社区