WebSocket API v1 – neočekávaná odpojení od datových toků trhu

Naposledy aktualizováno: 1. dubna 2025

Naše WebSocket API v1 je určeno k poskytování trvalého zdroje našich tržních dat (tickers, knihy objednávek, čas a prodeje atd.), ale někdy jsou připojení WebSocket neočekávaně ukončena službou Cloudflare.

Odpojení iniciovaná službou Cloudflare obvykle vedou k síťovým chybám, jako je následující chyba 1006:

•
Error reading from websocket: close 1006 (abnormal closure): unexpected EOF

nebo následující, kdy Python vyvolá výjimku při pokusu o čtení nové zprávy tržních dat z již uzavřeného připojení:

•
websocket._exceptions.WebSocketConnectionClosedException: socket is already closed

I když neexistuje řešení, které by zabránilo tomuto typu neočekávaných odpojení, existují některá velmi účinná řešení. V případě, že se setkáváte s častými odpojeními WebSocket, doporučujeme implementovat jedno nebo více z následujících:

Alternativní IP adresa

Bezpečnostní opatření Cloudflare jsou často aplikována na konkrétní IP adresy, skupiny podobných IP adres (jako je blok třídy C) nebo určité geografické lokality, proto změna vaší IP adresy je někdy jednoduchým, ale účinným řešením.

Například hostování vašeho API softwaru v jiné oblasti AWS nebo použití VPN v jiné geografické lokalitě by významně změnilo lokální IP adresu a potenciálně vyřešilo problém neočekávaného odpojení.

Logika opětovného připojení

Použití jediného připojení WebSocket, které je monitorováno na jakékoli neúmyslné odpojení a v případě potřeby znovu připojeno a znovu přihlášeno, je dalším jednoduchým, ale účinným řešením. Následuje základní příklad kódu Python, který ukazuje, jak znovu připojit a znovu přihlásit připojení WebSocket, kdykoli je vyvolána výjimka 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)

Jak je ukázáno v následujícím ukázkovém výstupu, připojení a odběr WebSocket jsou obnoveny, kdykoli je připojení neočekávaně ukončeno (při 30 a 60 iteracích smyčky):

Redundantní připojení

Použití více (dvou nebo více) redundantních připojení WebSocket je obvykle nejúčinnějším řešením neočekávaných odpojení WebSocket, protože umožňuje nepřerušované pokračování datových toků trhu bez ohledu na to, jak často jsou podkladová připojení ukončena.

Následující základní příklad kódu Python ukazuje, jak implementovat více připojení WebSocket s automatickým přepnutím na záložní systém:

#!/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)

Výše uvedený kód vytváří dvě připojení WebSocket a obě připojení přihlašuje ke stejnému datovému toku trhu. Primární připojení se používá k výstupu tržních dat, dokud není vygenerováno přerušení z klávesnice (například pomocí Ctrl+C), které primární připojení uzavře. Následné čtení z primárního připojení vyvolá výjimku, která je zachycena a použita ke změně zdroje tržních dat na záložní připojení, které je pak použito k výstupu tržních dat.

Následující ukázkový výstup ukazuje, jak se zdroj tržních dat mění z primárního připojení na záložní připojení bez přerušení datového toku trhu:

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","9675.00000","1591440132.527887","0.10336612","4.27935600"],"spread","XBT/USD"]

Všimněte si, že redundantní připojení WebSocket je nejsložitější ze tří řešení, ale je to optimální řešení s ohledem na spolehlivost.

WebSocket API v1 – neočekávaná odpojení od datových toků trhu

Alternativní IP adresa

Logika opětovného připojení

Redundantní připojení

Potřebujete další pomoc?