Ñò
ha-Kc @ s& d Z d d k Z d d k Z d d k Z y d d k Z Wn e j
o d d k Z n Xd Z d Z d Z d Z
d e f d „ ƒ YZ d f d
„ ƒ YZ
d f d „ ƒ YZ d
„ Z e d j o\d GHe ƒ d GHd g Z e
e d d ƒZ d „ Z d „ Z d f d „ ƒ YZ e d d ƒ e d d ƒ e d e d d >ƒ ƒ o' d GHe i d ƒ o d GHn d GHn d! GHe i d d g ƒ GHd" GHe e i d# ƒ ƒ GHe ƒ Z e d$ e ƒ d% GHe i d d ƒ Z e d& j o d GHn d GHd' GHe i d d ƒ Z e d j o d GHn d GHn d S(( sÖ
client module for memcached (memory cache daemon)
Overview
========
See U{the MemCached homepage} for more about memcached.
Usage summary
=============
This should give you a feel for how this module operates::
import memcache
mc = memcache.Client(['127.0.0.1:11211'], debug=0)
mc.set("some_key", "Some value")
value = mc.get("some_key")
mc.set("another_key", 3)
mc.delete("another_key")
mc.set("key", "1") # note that the key used for incr/decr must be a string.
mc.incr("key")
mc.decr("key")
The standard way to use memcache with a database is like this::
key = derive_key(obj)
obj = mc.get(key)
if not obj:
obj = backend_api.get(...)
mc.set(key, obj)
# we now have obj, and future passes through this code
# will use the object from the cache.
Detailed Documentation
======================
More detailed documentation is available in the L{Client} class.
iÿÿÿÿNs Evan Martin s
1.2_tummy5s$ Copyright (C) 2003 Danga Interactivet Pythont _Errorc B s e Z RS( ( t __name__t
__module__( ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR : s t Clientc B s
e Z d Z e Z d Z d Z d Z d Z d d „ Z d „ Z
d „ Z d „ Z d „ Z
d
„ Z d „ Z d „ Z d
„ Z d „ Z d d „ Z d d „ Z d d „ Z d „ Z d d „ Z d d „ Z d d „ Z d „ Z d „ Z d „ Z d d „ Z d „ Z RS( sv
Object representing a pool of memcache servers.
See L{memcache} for an overview.
In all cases where a key is used, the key can be either:
1. A simple hashable type (string, integer, etc.).
2. A tuple of C{(hashvalue, key)}. This is useful if you want to avoid
making this module calculate a hash value. You may prefer, for
example, to keep all of a given user's objects on the same memcache
server, so you could use the user's unique id as the hash value.
@group Setup: __init__, set_servers, forget_dead_hosts, disconnect_all, debuglog
@group Insertion: set, add, replace
@group Retrieval: get, get_multi
@group Integers: incr, decr
@group Removal: delete
@sort: __init__, set_servers, forget_dead_hosts, disconnect_all, debuglog, set, add, replace, get, get_multi, incr, decr, delete
i i i i
c C s# | i | ƒ | | _ h | _ d S( sï
Create a new Client object with the given list of servers.
@param servers: C{servers} is passed to L{set_servers}.
@param debug: whether to display error messages when a server can't be
contacted.
N( t set_serverst debugt stats( t selft serversR ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyt __init__Z s
c C s> g } | D] } | t | | i ƒ q ~ | _ | i ƒ d S( sd
Set the pool of servers used by this client.
@param servers: an array of servers.
Servers can be passed in two forms:
1. Strings of the form C{"host:port"}, which implies a default weight of 1.
2. Tuples of the form C{("host:port", weight)}, where C{weight} is
an integer weight value.
N( t _Hostt debuglogR t
_init_buckets( R R t _[1]t s( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR f s
0c C sÙ g } xÌ | i D]Á } | i ƒ p q n d | i | i | i f } | i d ƒ h } | i | | f ƒ | i } xY t oQ | ƒ } | p | i ƒ d j o Pn | i
d d ƒ } | d | | d >> mc.set("counter", "20") # returns 1, indicating success
1
>>> mc.incr("counter")
21
>>> mc.incr("counter")
22
Overflow on server is not checked. Be aware of values approaching
2**32. See L{decr}.
@param delta: Integer amount to increment by (should be zero or greater).
@return: New value after incrementing.
@rtype: int
t incr( t _incrdecr( R R6 t delta( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRC Ò s c C s | i d | | ƒ S( sV
Like L{incr}, but decrements. Unlike L{incr}, underflow is checked and
new values are capped at 0. If server value is 1, a decrement of 2
returns 0, not -1.
@param delta: Integer amount to decrement by (should be zero or greater).
@return: New value after decrementing.
@rtype: int
t decr( RD ( R R6 RE ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRF ë s
c C s™ | i | ƒ \ } } | p d S| i | ƒ d | | | f } y' | i | ƒ | i ƒ } t | ƒ SWn* t i j
o } | i | d ƒ d SXd S( Ni s %s %s %di ( R8 R) R R t intR= R> R? R5 ( R RA R6 RE R. R RB ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRD ÷ s
c C s | i d | | | ƒ S( s¿
Add new key with value.
Like L{set}, but only stores in memcache if the key doesn't already exist.
@return: Nonzero on success.
@rtype: int
t add( t _set( R R6 t valR@ ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRH s c C s | i d | | | ƒ S( sÚ Replace existing key with value.
Like L{set}, but only stores in memcache if the key already exists.
The opposite of L{add}.
@return: Nonzero on success.
@rtype: int
t replace( RI ( R R6 RJ R@ ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRK s c C s | i d | | | ƒ S( sÕ Unconditionally sets a key to a given value in the memcache.
The C{key} can optionally be an tuple, with the first element being the
hash value, if you want to avoid making this module calculate a hash value.
You may prefer, for example, to keep all of a given user's objects on the
same memcache server, so you could use the user's unique id as the hash
value.
@return: Nonzero on success.
@rtype: int
t set( RI ( R R6 RJ R@ ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRL s c C s< | i | ƒ \ } } | p d S| i | ƒ d } t | t ƒ o n„ t | t ƒ o | t i O} d | } nY t | t ƒ o | t i O} d | } n. | i o# | t i
O} t i | d ƒ } n d | | | | t
| ƒ | f } y | i | ƒ | i d ƒ Wn* t i j
o } | i | d ƒ d SXd S( Ni s %di s %s %s %d %d %d
%st STOREDi ( R8 R) R0 R' RG R t
_FLAG_INTEGERt longt
_FLAG_LONGt
_usePicklet _FLAG_PICKLEt picklet dumpsR4 R R# R= R> R? ( R RA R6 RJ R@ R. t flagst fullcmdRB ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRI ' s0
"
c C sÚ | i | ƒ \ } } | p d S| i d ƒ y[ | i d | ƒ | i | ƒ \ } } } | p d S| i | | | ƒ } | i d ƒ WnJ t t i f j
o5 } t
| t ƒ o | d } n | i | ƒ d SX| S( sX Retrieves a key from the memcache.
@return: The value or None.
t gets get %sR i N(
R8 R5 R) R t _expectvaluet _recv_valueR# R R= R> R0 R1 R? ( R R6 R. t rkeyRU t rlent valueRB ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRW F s"
c
C sÕ | i d ƒ h } x] | D]U } | i | ƒ \ } } | p q n | | j o g | | >> success = mc.set("foo", "bar")
>>> success = mc.set("baz", 42)
>>> mc.get_multi(["foo", "baz", "foobar"]) == {"foo": "bar", "baz": 42}
1
This method is recommended over regular L{get} as it lowers the number of
total packets flying around your network, reducing total latency, since
your app doesn't have to wait for each round-trip of L{get} before sending
the next one.
@param keys: An array of keys.
@return: A dictionary of key/value pairs that were available.
t get_multis get %sR i R N( R) R8 R t keysR t joinR= R> R? R RX R5 RY R (
R R^ t server_keysR6 R. t dead_serversRB t retvalsR RZ RU R[ RJ ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR] _ sH
"
c C sn | p | i ƒ } n | d d j o> | i ƒ \ } } } } t | ƒ } t | ƒ } | | | f Sd Sd S( Ni t VALUE( NNN( R R RG R5 ( R R. R t respRZ RU R4 R[ ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRX › s c C s! | d 7} | i | ƒ } t | ƒ | j o t d t | ƒ | f ƒ ‚ n t | ƒ | j o | d } n | d j o
| } nš | t i @o t | ƒ } n| | t i @o t | ƒ } n^ | i oB | t i @o4 y t
i | ƒ } Wq | i d ƒ d } q Xn | i d | ƒ | S( Ni s# received %d bytes when expecting %diþÿÿÿi s Pickle error...
s unknown flags on get: %x
( t recvR4 R R RN RG RP RO RQ RR RS t loadsR R5 ( R R. RU R[ t bufRJ ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRY § s(
i i i N( R R t __doc__t FalseRQ RR RN RP R3 R
R R R! R R) R+ R
R8 R: R; RC RF RD RH RK RL RI RW R] R5 RX RY ( ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR = s8
< R c B st e Z d Z d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d
„ Z
d „ Z RS(
i c C sÁ t | t ƒ o | d } | d | _ n
d | _ | i d ƒ d j o1 | i d ƒ \ | _ | _ t | i ƒ | _ n | d | _ | _ | p
d „ } n | | _ d | _ d | _ d S( Ni i t :iË+ c S s | S( ( ( t x( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyt Ò s ( R0 R1 R t findR R R RG R t deaduntilR5 R= ( R t hostt debugfunc( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR
Ä s
c C s2 | i o | i t i ƒ j o d Sd | _ d S( Ni i ( Rn R@ ( R ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyt _check_deadØ s c C s | i ƒ o d Sd S( Ni i ( t _get_socket( R ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR Þ s
c C s; | i d | | f ƒ t i ƒ t i | _ | i ƒ d S( Ns MemCache: %s: %s. Marking dead.( R R@ R t _DEAD_RETRYRn R9 ( R t reason( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR? ã s c C s— | i ƒ o d S| i o | i St i t i t i ƒ } y | i | i | i f ƒ Wn. t i j
o } | i d | d ƒ d SX| | _ | S( Ns connect: %si (
Rq R5 R= t AF_INETt SOCK_STREAMR R R R> R? ( R R RB ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRr è s
c C s( | i o | i i ƒ d | _ n d S( N( R= t closeR5 ( R ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR9 ÷ s
c C sO t | ƒ d j o$ | i i | ƒ | i i d ƒ n | i i | d ƒ d S( Nid s
( R4 R= t sendall( R RA ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR ü s c C sŒ d } | i i } xs t ok | d ƒ } | p | i d t | ƒ ƒ Pn | d j o! | o | d d j o | d S| | } q W| S( Nt i s' Connection closed while reading from %ss
iÿÿÿÿs
( R= Re R R? t repr( R t buffersRe R ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR s % c C s8 | i ƒ } | | j o | i d | | f ƒ n | S( Ns2 while expecting '%s', got unexpected response '%s'( R R ( R t textR ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR# s
c C sK d } | i i } x2 t | ƒ | j o | | | t | ƒ ƒ } q W| S( NRy ( R= Re R4 ( R R[ Rg Re ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyRe s c C s8 d } | i o d | i } n d | i | i | f S( NRy s (dead until %d)s %s:%d%s( Rn R R ( R t d( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyt __str__ s
N( R R Rs R5 R
Rq R R? Rr R9 R R R# Re R~ ( ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR Á s c C sS d d k } d d k } d g } t | d d ƒ} h | d 6} | i | d | ƒS( Niÿÿÿÿs 127.0.0.1:11211R i t mct globs( t doctestt memcacheR t testmod( R R‚ R R R€ ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyt _doctest$ s
t __main__s Testing docstrings...s Running tests:s 127.0.0.1:11211R i c C s- t | t ƒ p d | t | ƒ f Sd | S( Ns %s (%s)s %s( R0 R' t type( RJ ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyt to_s3 s c C s^ d t | ƒ t | ƒ f GHt i | | ƒ t i | ƒ } | | j o
d GHd Sd GHd Sd S( Ns Testing set/get {'%s': %s} ...R" i t FAILi ( R‡ R RL RW ( R6 RJ t newval( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyt test_setget7 s
t FooStructc B s# e Z d „ Z d „ Z d „ Z RS( c C s
d | _ d S( Nt baz( t bar( R ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR
C s c C s d S( Ns A FooStruct( ( R ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR~ E s c C s% t | t ƒ o | i | i j Sd S( Ni ( R0 R‹ R ( R t other( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyt __eq__G s ( R R R
R~ R ( ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyR‹ B s t a_strings some random stringt
an_integeri* RO i s Testing delete ...R" Rˆ s Testing get_multi ...s Testing get(unknown value) ...t
unknown_valuet foostructs Testing incr ...i+ s Testing decr ...( Rh R$ R= R@ t cPickleRS t ImportErrort
__author__t __version__t
__copyright__t __license__t ExceptionR R R R„ R R R R‡ RŠ R‹ RO R; R] RW t fRC Rk RF ( ( ( s< /usr/lib64/python2.6/site-packages/Cheetah/Utils/memcache.pyt + s` ÿ …c