Back to Ccxt

-*- coding: utf-8 -*-

wiki/examples/py/async-theocean-orderbook.md

4.5.65681 B
Original Source
python
# -*- coding: utf-8 -*-

import asyncio
from importlib import import_module
from importlib.util import find_spec

run = import_module(next(filter(find_spec, ('uvloop', 'winloop', 'asyncio')))).run
import os
import sys

if not sys.version >= '3.6':
    print('This script requires Python 3.6+')
    sys.exit()


import ccxt.async_support as ccxt  # noqa: E402


async def poll():
    exchange = ccxt.theocean()
    while True:
        yield await exchange.fetch_order_book('WETH/TUSD')
        await asyncio.sleep(exchange.rateLimit / 1000)


async def main():
    async for orderbook in poll():
        print(orderbook['bids'][0], orderbook['asks'][0])


run(main())