|
alice_bob (OP)
|
 |
June 04, 2019, 01:42:03 PM
Last edit: January 27, 2022, 01:23:57 PM by alice_bob |
|
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-apiimport 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)
# 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 |
