WebSocket API v1 - 시장 데이터 피드에서 예기치 않은 연결 해제

최종 업데이트: More than 3 months ago

당사의 WebSocket API v1은 시장 데이터(티커, 오더북, 시간 및 판매 등)의 지속적인 소스를 제공하기 위한 것이지만, 때때로 Cloudflare에 의해 WebSocket 연결이 예기치 않게 종료될 수 있습니다.

Cloudflare에 의해 시작된 연결 해제는 일반적으로 다음과 같은 1006 오류와 같은 네트워크 오류를 발생시킵니다.

•
websocket에서 읽기 오류: 닫기 1006 (비정상 종료): 예상치 못한 EOF

또는 Python이 이미 닫힌 연결에서 새 시장 데이터 메시지를 읽으려고 할 때 예외를 발생시키는 다음과 같은 경우:

•
websocket._exceptions.WebSocketConnectionClosedException: 소켓이 이미 닫혔습니다.

이러한 유형의 예기치 않은 연결 해제를 방지하는 해결책은 없지만, 매우 효과적인 몇 가지 해결 방법이 있습니다. WebSocket 연결 해제가 자주 발생하는 경우 다음 중 하나 이상을 구현하는 것이 좋습니다.

대체 IP 주소

Cloudflare의 보안 예방 조치는 특정 IP 주소, 유사한 IP 주소 그룹(예: 클래스 C 블록) 또는 특정 지리적 위치에 적용되는 경우가 많으므로, IP 주소를 변경하는 것이 때로는 간단하지만 효과적인 해결책이 될 수 있습니다.

예를 들어, API 소프트웨어를 다른 AWS 리전에 호스팅하거나 다른 지리적 위치에서 VPN을 사용하는 것은 모두 로컬 IP 주소를 크게 변경하고 예기치 않은 연결 해제 문제를 해결할 수 있습니다.

재연결 로직

의도치 않은 연결 해제를 모니터링하고 필요에 따라 재연결 및 재구독하는 단일 WebSocket 연결을 사용하는 것도 간단하지만 효과적인 해결책입니다. 다음은 WebSocketConnectionClosed 예외가 발생할 때마다 WebSocket 연결을 재연결하고 재구독하는 방법을 보여주는 기본적인 Python 코드 예시입니다.

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

다음 샘플 출력에서 볼 수 있듯이, 연결이 예기치 않게 종료될 때마다(루프의 30회 및 60회 반복 시) WebSocket 연결 및 구독이 갱신됩니다.

중복 연결

여러 개의(두 개 이상) 중복 WebSocket 연결을 사용하는 것이 예기치 않은 WebSocket 연결 해제에 대한 가장 효과적인 해결책인 경우가 많습니다. 이는 기본 연결이 얼마나 자주 종료되든 관계없이 시장 데이터 피드가 중단 없이 계속될 수 있도록 하기 때문입니다.

다음은 자동 페일오버를 통해 여러 WebSocket 연결을 구현하는 방법을 보여주는 기본적인 Python 코드 예시입니다.

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

중복 WebSocket 연결은 세 가지 해결책 중 가장 복잡하지만, 안정성 측면에서는 최적의 해결책입니다.

WebSocket API v1 - 시장 데이터 피드에서 예기치 않은 연결 해제

대체 IP 주소

재연결 로직

중복 연결

더 많은 도움이 필요하신가요?