Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from decouple import config
- import logging
- from binance_f import SubscriptionClient
- from binance_f.constant.test import *
- from binance_f.model import *
- from binance_f.exception.binanceapiexception import BinanceApiException
- from binance_f.base.printobject import *
- BINANCE_FUTURES_API_KEY = config('BINANCE_FUTURES_API_KEY')
- BINANCE_FUTURES_SECRET_KEY = config('BINANCE_FUTURES_SECRET_KEY')
- logger = logging.getLogger("binance-futures")
- logger.setLevel(level=logging.INFO)
- handler = logging.StreamHandler()
- handler.setFormatter(logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s'))
- logger.addHandler(handler)
- sub_client = SubscriptionClient(api_key=BINANCE_FUTURES_API_KEY, secret_key=BINANCE_FUTURES_SECRET_KEY)
- def callback(data_type: 'SubscribeMessageType', event: 'any'):
- if data_type == SubscribeMessageType.RESPONSE:
- print("Event ID: ", event)
- elif data_type == SubscribeMessageType.PAYLOAD:
- print("Event type: ", event.eventType)
- print("Event time: ", event.eventTime)
- print("Symbol: ", event.symbol)
- print("Data:")
- PrintBasic.print_obj(event.data)
- #sub_client.unsubscribe_all()
- else:
- print("Unknown Data:")
- print()
- def error(e: 'BinanceApiException'):
- print(e.error_code + e.error_message)
- sub_client.subscribe_candlestick_event("btcusdt", CandlestickInterval.MIN1, callback, error)
- while True:
- pass
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement