WebSocket API v1 – несподівані розриви з'єднань з потоками ринкових даних

Останнє оновлення: 1 квіт. 2025 р.

Наш WebSocket API v1 призначений для забезпечення постійного джерела наших ринкових даних (тікери, книги замовлень, час і продажі тощо), але іноді з'єднання WebSocket несподівано розриваються Cloudflare.

Розриви з'єднань, ініційовані Cloudflare, зазвичай призводять до мережевих помилок, таких як наступна помилка 1006:

•
Помилка читання з вебсокета: закриття 1006 (аномальне закриття): неочікуваний кінець файлу

або наступне, коли Python видає виняток при спробі прочитати нове повідомлення ринкових даних із вже закритого з'єднання:

•
websocket._exceptions.WebSocketConnectionClosedException: сокет вже закрито

Хоча не існує рішення, яке б запобігало таким несподіваним розривам з'єднань, є кілька дуже ефективних обхідних шляхів. У випадку, якщо ви часто стикаєтеся з розривами з'єднань WebSocket, ми рекомендуємо реалізувати одне або кілька з наступних:

Альтернативна IP-адреса

Заходи безпеки Cloudflare часто застосовуються до певних IP-адрес, груп схожих IP-адрес (наприклад, блок класу C) або певних географічних місць, тому зміна вашої IP-адреси іноді є простим, але ефективним рішенням.

Наприклад, розміщення вашого програмного забезпечення API в іншому регіоні AWS або використання VPN в іншому географічному місці значно змінить локальну IP-адресу та потенційно вирішить проблему несподіваного розриву з'єднання.

Логіка повторного підключення

Використання єдиного з'єднання WebSocket, яке відстежується на предмет будь-яких ненавмисних розривів, і його повторне підключення та повторна підписка за необхідності є ще одним простим, але ефективним рішенням. Нижче наведено базовий приклад коду Python, що показує, як повторно підключити та повторно підписати з'єднання WebSocket щоразу, коли виникає виняток WebSocketConnectionClosed:

#!/usr/bin/env python3 import sys from websocket import create_connection ws = create_connection('wss://ws.kraken.com/') print(ws.recv()) ws.send('{"event":"subscribe", "subscription":{"name":"ticker"}, "pair":["XBT/USD"]}') print(ws.recv()) for count in range(100): if count == 30 or count == 60: ws.close() try: print(ws.recv()) except: ws = create_connection('wss://ws.kraken.com/') print(ws.recv()) ws.send('{"event":"subscribe", "subscription":{"name":"ticker"}, "pair":["XBT/USD"]}') print(ws.recv()) ws.close() sys.exit(0)

Як показано в наступному прикладі виводу, з'єднання WebSocket та підписка поновлюються щоразу, коли з'єднання несподівано розривається (на 30 та 60 ітераціях циклу):

Надлишкові з'єднання

Використання кількох (двох або більше) надлишкових з'єднань WebSocket зазвичай є найефективнішим рішенням для несподіваних розривів з'єднань WebSocket, оскільки це дозволяє потокам ринкових даних продовжувати роботу безперервно, незалежно від того, як часто розриваються базові з'єднання.

Наступний базовий приклад коду Python показує, як реалізувати кілька з'єднань WebSocket з автоматичним перемиканням на резерв:

#!/usr/bin/env python3 import sys from websocket import create_connection ws = [ None, None ] data = [ "", "" ] ws[0] = create_connection("wss://ws.kraken.com/") print("WebSocket (Primary): %s" % ws[0].recv()) ws[1] = create_connection("wss://ws.kraken.com/") print("WebSocket (Backup): %s" % ws[1].recv()) ws[0].send('{"event":"subscribe", "subscription":{"name":"spread"}, "pair":["XBT/USD"]}') print("WebSocket (Primary): %s" % ws[0].recv()) ws[1].send('{"event":"subscribe", "subscription":{"name":"spread"}, "pair":["XBT/USD"]}') print("WebSocket (Backup): %s" % ws[1].recv()) source = 0 for count in range(100): try: try: data[0] = ws[0].recv() except Exception: source = 1 try: data[1] = ws[1].recv() except Exception: source = 0 except KeyboardInterrupt: ws[0].close() print("WebSocket (%(source)s): %(data)s" % {"source":"Primary" if source == 0 else "Backup", "data":data[source]}) ws[source].close() sys.exit(1)

Наведений вище код створює два з'єднання WebSocket і підписує обидва з'єднання на один і той же потік ринкових даних. Основне з'єднання використовується для виведення ринкових даних, доки не буде згенеровано переривання з клавіатури (наприклад, за допомогою Ctrl+C), яке закриває основне з'єднання. Подальші спроби читання з основного з'єднання викликають виняток, який перехоплюється та використовується для зміни джерела ринкових даних на резервне з'єднання, яке потім використовується для виведення ринкових даних.

Наступний приклад виводу показує, як джерело ринкових даних змінюється з основного з'єднання на резервне без переривання потоку ринкових даних:

WebSocket (Primary): {"connectionID":6894434610526943167,"event":"systemStatus","status":"online","version":"1.0.1"} WebSocket (Backup): {"connectionID":11520162761468018366,"event":"systemStatus","status":"online","version":"1.0.1"} WebSocket (Primary): {"channelID":275,"channelName":"spread","event":"subscriptionStatus","pair":"XBT/USD","status":"subscribed","subscription":{"name":"spread"}} WebSocket (Backup): {"channelID":275,"channelName":"spread","event":"subscriptionStatus","pair":"XBT/USD","status":"subscribed","subscription":{"name":"spread"}} WebSocket (Primary): [275,["9674.90000","9675.00000","1591440118.120752","10.88476562","3.47935600"],"spread","XBT/USD"] WebSocket (Primary): {"event":"heartbeat"} WebSocket (Primary): {"event":"heartbeat"} WebSocket (Primary): [275,["9674.90000","9675.00000","1591440127.108830","10.98812533","3.47935600"],"spread","XBT/USD"] WebSocket (Primary): {"event":"heartbeat"} WebSocket (Primary): [275,["9674.90000","9675.00000","1591440129.406073","1.87412533","7.47935600"],"spread","XBT/USD"] WebSocket (Primary): [275,["9674.90000","9675.00000","1591440129.505372","0.77412533","7.47935600"],"spread","XBT/USD"] WebSocket (Primary): [275,["9674.90000","9675.00000","1591440129.572658","0.10335971","7.47935600"],"spread","XBT/USD"] WebSocket (Primary): [275,["9674.90000","9675.00000","1591440129.572658","0.10335971","7.47935600"],"spread","XBT/USD"] ^C WebSocket (Backup): [275,["9674.90000","9675.00000","1591440130.156840","0.10335971","8.27935600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9674.90000","9675.00000","1591440130.195899","0.10335971","8.47435600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.80000","9675.00000","1591440130.459388","0.10335971","8.47435600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9672.60000","9675.00000","1591440130.195899","0.00516924","8.47435600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.80000","9675.00000","1591440130.764856","0.00400000","8.47435600"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.80000","9674.90000","1591440130.780514","0.00400000","0.25000000"],"spread","XBT/USD"] WebSocket (Backup): {"event":"heartbeat"} WebSocket (Backup): [275,["9673.80000","9674.90000","1591440132.433940","4.00400000","0.25000000"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.80000","9674.90000","1591440132.519509","4.00000000","0.25000000"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.90000","9674.90000","1591440132.527887","0.10336612","0.25000000"],"spread","XBT/USD"] WebSocket (Backup): [275,["9673.90000","9674.90000","1591440132.527887","0.10336612","4.27935600"],"spread","XBT/USD"]

Зауважте, що надлишкові з'єднання WebSocket є найскладнішим з трьох рішень, але воно є оптимальним рішенням щодо надійності.

WebSocket API v1 – несподівані розриви з'єднань з потоками ринкових даних

Альтернативна IP-адреса

Логіка повторного підключення

Надлишкові з'єднання

Потрібна додаткова допомога?