§
|
4h6 ã ót d Z ddlZddlmZmZmZ ddlZddlmZ ddl m
|
Z
|
G d d¦ « Z e ¦ « Z dS )u
|
Rediséå管çæå¡
|
é N)ÚOptionalÚDictÚAny)Úlogger)Úsettingsc
|
ó$ e Zd ZdZd ZdedefdZdedefdZdedefdZdede ee
|
f de fd Z dded e dee ee
|
f fd Z ddede de de fdZdede fdZdedee fdZ ddedede de fdZdede fdZdede fdZdS ) ÚRedisQueueManageru Rediséå管çå¨c óz t j t j d¬¦ « | _ d| _ d| _ d| _ d S )NT)Údecode_responsesz ecloud_queue:zecloud_processing:zecloud_conversation:)ÚredisÚfrom_urlr Ú redis_urlÚ redis_clientÚ queue_prefixÚprocessing_prefixÚconversation_prefix)Úselfs ú4d:\project\python\ECloud\app\services\redis_queue.pyÚ__init__zRedisQueueManager.__init__ s; Ý !N8Ô+=ÐPTÐ UÑ UÔ UÔØ +ÔØ!5Ô Ø#9Ô Ð Ð ó Ú from_userÚreturnc ó | j | S )u è·åç¨æ·éåé®)r ©r r s r Úget_user_queue_keyz$RedisQueueManager.get_user_queue_key s àÔ#Ð0 YÐ0Ð0Ð0r c ó | j | S )u è·åå¤çç¶æé®)r r s r Úget_processing_keyz$RedisQueueManager.get_processing_key s àÔ(Ð5¨)Ð5Ð5Ð5r c ó | j | S )u è·åç¨æ·å¯¹è¯IDé®)r r s r Úget_conversation_keyz&RedisQueueManager.get_conversation_key s àÔ*Ð7¨IÐ7Ð7Ð7r Ú message_datac óL | |¦ « }t j |d¬¦ « }| j ||¦ « }t j d| d| d| ¦ « dS # t $ r2}t j d| dt |¦ « ¦ « Y d }~dS d }~ww xY w)
|
u å°æ¶æ¯å å
¥ç¨æ·éåF)Ú ensure_asciiu æ¶æ¯å·²å å
¥éå: user=z, queue_length=z
|
, message=Tu æ¶æ¯å
¥é失败: user=ú, error=N)
|
r ÚjsonÚdumpsr Úlpushr ÚinfoÚ ExceptionÚerrorÚstr)r r r Ú queue_keyÚ message_jsonÚresultÚes r Úenqueue_messagez!RedisQueueManager.enqueue_message! sË ð Ø ×/Ò/° Ñ:Ô:IÝ : lÀÐGÑGÔGLð Ô&×,Ò,¨Y¸ ÑEÔEFå KÐq°yÐqÐqÐQWÐqÐqÐcoÐqÐqÑ rÔ rÐ rØ4øåð ð ð Ý LÐP°YÐPÐPÍÈAÉÌÐPÐPÑ QÔ QÐ QØ55555øøøøð øøøs A#A' Á'
|
B#Á1'B  B#r Útimeoutc ó | |¦ « }|dk r&| j ||¬¦ « }|r|\ }}n dS | j |¦ « }|sdS t j |¦ « }t j d| ¦ « |S # t $ r2}t j d| dt |¦ « ¦ « Y d}~dS d}~ww xY w)u ä»ç¨æ·éåä¸ååºæ¶æ¯r )r0 Nu æ¶æ¯å·²åºé: user=u æ¶æ¯åºé失败: user=r# ) r r ÚbrpopÚrpopr$ Úloadsr r' r( r) r* ) r r r0 r+ r- Ú_r, r r. s r Údequeue_messagez!RedisQueueManager.dequeue_message1 sü ð Ø ×/Ò/° Ñ:Ô:Ià{{à Ô*×0Ò0°ÀGÐ0ÑLÔLØð Ø&,OA||à 4ð $Ô 0× 5Ò 5°iÑ @Ô @ Ø#ð Ø 4å : lÑ3Ô3LÝ KÐ<°Ð<Ð<Ñ =Ô =Ð =Ø Ð øåð ð ð Ý LÐP°YÐPÐPÍÈAÉÌÐPÐPÑ QÔ QÐ QØ44444øøøøð øøøs# ?B Á B Á!,B Â
|
C
|
Â'CÃC
|
é, ÚstatusÚttlc ó | |¦ « }|r7| j ||d¦ « t j d| d| ¦ « n1| j |¦ « t j d| ¦ « dS # t $ r2}t j d| dt |¦ « ¦ « Y d}~d S d}~ww xY w)
|
u 设置ç¨æ·å¤çç¶æÚ
|
processingu 设置å¤çç¶æ: user=z, status=processing, ttl=u æ¸
é¤å¤çç¶æ: user=Tu 设置å¤çç¶æ失败: user=r# NF) r r Úsetexr r' Údeleter( r) r* )r r r8 r9 Úprocessing_keyr. s r Úset_processing_statusz'RedisQueueManager.set_processing_statusM sö ð Ø !× 4Ò 4°YÑ ?Ô ?Nàð EàÔ!×'Ò'¨¸¸\ÑJÔJÐJÝ ØY° ÐYÐYÐTWÐYÐYñô ð ð ð
|
Ô!×(Ò(¨ Ñ8Ô8Ð8Ý Ð C¸ Ð CÐ CÑDÔDÐDà4øåð ð ð Ý LÐV¸9ÐVÐVÍcÐRSÉfÌfÐVÐVÑ WÔ WÐ WØ55555øøøøð øøøs A?B Â
|
B? 'B:Â:B?c óè | |¦ « }| j |¦ « dk S # t $ r2}t j d| dt |¦ « ¦ « Y d}~dS d}~ww xY w)u! æ£æ¥ç¨æ·æ¯å¦æ£å¨å¤çä¸r u æ£æ¥å¤çç¶æ失败: user=r# NF)r r Úexistsr( r r) r* )r r r> r. s r Ú is_processingz RedisQueueManager.is_processinge s ð Ø !× 4Ò 4°YÑ ?Ô ?NØÔ$×+Ò+¨NÑ;Ô;¸aÒ?Ð ?øÝð ð ð Ý LÐV¸9ÐVÐVÍcÐRSÉfÌfÐVÐVÑ WÔ WÐ WØ55555øøøøð øøøs 25 µ
|
A1¿'A,Á,A1c óà | |¦ « }| j |¦ « S # t $ r2}t j d| dt |¦ « ¦ « Y d}~dS d}~ww xY w)u è·åç¨æ·ç对è¯IDu è·å对è¯ID失败: user=r# N)r r Úgetr( r r) r* )r r Úconversation_keyr. s r Úget_conversation_idz%RedisQueueManager.get_conversation_idn s ð Ø #× 8Ò 8¸Ñ CÔ CÐ ØÔ$×(Ò(Ð)9Ñ:Ô:Ð :øÝð ð ð Ý LÐR°yÐRÐRÍ#ÈaÉ&Ì&ÐRÐRÑ SÔ SÐ SØ44444øøøøð øøøó .1 ±
|
A-»'A(Á(A-éQ Úconversation_idc ó | |¦ « }| j |||¦ « t j d| d| ¦ « dS # t
|
$ r2}t j d| dt |¦ « ¦ « Y d}~dS d}~ww xY w)u 设置ç¨æ·ç对è¯IDu 设置对è¯ID: user=z, conversation_id=Tu 设置对è¯ID失败: user=r# NF)r r r< r r' r( r) r* )r r rI r9 rE r. s r Úset_conversation_idz%RedisQueueManager.set_conversation_idw s¸ ð Ø #× 8Ò 8¸Ñ CÔ CÐ Ø Ô × #Ò #Ð$4°c¸?Ñ KÔ KÐ KÝ KØV¨ ÐVÐVÀ_ÐVÐVñ ô ð ð 4øÝð ð ð Ý LÐR°yÐRÐRÍ#ÈaÉ&Ì&ÐRÐRÑ SÔ SÐ SØ55555øøøøð øøøs A A Á
|
B Á'BÂB c óà | |¦ « }| j |¦ « S # t $ r2}t j d| dt |¦ « ¦ « Y d}~dS d}~ww xY w)u è·åç¨æ·éåé¿åº¦u è·åéåé¿åº¦å¤±è´¥: user=r# Nr )r r Úllenr( r r) r* ©r r r+ r. s r Úget_queue_lengthz"RedisQueueManager.get_queue_length s
ð Ø ×/Ò/° Ñ:Ô:IØÔ$×)Ò)¨)Ñ4Ô4Ð 4øÝð ð ð Ý LÐV¸9ÐVÐVÍcÐRSÉfÌfÐVÐVÑ WÔ WÐ WØ11111øøøøð øøørG c ó | |¦ « }| j |¦ « t j d| ¦ « dS # t
|
$ r2}t j d| dt |¦ « ¦ « Y d}~dS d}~ww xY w)u æ¸
空ç¨æ·éåu æ¸
空ç¨æ·éå: user=Tu æ¸
空ç¨æ·éå失败: user=r# NF)r r r= r r' r( r) r* rN s r Úclear_user_queuez"RedisQueueManager.clear_user_queue s£ ð Ø ×/Ò/° Ñ:Ô:IØ Ô × $Ò $ YÑ /Ô /Ð /Ý KÐ?°IÐ?Ð?Ñ @Ô @Ð @Ø4øÝð ð ð Ý LÐV¸9ÐVÐVÍcÐRSÉfÌfÐVÐVÑ WÔ WÐ WØ55555øøøøð øøøs AA
|
Á
|
|
BÁ'BÂBN)r )r7 )rH )Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r* r r r r r Úboolr/ Úintr r6 r? rB rF rK rO rQ © r r r r s Ø Ð ð:ð :ð :ð 1¨Cð 1°Cð 1ð 1ð 1ð 1ð6¨Cð 6°Cð 6ð 6ð 6ð 6ð8¨cð 8°cð 8ð 8ð 8ð 8ð¨ð ¸DÀÀcÀ¼Nð Ètð ð ð ð ð" ./ðð Ø ðØ'*ðà $sCx.Ô !ðð ð ð ð: 8;ðð Ø ðØ&*ðØ14ðà ðð ð ð ð0 sð ¨tð ð ð ð ð¨Sð °X¸c´]ð ð ð ð ð @Eð ð Ø ð Ø/2ð Ø9<ð à ð ð ð ð ð ¨#ð °#ð ð ð ð ð ¨#ð °$ð ð ð ð ð ð r r ) rU r$ Útypingr r r r Úlogurur Úconfigr r Ú redis_queuerX r r ú<module>r] sª ððð ð Ø &Ð &Ð &Ð &Ð &Ð &Ð &Ð &Ð &Ð &Ø Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð ðLð Lð Lð Lð Lñ Lô Lð Lð` Ð Ñ!Ô! r
|
