WebSocket API v1 - piyasa veri akışlarından beklenmedik bağlantı kesintileri

Son güncelleme: 1 Nis 2025

WebSocket API v1'imiz, piyasa verilerimizin (ticker'lar, emir defterleri, zaman ve satışlar vb.) kalıcı bir kaynağını sağlamak üzere tasarlanmıştır, ancak bazen WebSocket bağlantıları Cloudflare tarafından beklenmedik bir şekilde sonlandırılır.

Cloudflare kaynaklı bağlantı kesintileri genellikle aşağıdaki 1006 hatası gibi ağ hatalarına neden olur:

•
websocket'ten okuma hatası: close 1006 (anormal kapanma): unexpected EOF

veya Python'ın zaten kapalı bir bağlantıdan yeni bir piyasa verisi mesajı okumaya çalışırken bir exception fırlattığı aşağıdaki durum:

•
websocket._exceptions.WebSocketConnectionClosedException: socket is already closed

Bu tür beklenmedik bağlantı kesintilerini önleyen bir çözüm olmasa da, çok etkili bazı geçici çözümler bulunmaktadır. Sık sık WebSocket bağlantı kesintileri yaşıyorsanız, aşağıdakilerden bir veya daha fazlasını uygulamanızı öneririz:

Alternatif IP adresi

Cloudflare'ın güvenlik önlemleri genellikle belirli IP adreslerine, benzer IP adres gruplarına (bir C sınıfı bloğu gibi) veya belirli coğrafi konumlara uygulanır, bu nedenle IP adresinizi değiştirmek bazen basit ama etkili bir çözüm olabilir.

Örneğin, API yazılımınızı farklı bir AWS bölgesinde barındırmak veya farklı bir coğrafi konumda bir VPN kullanmak, yerel IP adresini önemli ölçüde değiştirecek ve beklenmedik bağlantı kesintisi sorununu potansiyel olarak çözebilecektir.

Yeniden bağlantı mantığı

İstenmeyen bağlantı kesintileri için izlenen ve gerektiğinde yeniden bağlanan ve yeniden abone olunan tek bir WebSocket bağlantısı kullanmak, başka bir basit ama etkili çözümdür. Aşağıda, bir WebSocketConnectionClosed exception'ı fırlatıldığında bir WebSocket bağlantısının nasıl yeniden bağlanacağını ve yeniden abone olunacağını gösteren temel bir Python kodu örneği bulunmaktadır:

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

Aşağıdaki örnek çıktıda gösterildiği gibi, bağlantı beklenmedik bir şekilde sonlandırıldığında (döngünün 30 ve 60. yinelemelerinde) WebSocket bağlantısı ve aboneliği yenilenir:

Yedekli bağlantılar

Birden fazla (iki veya daha fazla) yedekli WebSocket bağlantısı kullanmak, beklenmedik WebSocket bağlantı kesintilerine karşı genellikle en etkili çözümdür, çünkü temel bağlantılar ne sıklıkta sonlandırılırsa sonlandırılsın, piyasa veri akışlarının kesintisiz devam etmesini sağlar.

Aşağıdaki temel Python kodu örneği, otomatik yük devretme ile birden fazla WebSocket bağlantısının nasıl uygulanacağını göstermektedir:

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

Yukarıdaki kod, iki WebSocket bağlantısı oluşturur ve her iki bağlantıyı da aynı piyasa veri akışına abone eder. Birincil bağlantı, bir klavye kesintisi (örneğin Ctrl+C aracılığıyla) oluşturulana kadar piyasa verilerini çıkarmak için kullanılır, bu da birincil bağlantıyı kapatır. Birincil bağlantıdan sonraki okumalar, yakalanan ve piyasa veri kaynağını yedek bağlantıya değiştirmek için kullanılan bir exception fırlatır, bu da daha sonra piyasa verilerini çıkarmak için kullanılır.

Aşağıdaki örnek çıktı, piyasa veri akışını kesintiye uğratmadan piyasa veri kaynağının birincil bağlantıdan yedek bağlantıya nasıl değiştiğini göstermektedir:

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"]

Yedekli WebSocket bağlantılarının üç çözüm arasında en karmaşık olanı olduğunu, ancak güvenilirlik açısından en uygun çözüm olduğunu unutmayın.

WebSocket API v1 - piyasa veri akışlarından beklenmedik bağlantı kesintileri

Alternatif IP adresi

Yeniden bağlantı mantığı

Yedekli bağlantılar

Daha fazla yardıma mı ihtiyacınız var?