Binance Watch Spot Futures Balances Continuously

# -*- coding: utf-8 -*-

from asyncio import run, gather
import os
import sys


import ccxt.pro  # noqa: E402


print('CCXT Version:', ccxt.__version__)


async def print_balance_continuously(exchange):
   while True:
       try:
           print('-----------------------------------------------------------')
           await exchange.load_markets()
           balance = await exchange.watch_balance()
           print(exchange.iso8601(exchange.milliseconds()), exchange.id)
           for currency, value in balance['total'].items():
               print(value, currency)
       except Exception as e:
           print('-----------------------------------------------------------')
           print(exchange.iso8601(exchange.milliseconds()), exchange.id, type(e), e)
           await exchange.sleep(300000)  # sleep 5 minutes and retry


async def main():
   config = {
       'apiKey': 'YOUR_API_KEY',
       'secret': 'YOUR_SECRET',
   }
   exchange_ids = [
       'binance',
       'binanceusdm',
       'binancecoinm',
   ]
   exchanges = [getattr(ccxt.pro, exchange_id)(config) for exchange_id in exchange_ids]
   printing_loops = [print_balance_continuously(exchange) for exchange in exchanges]
   await gather(*printing_loops)
   closing_tasks = [exchange.close() for exchange in exchanges]
   await gather(*closing_tasks)


run(main())