B
|
âJf` ã @ 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 Z load_headerÚjsonÚdumpsÚencodeZ create_socketÚ SERVER_HOSTÚ SERVER_PORTÚsendallZ recv_dataÚloadsÚ ExceptionÚgetÚclose)Ú data_jsonZ
|
data_bytesÚskZ
|
result_strÚ
|
header_strZ result_json© r ú2D:\workspace\trade_cb\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 r, c C s dd| dd}|S )NZl2_position_subscript_codes)r r )r r r )r r r r r Ú load_l2_position_subscript_codesA s r- c C s dd| dd}|S )NZpush_msg)r r )r r r )r r r r r Ú load_push_msgG s r. )Ú__doc__r Úutilsr r r r r r r" r& r* r, r- r. r r r r Ú<module> s
|
