ritmex-bot/docs/ccxt/examples/ccxt.pro/py/watch-custom-exchange-specific-streams.py

import asyncio
import ccxt.pro


class MyBinance(ccxt.pro.binance):

    def handle_mini_ticker(self, client, message):
        market_id = self.safe_string_lower(message, 's')
        message_hash = market_id + '@miniTicker'
        client.resolve(message, message_hash)

    def handle_message(self, client, message):
        handlers = {
            '24hrMiniTicker': self.handle_mini_ticker,
            # add other custom handlers here
        }
        e = self.safe_string(message, 'e')
        method = self.safe_value(handlers, e)
        if method:
            return method(client, message)
        else:
            return super(MyBinance, self).handle_message(client, message)


async def main():
    exchange = MyBinance({
        'enableRateLimit': False,
        'options': {
            'defaultType': 'future'
        }
    })
    await exchange.load_markets()
    # exchange.verbose = True  # uncomment for debugging purposes
    market = exchange.market('BTC/USDT')
    message_hash = market['lowercaseId'] + '@miniTicker'
    while True:
        try:
            print(await exchange.watch_public(message_hash))
        except Exception as e:
            print(type(e).__name__, str(e))
    await exchange.close()


if __name__ == '__main__':
    asyncio.run(main())