B
|
ÕdÄ ã @ sh d Z ddlZddlZddlZddlmZ ejZdd edD Z G dd dZ
|
G d d
|
d
|
Z e d krddS ) u
|
redis管çå¨
|
é N)Úlogger_redis_debugc
|
C s. g | ]&}t jtd td td |dddqS )ÚhostÚportÚpwdTé2 )r r ÚpasswordÚdbÚdecode_responsesZmax_connections)ÚredisZConnectionPoolÚconfig)Ú.0r © r ú4D:\workspace\GP\gp_middle_server\db\redis_manager.pyú
|
<listcomp> s r é c @ s, e Zd Zed fddZdd Zdd ZdS ) Ú RedisManagerr c C s t | | _|| _d S )N)Ú pool_cachesÚpoolr )Úselfr r r r Ú__init__ s
|
zRedisManager.__init__c C s t j| jdS )N)Zconnection_pool)r
|
ÚRedisr )r r r r ÚgetRedis s zRedisManager.getRedisc C s" t jtd td td | jddS )Nr r r T)r r r r r )r
|
r r r )r r r r ÚgetRedisNoPool s zRedisManager.getRedisNoPoolN)Ú__name__Ú
|
__module__Ú __qualname__r r r r r r r r r s r c @ s e Zd Zedd Zed(ddZed)ddZed*d d
|
Zed+d d Zed,d dZ ed-ddZ
|
ed.ddZ ed/ddZ ed0ddZ ed1ddZed2ddZed3dd Zed4d d Zed5d d Zed6d!d"Zed7d#d$Zed%d& Zd'S )8Ú
|
RedisUtilsc C s8 t ¡ }z| S t d|tt ¡ | d d|¡ X d S )Nz {}({}):{}iè é )Útimer ÚinfoÚround)ÚclsÚ method_nameÚkeyZ lamada_methodZ_RedisUtils__start_timer r r Úexec! s zRedisUtils.execTc s | d fdd¡S )NÚgetc s
|
¡S )N)r% r )r# Úredis_r r Ú<lambda>+ ó z RedisUtils.get.<locals>.<lambda>)r$ )r! r& r# Ú auto_freer )r# r& r r% ) s zRedisUtils.getc s | d fdd¡S )NÚscardc s
|
¡S )N)r* r )r# r& r r r' / r( z"RedisUtils.scard.<locals>.<lambda>)r$ )r! r& r# r) r )r# r& r r* - s zRedisUtils.scardFc s | d fdd¡S )NÚdeletec s
|
¡S )N)r+ r )r# r& r r r' 3 r( z#RedisUtils.delete.<locals>.<lambda>)r$ )r! r& r# r) Ú_asyncr )r# r& r r+ 1 s zRedisUtils.deletec s | d fdd¡S )NÚkeysc s
|
¡S )N)r- r )r# r& r r r' 7 r( z!RedisUtils.keys.<locals>.<lambda>)r$ )r! r& r# r) r )r# r& r r- 5 s zRedisUtils.keysc s | d fdd¡S )NÚsetc s ¡S )N)r. r )r# r& Úvalr r r' ; r( z RedisUtils.set.<locals>.<lambda>)r$ )r! r& r# r/ r) r )r# r& r/ r r. 9 s zRedisUtils.setc s | d fdd¡S )NÚsetexc s ¡S )N)r0 r )Úexpirer# r& r/ r r r' ? r( z"RedisUtils.setex.<locals>.<lambda>)r$ )r! r& r# r1 r/ r) r, r )r1 r# r& r/ r r0 = s zRedisUtils.setexc s | d fdd¡S )NÚsetnxc s ¡S )N)r2 r )r# r& r/ r r r' C r( z"RedisUtils.setnx.<locals>.<lambda>)r$ )r! r& r# r/ r) r )r# r& r/ r r2 A s zRedisUtils.setnxc s | d fdd¡S )Nr1 c s ¡S )N)r1 r )r1 r# r& r r r' G r( z#RedisUtils.expire.<locals>.<lambda>)r$ )r! r& r# r1 r) r )r1 r# r& r r1 E s zRedisUtils.expirec s | d fdd¡S )NÚsaddc s ¡S )N)r3 r )r# r& r/ r r r' K r( z!RedisUtils.sadd.<locals>.<lambda>)r$ )r! r& r# r/ r) r )r# r& r/ r r3 I s zRedisUtils.saddc s | d fdd¡S )NÚ sismemberc s ¡S )N)r4 r )r# r& r/ r r r' O r( z&RedisUtils.sismember.<locals>.<lambda>)r$ )r! r& r# r/ r) r )r# r& r/ r r4 M s zRedisUtils.sismemberc s | d fdd¡S )NÚsmembersc s
|
¡S )N)r5 r )r# r& r r r' S r( z%RedisUtils.smembers.<locals>.<lambda>)r$ )r! r& r# r) r )r# r& r r5 Q s zRedisUtils.smembersc s | d fdd¡S )NÚsremc s ¡S )N)r6 r )r# r& r/ r r r' W r( z!RedisUtils.srem.<locals>.<lambda>)r$ )r! r& r# r/ r) r )r# r& r/ r r6 U s zRedisUtils.sremc s | d fdd¡S )NÚincrbyc s ¡S )N)r7 r )r# Únumr& r r r' [ r( z#RedisUtils.incrby.<locals>.<lambda>)r$ )r! r& r# r8 r) r, r )r# r8 r& r r7 Y s zRedisUtils.incrbyc s | d fdd¡S )NÚlpushc s ¡S )N)r9 r )r# r& r/ r r r' _ r( z"RedisUtils.lpush.<locals>.<lambda>)r$ )r! r& r# r/ r) r )r# r& r/ r r9 ] s zRedisUtils.lpushc s | d fdd¡S )NÚlpopc s
|
¡S )N)r: r )r# r& r r r' c r( z!RedisUtils.lpop.<locals>.<lambda>)r$ )r! r& r# r) r )r# r& r r: a s zRedisUtils.lpopc s | d fdd¡S )NÚrpushc s ¡S )N)r; r )r# r& r/ r r r' g r( z"RedisUtils.rpush.<locals>.<lambda>)r$ )r! r& r# r/ r) r )r# r& r/ r r; e s zRedisUtils.rpushc C s d S )Nr )r! r& r r r Úrealsei s zRedisUtils.realseN)T)T)TF)T)T)TF)T)T)T)T)T)T)TF)T)T)T)r r r Ú classmethodr$ r% r* r+ r- r. r0 r2 r1 r3 r4 r5 r6 r7 r9 r: r; r< r r r r r sD r Ú__main__) Ú__doc__r r
|
ÚconstantÚlogr Ú REDIS_CONFIGr Úranger r r r r r r r Ú<module> s O
|
