91av视频/亚洲h视频/操亚洲美女/外国一级黄色毛片 - 国产三级三级三级三级

  • 大小: 2KB
    文件類型: .rar
    金幣: 2
    下載: 0 次
    發(fā)布日期: 2021-06-14
  • 語(yǔ)言: Python
  • 標(biāo)簽: Python??wind??

資源簡(jiǎn)介

演示wsq實(shí)時(shí)行情訂閱的使用,訂閱模式主要有兩部分組成,一部分是用wsq函數(shù)訂閱所需要的行情, 另一部分是編寫(xiě)自己的回調(diào)函數(shù),用于處理實(shí)時(shí)推送過(guò)來(lái)的行情數(shù)據(jù)

資源截圖

代碼片段和文件信息

#?coding:?UTF-8
#?說(shuō)明:
#?該案例是演示wsq實(shí)時(shí)行情訂閱的使用,訂閱模式主要有兩部分組成,一部分是用wsq函數(shù)訂閱所需要的行情,
#?另一部分是編寫(xiě)自己的回調(diào)函數(shù),用于處理實(shí)時(shí)推送過(guò)來(lái)的行情數(shù)據(jù)
#?myCallback(indata)?即為本案例所使用的回調(diào)函數(shù),回調(diào)函數(shù)有且只能有一個(gè)參數(shù):indata
#?indata的數(shù)據(jù)結(jié)構(gòu)如下:
#?indata.ErrorCode?錯(cuò)誤碼,如果為0表示運(yùn)行正常
#?indata.StateCode?狀態(tài)字段,使用時(shí)無(wú)需處理
#?indata.RequestID?存放對(duì)應(yīng)wsq請(qǐng)求的RequestID
#?indata.Codes?存放行情對(duì)應(yīng)的code
#?indata.Fields?存放行情數(shù)據(jù)對(duì)應(yīng)的指標(biāo)
#?indata.Times?存放本地時(shí)間,注意這個(gè)不是行情對(duì)應(yīng)的時(shí)間,要獲取行情對(duì)應(yīng)的時(shí)間,請(qǐng)訂閱rt_time指標(biāo)
#?indata.Data?存放行情數(shù)據(jù)

#?取消訂閱可使用w.cancelRequest(requestID)如果想取消全部訂閱,可使用w.cancelRequest(0)

#例如:
#?indata.ErrorCode=0
#?indata.StateCode=1
#?indata.RequestID=3
#?indata.Codes=[IF.CFE]
#?indata.Fields=[RT_LAST]
#?indata.Times=[20151123?15:12:40]
#?indata.Data=[[3623.0]]


from?WindPy?import?*
w.start();

#open?a?file?to?write.
pf?=?open(‘c:\\pywsqdataif.data‘?‘w‘)

#define?the?callback?function
#用于處理行情的回調(diào)函數(shù)
def?myCallback(indata):
????print?indata
????if?indata.ErrorCode!=0:
????????print(‘error?code:‘+str(indata.ErrorCode)+‘\n‘);
????????return();

????global?begintime
????lastvalue?=““;
????for?k?in?range(0len(indata.Fields)):
?????????if(indata.Fields[k]?==?“RT_TIME“):
????????????begintime?=?indata.Data[k][0];
?????????if(indata.Fields[k]?==?“RT_LAST“):
????????????lastvalue?=?str(indata.Data[k][0]);

????string?=?str(begintime)?+?“?“?+?lastvalue?+“\n“;
????pf.writelines(string)
????print(string);
????pf.flush();

????#想要結(jié)束訂閱,可使用w.cancelRequest(0)命令,然后后調(diào)用pf.close()關(guān)閉文件
????#pf.close();


#訂閱行情
w.wsq(“IF.CFE““rt_timert_last“func=myCallback)
while(1):
????info=“這個(gè)while循環(huán)主要是防止IDE在運(yùn)行或者debug時(shí),運(yùn)行w.wsq()語(yǔ)句后就退出,從而導(dǎo)致行情推送過(guò)來(lái)后,回調(diào)函數(shù)無(wú)法運(yùn)行!“;

?屬性????????????大小?????日期????時(shí)間???名稱
-----------?---------??----------?-----??----

?????文件???????2237??2015-11-23?17:32??Python?WSQ行情訂閱演示案例\wsqsave.py

?????文件????????937??2015-11-23?17:33??Python?WSQ行情訂閱演示案例\程序說(shuō)明.txt

?????目錄??????????0??2015-11-23?17:30??Python?WSQ行情訂閱演示案例

-----------?---------??----------?-----??----

?????????????????3174????????????????????3


評(píng)論

共有 條評(píng)論