watch_order_book error with Binance : Connection closed by remote server, closing code 1008

@YuriyTigiev try adding more pairs to it to see where it breaks. Then add the database connector. Make sure you use an async connector, for example: https://aioinflux.readthedocs.io/en/stable/

Please find below a reproducible example.

When 4 markets are monitored it throws a RuntimeError : This event loop is already running then returns data, but when 5 markets are monitored it throws the RuntimeError with no data. That is the problem

Now, when I replace break with continue my IP address get banned by the remote host (happened yesterday) so I don’t think it’s a workaround.

Thanks for your support, Kinzowa

import ccxtpro
import asyncio

async def watch_book(client, symbol):

    while True:
        try:
            ob = await client.watch_order_book(symbol)
            print(ob['asks'][0][0])
        
            await client.sleep(1000)
            
        except Exception as e:
            print('error {0}'.format(symbol), str(e))
            break
            
async def markets_loop(loop):

    client = getattr(ccxtpro, 'binance')({'enableRateLimit': True, 'asyncio_loop': loop, })
    client.options['defaultType'] = 'spot'

    symbols = ['DOT/BUSD',
              'FTM/BUSD',
              # 'FTM/USDT',    #  <- REMOVE TO MONITOR 5 MARKETS INSTEAD OF 4
              'SOL/USDT',
              'DOT/USDT']

    ws_loops = [watch_book(client, symbol) for symbol in symbols]

    await asyncio.gather(*ws_loops)
    await client.close()
        
loop = asyncio.get_event_loop()
gp = asyncio.wait([markets_loop(loop)])
loop.run_until_complete(gp)
loop.close()