透過設定回呼函式,在斷線時觸發重新訂閱設定的行情。
import time
ls=['TXF'] #設定股票列表清單,若斷線後重新訂閱此清單中的股票行情
def quote_event(event: kgi.Event):
display(event)
if event.event_code == kgi.Event.event_code.DISCONNECTED:
display('連線中斷,嘗試重新訂閱行情')
for sym in ls:
api.Quote.subscribe_tick(sym)
time.sleep(5)
api.FutQuote.set_cb_event(quote_event)
連線中斷,嘗試重新訂閱行情
event:回調事件,當訂閲的事件更新時將被呼叫。回調事件需要定義一個接收事件的參數,該參數會在行情事件更新時傳遞給函數。
此方法不直接返回值,而是在訂閲行情後,根據event的編制邏輯,當有相關事件更新時執行回調事件,從而實現即時行情事件處理和反應。