UNICORN Binance Suite:
- unicorn-fy
- unicorn-binance-local-depth-cache
- unicorn-binance-rest-api
- unicorn-binance-trailing-stop-loss
- unicorn-binance-websocket-api
Topic: Python API "UNICORN Binance WebSocket API" (Read 192 times)
Endpoints for binance.com futures are now implemented:
https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/blob/master/example_binance_futures.py
https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/blob/master/example_binance_futures.py
Added support for binance.us Websockets:
https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/blob/master/example_binance_us.py
https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/blob/master/example_binance_us.py
Added support for Binance DEX and Binance DEX testnet:
https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/blob/master/example_binance_dex.py
https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/blob/master/example_binance_dex.py
We added support for Binance Jersey!
Code:
ubwa = unicorn_binance_websocket_api.BinanceWebSocketApiManager(exchange="binance.je")
Hello!
I would like to introduce a python API to manage websockets to binance!
Project: https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api
# What are the benefits of the UNICORN Binance WebSocket API?
Best regards,
Oliver
I would like to introduce a python API to manage websockets to binance!
Project: https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api
Code:
import unicorn_binance_websocket_api
ubwa = unicorn_binance_websocket_api.BinanceWebSocketApiManager(exchange="binance.com")
ubwa.create_stream(['trade', 'kline_1m'], ['btcusdt', 'bnbbtc', 'ethbtc'])
while True:
oldest_data_from_stream_buffer = ubwa.pop_stream_data_from_stream_buffer()
if oldest_data_from_stream_buffer:
print(oldest_data_from_stream_buffer)
ubwa = unicorn_binance_websocket_api.BinanceWebSocketApiManager(exchange="binance.com")
ubwa.create_stream(['trade', 'kline_1m'], ['btcusdt', 'bnbbtc', 'ethbtc'])
while True:
oldest_data_from_stream_buffer = ubwa.pop_stream_data_from_stream_buffer()
if oldest_data_from_stream_buffer:
print(oldest_data_from_stream_buffer)
# What are the benefits of the UNICORN Binance WebSocket API?
- Fully managed websockets and 100% auto-reconnect! Also handles maintenance windows!
- Streams are processing asynchronous/concurrent (Python asyncio) and each stream is started in a separate thread, so you dont need to deal with asyncio in your code!
- No use of the twisted module, so you can use this lib in a daemonized application (compatible with python-daemon).
- Supports subscribe/unsubscribe on all exchanges! (Take a look to the max supported subscriptions per stream in the endpoint configuration overview!)
- UNICORN Binance WebSocket API respects Binance's API guidelines and protects you from avoidable reconnects and bans.
- Support for multiple private !userData streams with different api_key and api_secret. (example_multiple_userdata_streams.py)
- Pick up the received data from the stream_buffer - if you can not store your data in cause of a temporary technical issue, you can kick back the data to the stream_buffer which stores the receives in the RAM till you are able to process the data in the normal way again. Learn more!
- Use separate stream_buffers for specific streams or users!
- Watch the stream_signal_buffer to receive CONNECT, DISCONNECT and FIRST_RECEIVED_DATA signals about the streams! Learn more!
- Get the received data unchanged as received, as Python dictionary or converted with UnicornFy into well-formed Python dictionaries. Use the output parameter of create_stream() to control the output format.
- Helpful management features like get_binance_api_status(), get_current_receiving_speed(), get_errors_from_endpoints(), get_limit_of_subscriptions_per_stream(), get_request_id(), get_result_by_request_id(), get_results_from_endpoints(), get_stream_buffer_length(), get_stream_info(), get_stream_list(), get_stream_id_by_label(), get_stream_statistic(), get_stream_subscriptions(), get_version(), is_update_availabe(), pop_stream_data_from_stream_buffer(), print_summary(), replace_stream(), set_stream_label(), set_ringbuffer_error_max_size(), subscribe_to_stream(), stop_stream(), stop_manager_with_all_streams(), unsubscribe_from_stream(), wait_till_stream_has_started() and many more! Explore them here.
- Monitor the status of the created BinanceWebSocketApiManager() instance within your code with get_monitoring_status_plain() and specific streams with get_stream_info().
- Nice to use with iPython: "IPython (Interactive Python) is a command shell for interactive computing that offers introspection, rich media, shell syntax, tab completion, and history." (example_interactive_mode.py) iPython
- Also nice to use with the Jupyter Notebook
- Monitoring API service and a check_command for ICINGA/Nagios icinga2-demo
- Excessively tested on Linux, Mac and Windows
Best regards,
Oliver
Jump to: