B
|
_NfW
|
ã @ sz d Z ddlZddlmZ dZdZeefddZdd Zd
|
d Zd d Z dd Z
|
dd Z dd Z dd Z dd Zdd ZdS )u#
|
ä¸ä¸é´æå¡å¨çéä¿¡åè®®
|
é N)Ú socket_utilz 43.138.167.68i' c C s t | tkrt| } t t | ¡ d¡¡}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ÚsendallZ recv_dataÚloadsÚ ExceptionÚgetÚclose)Ú data_jsonÚhostÚportZ
|
data_bytesÚskZ
|
result_strZ
|
header_strZ result_json© r õ; D:\éåä½å¸\low_suction_hx\trade\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 Zcmds)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, c C s d| |dd}|S )NZsimulation_trade)r r )r r r )r r r r r r Úload_simulation_tradeM s r- )Ú__doc__r Úutilsr Z SERVER_HOSTZ SERVER_PORTr r r r r$ r( r* r+ r, r- r r r r Ú<module> s
|
