B
|
j9ýeE ã @ sl d Z ddlZddlmZ dZdZdd Zdd Zd
|
d Zd d Z dd Z
|
dd Z dd Z dd Z dd ZdS )u#
|
ä¸ä¸é´æå¡å¨çéä¿¡åè®®
|
é N)Ú socket_utilz 43.138.167.68iP2 c C s t | tkrt| } t t | ¡ d¡¡}t t t
|
¡}zD| |¡ t |¡\}}t |¡}|d dkrrt|d | d¡S | ¡ X d S )Nzutf-8Úcoder ÚmsgÚdata)ÚtypeÚsetÚlistr Ú load_headerÚjsonÚdumpsÚencodeÚ create_socketÚ SERVER_HOSTÚ SERVER_PORTÚsendallÚ recv_dataÚloadsÚ ExceptionÚgetÚclose)Ú data_jsonÚ
|
data_bytesÚskZ
|
result_strÚ
|
header_strÚ result_json© r ú4D:\workspace\trade_sell\utils\middle_api_protocol.pyÚrequest s
|
|
|
r c C s dd| dd}|S )NÚredisÚcmd)Úctyper )r r r )r Úfdatar r r Úload_redis_cmd s r" c C s dd| dd}|S )Nr Úcmds)r r )r r r )Údatasr! r r r Úload_redis_cmds" s r% c C s dd| dd}|S )NÚmysqlr )r r )r r r )r r! r r r Úload_mysql_cmd( s r' c C s dd| |ddd}|S )NÚjuejin)ÚpathÚparams)r r )r r r )Zpath_r r! r r r Ú load_juejin/ s r+ c C s dd| ||ddd}|S )NÚkpl)Úurlr Útimeout)r r )r r r )r- r r. r! r r r Úload_kpl5 s r/ c C s ddd| idd}|S )NÚkp_msgr )r r )r r r )r r! r r r Ú load_kp_msg; s r1 c C s dd| dd}|S )NZl2_subscript_codes)r r )r r r )r$ r! r r r Úload_l2_subscript_codesA s r2 c C s dd| dd}|S )NZpush_msg)r r )r r r )r r! r r r Ú load_push_msgG s r3 )Ú__doc__r
|
Úutilsr r r r r" r% r' r+ r/ r1 r2 r3 r r r r Ú<module> s
|
