async def connected_callback(self):
    '网络链接成功回调\n        '
    for sym in self._symbols:
        if (self.cb.on_trade_update_callback != None):
            (await self.send_json({'op': 'subscribe', 'channel': 'trades', 'market': sym}))
        if (self.cb.on_orderbook_update_callback != None):
            (await self.send_json({'op': 'subscribe', 'channel': 'orderbook', 'market': sym}))
        if (self.cb.on_ticker_update_callback != None):
            (await self.send_json({'op': 'subscribe', 'channel': 'ticker', 'market': sym}))
        if (self.cb.on_kline_update_callback != None):
            LoopRunTask.register(self._kline_loop_query, 60, sym)
网络链接成功回调
async def connected_callback(self):
    '\n        '
    for sym in self._symbols:
        if (self.cb.on_trade_update_callback != None):
            (await self.send_json({'op': 'subscribe', 'channel': 'trades', 'market': sym}))
        if (self.cb.on_orderbook_update_callback != None):
            (await self.send_json({'op': 'subscribe', 'channel': 'orderbook', 'market': sym}))
        if (self.cb.on_ticker_update_callback != None):
            (await self.send_json({'op': 'subscribe', 'channel': 'ticker', 'market': sym}))
        if (self.cb.on_kline_update_callback != None):
            LoopRunTask.register(self._kline_loop_query, 60, sym)