Open progressivehed opened 2 years ago
import asyncio from kucoin_futures.client import WsToken from kucoin_futures.ws_client import KucoinFuturesWsClient
async def main(): async def deal_msg(msg): if msg['topic'] == '/contractMarket/level2:XBTUSDM': print(f'Get XBTUSDM Ticker:{msg["data"]}')
# is public client = WsToken(is_sandbox=True) ws_client = await KucoinFuturesWsClient.create(loop, client, deal_msg, private=False) await ws_client.subscribe('/contractMarket/level2:XBTUSDM') while True: await asyncio.sleep(60)
if name == "main": loop = asyncio.get_event_loop() loop.run_until_complete(main())
Example update for deprectaing endpoint
import asyncio from kucoin_futures.client import WsToken from kucoin_futures.ws_client import KucoinFuturesWsClient
async def main(): async def deal_msg(msg): if msg['topic'] == '/contractMarket/level2:XBTUSDM': print(f'Get XBTUSDM Ticker:{msg["data"]}')
if name == "main": loop = asyncio.get_event_loop() loop.run_until_complete(main())