ton77v/example.py

## example.py
import asyncio
from cryptofeed import FeedHandler
from cryptofeed.defines import L2_BOOK
from cryptofeed.exchanges import Binance, Huobi


def add_feed_test():
    # following example from https://github.com/bmoscon/cryptofeed/blob/master/examples/demo_loop.py
    async def orderbook_watch(book, receipt_timestamp):
        print(f'{receipt_timestamp}: {book.exchange} - {book.symbol}, {len(book.book)} entries')

    def stop():
        loop.stop()

    loop = asyncio.get_event_loop()
    book_cb = {L2_BOOK: orderbook_watch}
    ticker_code = 'USDC-USDT'
    conf = {'log': {'filename': 'cryptofeed.log', 'level': 'DEBUG', 'disabled': False}}
    f = FeedHandler(config=conf)
    f.run(start_loop=False)
    f.add_feed(Binance(symbols=[ticker_code], channels=[L2_BOOK], callbacks=book_cb), loop=loop)
    loop.call_later(3, stop)
    loop.run_forever()
    f.stop(loop=loop)
	import asyncio
	from cryptofeed import FeedHandler
	from cryptofeed.defines import L2_BOOK
	from cryptofeed.exchanges import Binance, Huobi


	def add_feed_test():
	# following example from https://github.com/bmoscon/cryptofeed/blob/master/examples/demo_loop.py
	async def orderbook_watch(book, receipt_timestamp):
	print(f'{receipt_timestamp}: {book.exchange} - {book.symbol}, {len(book.book)} entries')

	def stop():
	loop.stop()

	loop = asyncio.get_event_loop()
	book_cb = {L2_BOOK: orderbook_watch}
	ticker_code = 'USDC-USDT'
	conf = {'log': {'filename': 'cryptofeed.log', 'level': 'DEBUG', 'disabled': False}}
	f = FeedHandler(config=conf)
	f.run(start_loop=False)
	f.add_feed(Binance(symbols=[ticker_code], channels=[L2_BOOK], callbacks=book_cb), loop=loop)
	loop.call_later(3, stop)
	loop.run_forever()
	f.stop(loop=loop)