search

LUCIT-Systems-and-Development / unicorn-binance-websocket-api

A Python SDK by LUCIT to use the Binance Websocket API`s (com+testnet, com-margin+testnet, com-isolated_margin+testnet, com-futures+testnet, com-coin_futures, us, tr, dex/chain+testnet) in a simple, fast, flexible, robust and fully-featured way.
https://unicorn-binance-websocket-api.docs.lucit.tech/
Other
677 stars 166 forks source link

No data coming after replace_stream #287

Closed dima-dmytruk23 closed 1 year ago

dima-dmytruk23 commented 1 year ago

Version of this library.

1.47.0

Solution to Issue cannot be found in the documentation or other Issues and also occurs in the latest version of this library.

Hardware?

VPS or other cloud hosting

Operating System?

Linux

Python version?

Python3.9

Installed packages

No response

Logging output

2022-08-12 19:42:40
stdout
TOGGLE1
2022-08-12 19:42:40
stdout
toggle_websockets start first
2022-08-12 19:42:40
stderr
INFO | 1 | 140005731338048 | manager | manager.py:1288 | BinanceWebSocketApiManager.create_stream(('arr',), ['!userData'], None, False, False) with stream_id=77f51b5f0433-f665-21c6-d329-b902879f
2022-08-12 19:42:40
stderr
INFO | 1 | 140005731338048 | manager | manager.py:478 | BinanceWebSocketApiManager._add_stream_to_stream_list(77f51b5f0433-f665-21c6-d329-b902879f, ('arr',), ['!userData'], None, False, None, False)
2022-08-12 19:42:40
stderr
INFO | 1 | 140005638682368 | sockets | sockets.py:64 | BinanceWebSocketApiSocket.start_socket(77f51b5f0433-f665-21c6-d329-b902879f, ('arr',), ['!userData']) socket_id=5b374f95-5a72-4a2f-811b-3eb9883d9d0a recent_socket_id=5b374f95-5a72-4a2f-811b-3eb9883d9d0a
2022-08-12 19:42:40
stderr
ERROR | 1 | 140005638682368 | connection | connection.py:71 | BinanceWebSocketApiConnection.receive(77f51b5f0433-f665-21c6-d329-b902879f) socket_id=5b374f95-5a72-4a2f-811b-3eb9883d9d0a) - Adding timeout to `websocket.recv()`
2022-08-12 19:42:40
stderr
INFO | 1 | 140005638682368 | restclient | restclient.py:270 | BinanceWebSocketApiRestclient.get_listen_key() symbol='False' stream_id='77f51b5f0433-f665-21c6-d329-b902879f')
2022-08-12 19:42:40
stderr
INFO | 1 | 140005638682368 | manager | manager.py:1401 | BinanceWebSocketApiManager.create_websocket_uri(('arr',), ['!userData'], False) - result: wss://fstream.binance.com/ws/****
2022-08-12 19:42:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:3567 | BinanceWebSocketApiManager.stop_stream(d60444a02d11-9b58-2d90-7b40-e23702ea)
2022-08-12 19:42:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(d60444a02d11-9b58-2d90-7b40-e23702ea)
2022-08-12 19:42:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:1529 | BinanceWebSocketApiManager.delete_listen_key_by_stream_id(d60444a02d11-9b58-2d90-7b40-e23702ea)
2022-08-12 19:42:42
stderr
INFO | 1 | 140005731338048 | restclient | restclient.py:324 | BinanceWebSocketApiRestclient.delete_listen_key() stream_id='d60444a02d11-9b58-2d90-7b40-e23702ea')
2022-08-12 19:42:42
stderr
INFO | 1 | 140005731338048 | restclient | restclient.py:123 | BinanceWebSocketApiRestclient.delete_listen_key(****)
2022-08-12 19:42:42
stdout
stream='77f51b5f0433-f665-21c6-d329-b902879f'
2022-08-12 19:42:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:1288 | BinanceWebSocketApiManager.create_stream(('arr',), ['!userData'], None, False, False) with stream_id=ea7ec0a64491-2734-039a-9dec-bf0722a2
2022-08-12 19:42:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:478 | BinanceWebSocketApiManager._add_stream_to_stream_list(ea7ec0a64491-2734-039a-9dec-bf0722a2, ('arr',), ['!userData'], None, False, None, False)
2022-08-12 19:42:42
stderr
INFO | 1 | 140002713401088 | sockets | sockets.py:64 | BinanceWebSocketApiSocket.start_socket(ea7ec0a64491-2734-039a-9dec-bf0722a2, ('arr',), ['!userData']) socket_id=8cfa8f6b-5bec-4904-a47c-44d58a9caf29 recent_socket_id=8cfa8f6b-5bec-4904-a47c-44d58a9caf29
2022-08-12 19:42:42
stderr
ERROR | 1 | 140002713401088 | connection | connection.py:71 | BinanceWebSocketApiConnection.receive(ea7ec0a64491-2734-039a-9dec-bf0722a2) socket_id=8cfa8f6b-5bec-4904-a47c-44d58a9caf29) - Adding timeout to `websocket.recv()`
2022-08-12 19:42:42
stderr
INFO | 1 | 140002713401088 | restclient | restclient.py:270 | BinanceWebSocketApiRestclient.get_listen_key() symbol='False' stream_id='ea7ec0a64491-2734-039a-9dec-bf0722a2')
2022-08-12 19:42:42
stderr
INFO | 1 | 140004298835712 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(d60444a02d11-9b58-2d90-7b40-e23702ea)
2022-08-12 19:42:42
stderr
INFO | 1 | 140004298835712 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(d60444a02d11-9b58-2d90-7b40-e23702ea)
2022-08-12 19:42:42
stderr
INFO | 1 | 140004298835712 | connection | connection.py:266 | BinanceWebSocketApiConnection.close(d60444a02d11-9b58-2d90-7b40-e23702ea)
2022-08-12 19:42:43
stderr
INFO | 1 | 140002713401088 | manager | manager.py:1401 | BinanceWebSocketApiManager.create_websocket_uri(('arr',), ['!userData'], False) - result: wss://fstream.binance.com/ws/****
2022-08-12 19:42:43
stderr
INFO | 1 | 140005397755648 | manager | manager.py:673 | BinanceWebSocketApiManager._frequent_checks() - reached new `highest_receiving_speed` 188 B/s at 2022-08-12, 15:42:43 UTC
2022-08-12 19:42:43
stderr
INFO | 1 | 140005355792128 | manager | manager.py:673 | BinanceWebSocketApiManager._frequent_checks() - reached new `highest_receiving_speed` 188 B/s at 2022-08-12, 15:42:43 UTC
2022-08-12 19:42:43
stderr
INFO | 1 | 140004290443008 | manager | manager.py:673 | BinanceWebSocketApiManager._frequent_checks() - reached new `highest_receiving_speed` 282 B/s at 2022-08-12, 15:42:43 UTC
2022-08-12 19:42:43
stderr
INFO | 1 | 140003778750208 | manager | manager.py:673 | BinanceWebSocketApiManager._frequent_checks() - reached new `highest_receiving_speed` 188 B/s at 2022-08-12, 15:42:43 UTC
2022-08-12 19:42:44
stderr
INFO | 1 | 140005731338048 | manager | manager.py:3567 | BinanceWebSocketApiManager.stop_stream(8330ee87d33f-85ea-aec9-a526-4ef43b55)
2022-08-12 19:42:44
stderr
INFO | 1 | 140005731338048 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(8330ee87d33f-85ea-aec9-a526-4ef43b55)
2022-08-12 19:42:44
stderr
INFO | 1 | 140005731338048 | manager | manager.py:1529 | BinanceWebSocketApiManager.delete_listen_key_by_stream_id(8330ee87d33f-85ea-aec9-a526-4ef43b55)
2022-08-12 19:42:44
stderr
INFO | 1 | 140005731338048 | restclient | restclient.py:324 | BinanceWebSocketApiRestclient.delete_listen_key() stream_id='8330ee87d33f-85ea-aec9-a526-4ef43b55')
2022-08-12 19:42:44
stderr
INFO | 1 | 140005731338048 | restclient | restclient.py:123 | BinanceWebSocketApiRestclient.delete_listen_key(****)
2022-08-12 19:42:45
stdout
stream='ea7ec0a64491-2734-039a-9dec-bf0722a2'
2022-08-12 19:42:45
stdout
toggle_websockets end, 4.514845 sec
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318962671}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140004298835712)>, websocket[0].stream_list={'d60444a02d11-9b58-2d90-7b40-e23702ea': {'exchange': 'binance.com-futures', 'stream_id': 'd60444a02d11-9b58-2d90-7b40-e23702ea', 'recent_socket_id': UUID('c8f7356f-66ee-416c-a0bf-d9416448d978'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317460.9913564, 'processed_receives_total': 1, 'receives_statistic_last_second': {'most_receives_per_second': 0, 'entries': {1660318962: 1}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318962.3176556, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660318962.8096254, 'reconnects': 0, 'last_stream_signal': 'DISCONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962671}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 94}, 'speed': 94}}, '77f51b5f0433-f665-21c6-d329-b902879f': {'exchange': 'binance.com-futures', 'stream_id': '77f51b5f0433-f665-21c6-d329-b902879f', 'recent_socket_id': UUID('5b374f95-5a72-4a2f-811b-3eb9883d9d0a'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660318960.532609, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 2, 'entries': {1660318962: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318964.8116298, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962672}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 188}, 'speed': 188}}}, websocket[1]='77f51b5f0433-f665-21c6-d329-b902879f'
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318962671}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003787142912)>, websocket[0].stream_list={'295531d5a03b-41b3-83e1-b1e1-d4f407b0': {'exchange': 'binance.com-futures', 'stream_id': '295531d5a03b-41b3-83e1-b1e1-d4f407b0', 'recent_socket_id': UUID('0348b5eb-5145-4268-abd4-48850d389176'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'running', 'start_time': 1660317462.9978752, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 2, 'entries': {1660318962: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318964.8112395, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962672}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 188}, 'speed': 188}}}, websocket[1]='295531d5a03b-41b3-83e1-b1e1-d4f407b0'
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318962671}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140004298835712)>, websocket[0].stream_list={'d60444a02d11-9b58-2d90-7b40-e23702ea': {'exchange': 'binance.com-futures', 'stream_id': 'd60444a02d11-9b58-2d90-7b40-e23702ea', 'recent_socket_id': UUID('c8f7356f-66ee-416c-a0bf-d9416448d978'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317460.9913564, 'processed_receives_total': 1, 'receives_statistic_last_second': {'most_receives_per_second': 0, 'entries': {1660318962: 1}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318962.3176556, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660318962.8096254, 'reconnects': 0, 'last_stream_signal': 'DISCONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962671}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 94}, 'speed': 94}}, '77f51b5f0433-f665-21c6-d329-b902879f': {'exchange': 'binance.com-futures', 'stream_id': '77f51b5f0433-f665-21c6-d329-b902879f', 'recent_socket_id': UUID('5b374f95-5a72-4a2f-811b-3eb9883d9d0a'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660318960.532609, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 2, 'entries': {1660318962: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318964.8116298, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962672}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 188}, 'speed': 188}}}, websocket[1]='77f51b5f0433-f665-21c6-d329-b902879f'
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318962672}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003787142912)>, websocket[0].stream_list={'295531d5a03b-41b3-83e1-b1e1-d4f407b0': {'exchange': 'binance.com-futures', 'stream_id': '295531d5a03b-41b3-83e1-b1e1-d4f407b0', 'recent_socket_id': UUID('0348b5eb-5145-4268-abd4-48850d389176'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'running', 'start_time': 1660317462.9978752, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 2, 'entries': {1660318962: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318964.8112395, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962672}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 188}, 'speed': 188}}}, websocket[1]='295531d5a03b-41b3-83e1-b1e1-d4f407b0'
2022-08-12 19:42:45
stderr
INFO | 1 | 140003736786688 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(8330ee87d33f-85ea-aec9-a526-4ef43b55)
2022-08-12 19:42:45
stderr
INFO | 1 | 140003736786688 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(8330ee87d33f-85ea-aec9-a526-4ef43b55)
2022-08-12 19:42:45
stderr
INFO | 1 | 140003736786688 | connection | connection.py:266 | BinanceWebSocketApiConnection.close(8330ee87d33f-85ea-aec9-a526-4ef43b55)
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318962672}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140004298835712)>, websocket[0].stream_list={'d60444a02d11-9b58-2d90-7b40-e23702ea': {'exchange': 'binance.com-futures', 'stream_id': 'd60444a02d11-9b58-2d90-7b40-e23702ea', 'recent_socket_id': UUID('c8f7356f-66ee-416c-a0bf-d9416448d978'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317460.9913564, 'processed_receives_total': 1, 'receives_statistic_last_second': {'most_receives_per_second': 0, 'entries': {1660318962: 1}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318962.3176556, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660318962.8096254, 'reconnects': 0, 'last_stream_signal': 'DISCONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962671}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 94}, 'speed': 94}}, '77f51b5f0433-f665-21c6-d329-b902879f': {'exchange': 'binance.com-futures', 'stream_id': '77f51b5f0433-f665-21c6-d329-b902879f', 'recent_socket_id': UUID('5b374f95-5a72-4a2f-811b-3eb9883d9d0a'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660318960.532609, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 2, 'entries': {1660318962: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318964.8116298, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962672}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 188}, 'speed': 188}}}, websocket[1]='77f51b5f0433-f665-21c6-d329-b902879f'
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318964938}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003753572096)>, websocket[0].stream_list={'8330ee87d33f-85ea-aec9-a526-4ef43b55': {'exchange': 'binance.com-futures', 'stream_id': '8330ee87d33f-85ea-aec9-a526-4ef43b55', 'recent_socket_id': UUID('7ea5ec12-bacf-4fc4-86f4-4923d53f261c'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317465.4766195, 'processed_receives_total': 8, 'receives_statistic_last_second': {'most_receives_per_second': 7, 'entries': {1660318374: 7, 1660318965: 1}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318963.372537, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660318965.0678093, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964938}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318374: 3041, 1660318965: 94}, 'speed': 3041}}, 'ea7ec0a64491-2734-039a-9dec-bf0722a2': {'exchange': 'binance.com-futures', 'stream_id': 'ea7ec0a64491-2734-039a-9dec-bf0722a2', 'recent_socket_id': UUID('8cfa8f6b-5bec-4904-a47c-44d58a9caf29'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660318962.7880065, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 0, 'entries': {1660318965: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318965.0664527, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964939}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318965: 188}, 'speed': 0}}}, websocket[1]='ea7ec0a64491-2734-039a-9dec-bf0722a2'
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318964938}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003241879296)>, websocket[0].stream_list={'60281898189e-2b90-601c-40a3-7ac428df': {'exchange': 'binance.com-futures', 'stream_id': '60281898189e-2b90-601c-40a3-7ac428df', 'recent_socket_id': UUID('3b417e26-87d4-4a55-b3bd-49e58aa92e11'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'running', 'start_time': 1660317467.4838889, 'processed_receives_total': 9, 'receives_statistic_last_second': {'most_receives_per_second': 7, 'entries': {1660318374: 7, 1660318965: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318965.0710588, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964939}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318374: 3041, 1660318965: 188}, 'speed': 3041}}}, websocket[1]='60281898189e-2b90-601c-40a3-7ac428df'
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318964939}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003753572096)>, websocket[0].stream_list={'8330ee87d33f-85ea-aec9-a526-4ef43b55': {'exchange': 'binance.com-futures', 'stream_id': '8330ee87d33f-85ea-aec9-a526-4ef43b55', 'recent_socket_id': UUID('7ea5ec12-bacf-4fc4-86f4-4923d53f261c'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317465.4766195, 'processed_receives_total': 8, 'receives_statistic_last_second': {'most_receives_per_second': 7, 'entries': {1660318374: 7, 1660318965: 1}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318963.372537, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660318965.0678093, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964938}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318374: 3041, 1660318965: 94}, 'speed': 3041}}, 'ea7ec0a64491-2734-039a-9dec-bf0722a2': {'exchange': 'binance.com-futures', 'stream_id': 'ea7ec0a64491-2734-039a-9dec-bf0722a2', 'recent_socket_id': UUID('8cfa8f6b-5bec-4904-a47c-44d58a9caf29'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660318962.7880065, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 0, 'entries': {1660318965: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318965.0664527, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964939}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318965: 188}, 'speed': 0}}}, websocket[1]='ea7ec0a64491-2734-039a-9dec-bf0722a2'
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318964939}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003241879296)>, websocket[0].stream_list={'60281898189e-2b90-601c-40a3-7ac428df': {'exchange': 'binance.com-futures', 'stream_id': '60281898189e-2b90-601c-40a3-7ac428df', 'recent_socket_id': UUID('3b417e26-87d4-4a55-b3bd-49e58aa92e11'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'running', 'start_time': 1660317467.4838889, 'processed_receives_total': 9, 'receives_statistic_last_second': {'most_receives_per_second': 7, 'entries': {1660318374: 7, 1660318965: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318965.0710588, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964939}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318374: 3041, 1660318965: 188}, 'speed': 3041}}}, websocket[1]='60281898189e-2b90-601c-40a3-7ac428df'
2022-08-12 19:42:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660318964938}
2022-08-12 19:42:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003753572096)>, websocket[0].stream_list={'8330ee87d33f-85ea-aec9-a526-4ef43b55': {'exchange': 'binance.com-futures', 'stream_id': '8330ee87d33f-85ea-aec9-a526-4ef43b55', 'recent_socket_id': UUID('7ea5ec12-bacf-4fc4-86f4-4923d53f261c'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317465.4766195, 'processed_receives_total': 8, 'receives_statistic_last_second': {'most_receives_per_second': 7, 'entries': {1660318374: 7, 1660318965: 1}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318963.372537, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660318965.0678093, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964938}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318374: 3041, 1660318965: 94}, 'speed': 3041}}, 'ea7ec0a64491-2734-039a-9dec-bf0722a2': {'exchange': 'binance.com-futures', 'stream_id': 'ea7ec0a64491-2734-039a-9dec-bf0722a2', 'recent_socket_id': UUID('8cfa8f6b-5bec-4904-a47c-44d58a9caf29'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660318962.7880065, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 0, 'entries': {1660318965: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660318965.0664527, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964939}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318965: 188}, 'speed': 0}}}, websocket[1]='ea7ec0a64491-2734-039a-9dec-bf0722a2'
2022-08-12 19:44:40
stdout
TOGGLE2
2022-08-12 19:44:40
stdout
toggle_websockets start second
2022-08-12 19:44:40
stderr
INFO | 1 | 140005731338048 | manager | manager.py:1288 | BinanceWebSocketApiManager.create_stream(('arr',), ['!userData'], None, False, False) with stream_id=c216f76232cb-1ad2-abf0-70b5-1eac2678
2022-08-12 19:44:40
stderr
INFO | 1 | 140005731338048 | manager | manager.py:478 | BinanceWebSocketApiManager._add_stream_to_stream_list(c216f76232cb-1ad2-abf0-70b5-1eac2678, ('arr',), ['!userData'], None, False, None, False)
2022-08-12 19:44:40
stderr
INFO | 1 | 140003736786688 | sockets | sockets.py:64 | BinanceWebSocketApiSocket.start_socket(c216f76232cb-1ad2-abf0-70b5-1eac2678, ('arr',), ['!userData']) socket_id=46fda9bc-72c9-4b8c-9c2d-780a894a88f4 recent_socket_id=46fda9bc-72c9-4b8c-9c2d-780a894a88f4
2022-08-12 19:44:40
stderr
ERROR | 1 | 140003736786688 | connection | connection.py:71 | BinanceWebSocketApiConnection.receive(c216f76232cb-1ad2-abf0-70b5-1eac2678) socket_id=46fda9bc-72c9-4b8c-9c2d-780a894a88f4) - Adding timeout to `websocket.recv()`
2022-08-12 19:44:40
stderr
INFO | 1 | 140003736786688 | restclient | restclient.py:270 | BinanceWebSocketApiRestclient.get_listen_key() symbol='False' stream_id='c216f76232cb-1ad2-abf0-70b5-1eac2678')
2022-08-12 19:44:40
stderr
INFO | 1 | 140003736786688 | manager | manager.py:1401 | BinanceWebSocketApiManager.create_websocket_uri(('arr',), ['!userData'], False) - result: wss://fstream.binance.com/ws/****
2022-08-12 19:44:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:3567 | BinanceWebSocketApiManager.stop_stream(295531d5a03b-41b3-83e1-b1e1-d4f407b0)
2022-08-12 19:44:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(295531d5a03b-41b3-83e1-b1e1-d4f407b0)
2022-08-12 19:44:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:1529 | BinanceWebSocketApiManager.delete_listen_key_by_stream_id(295531d5a03b-41b3-83e1-b1e1-d4f407b0)
2022-08-12 19:44:42
stderr
INFO | 1 | 140005731338048 | restclient | restclient.py:324 | BinanceWebSocketApiRestclient.delete_listen_key() stream_id='295531d5a03b-41b3-83e1-b1e1-d4f407b0')
2022-08-12 19:44:42
stderr
INFO | 1 | 140005731338048 | restclient | restclient.py:123 | BinanceWebSocketApiRestclient.delete_listen_key(****)
2022-08-12 19:44:42
stdout
stream='c216f76232cb-1ad2-abf0-70b5-1eac2678'
2022-08-12 19:44:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:1288 | BinanceWebSocketApiManager.create_stream(('arr',), ['!userData'], None, False, False) with stream_id=2a46eea82004-63ca-8a19-64eb-5032f9d1
2022-08-12 19:44:42
stderr
INFO | 1 | 140005731338048 | manager | manager.py:478 | BinanceWebSocketApiManager._add_stream_to_stream_list(2a46eea82004-63ca-8a19-64eb-5032f9d1, ('arr',), ['!userData'], None, False, None, False)
2022-08-12 19:44:42
stderr
INFO | 1 | 140004273657600 | sockets | sockets.py:64 | BinanceWebSocketApiSocket.start_socket(2a46eea82004-63ca-8a19-64eb-5032f9d1, ('arr',), ['!userData']) socket_id=23eea084-667b-4c64-9bd2-1b0e11234dae recent_socket_id=23eea084-667b-4c64-9bd2-1b0e11234dae
2022-08-12 19:44:42
stderr
ERROR | 1 | 140004273657600 | connection | connection.py:71 | BinanceWebSocketApiConnection.receive(2a46eea82004-63ca-8a19-64eb-5032f9d1) socket_id=23eea084-667b-4c64-9bd2-1b0e11234dae) - Adding timeout to `websocket.recv()`
2022-08-12 19:44:42
stderr
INFO | 1 | 140004273657600 | restclient | restclient.py:270 | BinanceWebSocketApiRestclient.get_listen_key() symbol='False' stream_id='2a46eea82004-63ca-8a19-64eb-5032f9d1')
2022-08-12 19:44:43
stderr
INFO | 1 | 140003770357504 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(295531d5a03b-41b3-83e1-b1e1-d4f407b0)
2022-08-12 19:44:43
stderr
INFO | 1 | 140003770357504 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(295531d5a03b-41b3-83e1-b1e1-d4f407b0)
2022-08-12 19:44:43
stderr
INFO | 1 | 140003770357504 | connection | connection.py:266 | BinanceWebSocketApiConnection.close(295531d5a03b-41b3-83e1-b1e1-d4f407b0)
2022-08-12 19:44:43
stderr
INFO | 1 | 140004273657600 | manager | manager.py:1401 | BinanceWebSocketApiManager.create_websocket_uri(('arr',), ['!userData'], False) - result: wss://fstream.binance.com/ws/****
2022-08-12 19:44:44
stderr
INFO | 1 | 140005731338048 | manager | manager.py:3567 | BinanceWebSocketApiManager.stop_stream(60281898189e-2b90-601c-40a3-7ac428df)
2022-08-12 19:44:44
stderr
INFO | 1 | 140005731338048 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(60281898189e-2b90-601c-40a3-7ac428df)
2022-08-12 19:44:44
stderr
INFO | 1 | 140005731338048 | manager | manager.py:1529 | BinanceWebSocketApiManager.delete_listen_key_by_stream_id(60281898189e-2b90-601c-40a3-7ac428df)
2022-08-12 19:44:44
stderr
INFO | 1 | 140005731338048 | restclient | restclient.py:324 | BinanceWebSocketApiRestclient.delete_listen_key() stream_id='60281898189e-2b90-601c-40a3-7ac428df')
2022-08-12 19:44:44
stderr
INFO | 1 | 140005731338048 | restclient | restclient.py:123 | BinanceWebSocketApiRestclient.delete_listen_key(****)
2022-08-12 19:44:45
stdout
stream='2a46eea82004-63ca-8a19-64eb-5032f9d1'
2022-08-12 19:44:45
stdout
toggle_websockets end, 4.502262 sec
2022-08-12 19:44:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660319082662}
2022-08-12 19:44:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003787142912)>, websocket[0].stream_list={'295531d5a03b-41b3-83e1-b1e1-d4f407b0': {'exchange': 'binance.com-futures', 'stream_id': '295531d5a03b-41b3-83e1-b1e1-d4f407b0', 'recent_socket_id': UUID('0348b5eb-5145-4268-abd4-48850d389176'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317462.9978752, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 2, 'entries': {1660318962: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660319080.9220092, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660319082.9238234, 'reconnects': 0, 'last_stream_signal': 'DISCONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962672}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 188}, 'speed': 188}}, 'c216f76232cb-1ad2-abf0-70b5-1eac2678': {'exchange': 'binance.com-futures', 'stream_id': 'c216f76232cb-1ad2-abf0-70b5-1eac2678', 'recent_socket_id': UUID('46fda9bc-72c9-4b8c-9c2d-780a894a88f4'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660319080.5274034, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 2, 'entries': {1660319082: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660319084.7993011, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660319082663}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660319082: 188}, 'speed': 188}}}, websocket[1]='c216f76232cb-1ad2-abf0-70b5-1eac2678'
2022-08-12 19:44:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660319082663}
2022-08-12 19:44:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003787142912)>, websocket[0].stream_list={'295531d5a03b-41b3-83e1-b1e1-d4f407b0': {'exchange': 'binance.com-futures', 'stream_id': '295531d5a03b-41b3-83e1-b1e1-d4f407b0', 'recent_socket_id': UUID('0348b5eb-5145-4268-abd4-48850d389176'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317462.9978752, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 2, 'entries': {1660318962: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660319080.9220092, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660319082.9238234, 'reconnects': 0, 'last_stream_signal': 'DISCONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318962672}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318962: 188}, 'speed': 188}}, 'c216f76232cb-1ad2-abf0-70b5-1eac2678': {'exchange': 'binance.com-futures', 'stream_id': 'c216f76232cb-1ad2-abf0-70b5-1eac2678', 'recent_socket_id': UUID('46fda9bc-72c9-4b8c-9c2d-780a894a88f4'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660319080.5274034, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 2, 'entries': {1660319082: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660319084.7993011, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660319082663}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660319082: 188}, 'speed': 188}}}, websocket[1]='c216f76232cb-1ad2-abf0-70b5-1eac2678'
2022-08-12 19:44:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660319084916}
2022-08-12 19:44:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003241879296)>, websocket[0].stream_list={'60281898189e-2b90-601c-40a3-7ac428df': {'exchange': 'binance.com-futures', 'stream_id': '60281898189e-2b90-601c-40a3-7ac428df', 'recent_socket_id': UUID('3b417e26-87d4-4a55-b3bd-49e58aa92e11'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317467.4838889, 'processed_receives_total': 9, 'receives_statistic_last_second': {'most_receives_per_second': 7, 'entries': {1660318374: 7, 1660318965: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660319083.1855655, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660319084.778097, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964939}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318374: 3041, 1660318965: 188}, 'speed': 188}}, '2a46eea82004-63ca-8a19-64eb-5032f9d1': {'exchange': 'binance.com-futures', 'stream_id': '2a46eea82004-63ca-8a19-64eb-5032f9d1', 'recent_socket_id': UUID('23eea084-667b-4c64-9bd2-1b0e11234dae'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660319082.7744272, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 0, 'entries': {1660319085: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660319085.0469844, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660319084917}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660319085: 188}, 'speed': 0}}}, websocket[1]='2a46eea82004-63ca-8a19-64eb-5032f9d1'
2022-08-12 19:44:45
stdout
data={'e': 'listenKeyExpired', 'E': 1660319084917}
2022-08-12 19:44:45
stdout
websocket[0]=<BinanceWebSocketApiManager(unicorn-binance-websocket-api, stopped 140003241879296)>, websocket[0].stream_list={'60281898189e-2b90-601c-40a3-7ac428df': {'exchange': 'binance.com-futures', 'stream_id': '60281898189e-2b90-601c-40a3-7ac428df', 'recent_socket_id': UUID('3b417e26-87d4-4a55-b3bd-49e58aa92e11'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 5, 'ping_timeout': 10, 'close_timeout': 1, 'status': 'stopped', 'start_time': 1660317467.4838889, 'processed_receives_total': 9, 'receives_statistic_last_second': {'most_receives_per_second': 7, 'entries': {1660318374: 7, 1660318965: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660319083.1855655, 'stop_request': True, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': 1660319084.778097, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660318964939}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660318374: 3041, 1660318965: 188}, 'speed': 188}}, '2a46eea82004-63ca-8a19-64eb-5032f9d1': {'exchange': 'binance.com-futures', 'stream_id': '2a46eea82004-63ca-8a19-64eb-5032f9d1', 'recent_socket_id': UUID('23eea084-667b-4c64-9bd2-1b0e11234dae'), 'channels': ('arr',), 'markets': ['!userData'], 'stream_label': None, 'stream_buffer_name': False, 'stream_buffer_maxlen': None, 'symbols': False, 'output': 'raw_data', 'subscriptions': 1, 'payload': [], 'api_key': '****', 'api_secret': '****', 'dex_user_address': False, 'ping_interval': 20, 'ping_timeout': 20, 'close_timeout': 10, 'status': 'running', 'start_time': 1660319082.7744272, 'processed_receives_total': 2, 'receives_statistic_last_second': {'most_receives_per_second': 0, 'entries': {1660319085: 2}}, 'seconds_to_last_heartbeat': None, 'last_heartbeat': 1660319085.0469844, 'stop_request': None, 'crash_request': None, 'kill_request': None, 'seconds_since_has_stopped': None, 'has_stopped': False, 'reconnects': 0, 'last_stream_signal': 'CONNECT', 'logged_reconnects': [], 'processed_transmitted_total': 0, 'last_static_ping_listen_key': 0, 'listen_key': '****', 'listen_key_cache_time': 1800, 'last_received_data_record': '{"e": "listenKeyExpired", "E": 1660319084917}', 'processed_receives_statistic': {}, 'transfer_rate_per_second': {'bytes': {1660319085: 188}, 'speed': 0}}}, websocket[1]='2a46eea82004-63ca-8a19-64eb-5032f9d1'
2022-08-12 19:44:45
stderr
INFO | 1 | 140003241879296 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(60281898189e-2b90-601c-40a3-7ac428df)
2022-08-12 19:44:45
stderr
INFO | 1 | 140003241879296 | manager | manager.py:3655 | BinanceWebSocketApiManager.stream_is_stopping(60281898189e-2b90-601c-40a3-7ac428df)
2022-08-12 19:44:45
stderr
INFO | 1 | 140003241879296 | connection | connection.py:266 | BinanceWebSocketApiConnection.close(60281898189e-2b90-601c-40a3-7ac428df)
2022-08-12 19:47:32
stderr
INFO | 1 | 140005397755648 | restclient | restclient.py:353 | BinanceWebSocketApiRestclient.get_listen_key() stream_id='d8c393a77501-2fc8-9e07-3223-d0402275')
2022-08-12 19:47:32
stderr
INFO | 1 | 140005397755648 | restclient | restclient.py:112 | BinanceWebSocketApiRestclient.keepalive_listen_key(****)
2022-08-12 19:47:32
stderr
INFO | 1 | 140005397755648 | manager | manager.py:697 | BinanceWebSocketApiManager._frequent_checks() - sent listen_key keepalive ping for stream_id=d8c393a77501-2fc8-9e07-3223-d0402275
2022-08-12 19:47:34
stderr
INFO | 1 | 140005355792128 | restclient | restclient.py:353 | BinanceWebSocketApiRestclient.get_listen_key() stream_id='f5006a870f7f-ec2c-8522-f693-e8e06b9e')
2022-08-12 19:47:34
stderr
INFO | 1 | 140005355792128 | restclient | restclient.py:112 | BinanceWebSocketApiRestclient.keepalive_listen_key(****)
2022-08-12 19:47:34
stderr
INFO | 1 | 140005355792128 | manager | manager.py:697 | BinanceWebSocketApiManager._frequent_checks() - sent listen_key keepalive ping for stream_id=f5006a870f7f-ec2c-8522-f693-e8e06b9e
2022-08-12 19:47:36
stderr
INFO | 1 | 140004844099328 | restclient | restclient.py:353 | BinanceWebSocketApiRestclient.get_listen_key() stream_id='05a8a63e6ed3-9ed9-15c0-4a0f-eb4ec026')
2022-08-12 19:47:36
stderr
INFO | 1 | 140004844099328 | restclient | restclient.py:112 | BinanceWebSocketApiRestclient.keepalive_listen_key(****)
2022-08-12 19:47:37
stderr
INFO | 1 | 140004844099328 | manager | manager.py:697 | BinanceWebSocketApiManager._frequent_checks() - sent listen_key keepalive ping for stream_id=05a8a63e6ed3-9ed9-15c0-4a0f-eb4ec026
2022-08-12 19:47:38
stderr
INFO | 1 | 140004810528512 | restclient | restclient.py:353 | BinanceWebSocketApiRestclient.get_listen_key() stream_id='dd3e7720346f-2386-4ed2-b583-ebadbd24')
2022-08-12 19:47:38
stderr
INFO | 1 | 140004810528512 | restclient | restclient.py:112 | BinanceWebSocketApiRestclient.keepalive_listen_key(****)
2022-08-12 19:47:39
stderr
INFO | 1 | 140004810528512 | manager | manager.py:697 | BinanceWebSocketApiManager._frequent_checks() - sent listen_key keepalive ping for stream_id=dd3e7720346f-2386-4ed2-b583-ebadbd24

Processing method?

stream_buffer

Used endpoint?

binance.com-futures

Issue

The library (and websockets in general) has the problem that data is lost during restart/downtime. To process this, I create two identical streams per binance account. I restart them every 25 minutes with a lag of 2 minutes relative to each other. But after the restart, the data does not come. Or do I not see them? Judging by the logs, the first pair restarted at 19:42, the second - at 19:44. Everything is correct. But after that the logs went at 19:47...

class BinanceHandler:
    def __init__(self):
        self.websockets: dict[int, list[BinanceWebSocketApiManager, Union[bool, str]]] = {}
        self.websockets_api_keys: dict[int, tuple[str, str]] = {}
        self.websockets2: dict[int, list[BinanceWebSocketApiManager, Union[bool, str]]] = {}
        self.websockets_api_keys2: dict[int, tuple[str, str]] = {}

    def execute(self):
        self.start_websockets()
        start_time = time.time()
        start_time2 = start_time + 120

        while True:
            for websocket in (list(self.websockets.values()) + list(self.websockets2.values())):
                stream = websocket[0].pop_stream_data_from_stream_buffer()
                if stream:
                    ...

            elapsed_time1 = time.time() - start_time
            elapsed_time2 = time.time() - start_time2
            if elapsed_time1 > settings.BINANCE_WEBSOCKET_LIFE_TIME:
                self.toggle_websockets(websockets=self.websockets, ws_number='first')
                start_time = time.time()

            elif elapsed_time2 > settings.BINANCE_WEBSOCKET_LIFE_TIME:
                self.toggle_websockets(websockets=self.websockets2, ws_number='second')
                start_time2 = start_time + 120

    def start_websockets(self):
        for account in BinanceAccount.objects.all():
            self._start_websocket(account=account)

    def _start_websocket(self, account: BinanceAccount):
        client = Client(account.api_key, account.api_secret, {"timeout": 120})
        self.create_ws_connection(account=account)
        self.create_ws_connection(account=account, second_set=True)

    def create_ws_connection(self, account: BinanceAccount, second_set: bool = False):
        websocket = BinanceWebSocketApiManager(
            exchange="binance.com-futures", warn_on_update=False, show_secrets_in_logs=settings.DEBUG
        )
        stream_id = websocket.create_stream(
            ("arr",),
            ("!userData",),
            api_key=account.api_key,
            api_secret=account.api_secret
        )
        if second_set:
            self.websockets2[account.id] = [websocket, stream_id]
        else:
            self.websockets[account.id] = [websocket, stream_id]

    def toggle_websockets(
        self,
        websockets: dict[int, list[BinanceWebSocketApiManager, Union[bool, str]]],
        ws_number: Literal['first', 'second']
    ):
        for acc_id, ws_obj in websockets.items():
            account = BinanceAccount.objects.get(pk=acc_id)
            websocket, old_stream = ws_obj
            stream = websocket.replace_stream(
                stream_id=old_stream,
                new_channels=("arr",),
                new_markets=("!userData",),
                new_api_key=account.api_key,
                new_api_secret=account.api_secret
            )
            if stream:
                if ws_number == 'first':
                    self.websockets[acc_id] = [websocket, stream]
                elif ws_number == 'second':
                    self.websockets2[acc_id] = [websocket, stream]
oliver-zehentleitner commented 1 year ago

The problem seems, that after stopping a userData stream UBWA is deleting the listenKey... We need to implement a solution for that, will do it in first januar week...

oliver-zehentleitner commented 1 year ago

Duplicate of https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/issues/275