WebSocket API v1 오더북 피드 해석을 위한 예시 코드 (비동기/멀티스레드)

최종 업데이트: 2025년 4월 2일

WebSocket API v1 오더북 피드를 해석하는 방법에 대한 자세한 지침은 WebSocket API v1 오더북 피드 지원 페이지와 유효한 오더북을 유지하는 방법 지원 페이지에서 확인할 수 있습니다.

WebSocket API v1 오더북 피드와 통합하고 오더북의 로컬 사본을 유지하기 위한 Python 예시 코드는 아래에 제공되어 있습니다.

이 코드는 표준 Python WebSocket 라이브러리를 사용하며, 오더북 피드 해석과 병행하여 다른 작업을 계속할 수 있도록 비동기(이벤트 기반/멀티스레드) 방식을 구현합니다.

사용법

코드는 다음과 같이 명령 프롬프트(예: macOS 터미널)를 통해 실행해야 합니다.

  • •

    krakenwsorderbookasync.py symbol depth, 또는,

  • •

    python3 krakenwsorderbookasync.py symbol depth

예를 들어, 다음 명령은 Dogecoin/USD (XDG/USD) 오더북 피드를 10개 가격 수준(각 측면)의 깊이로 검색하고 해석합니다.

  • •

    krakenwsorderbookasync.py XDG/USD 10

코드는 키보드 인터럽트(대부분의 명령줄 환경에서 Ctrl+C)로 종료될 때까지 무기한 실행됩니다.

Python 코드

Python 코드는 아래에서 볼 수 있으며 krakenwsorderbookasync.py로 다운로드할 수도 있습니다.

#!/usr/bin/env python3

# Import WebSocket client library (and others)
import sys
import json
import signal
import time
import _thread
import websocket

# Parse command line arguments (symbol and depth)
if len(sys.argv) < 3:
sys.exit(1)
else:
api_symbol = sys.argv[1]
api_depth = int(sys.argv[2])

# Define order book variables
api_book = {'bid':{}, 'ask':{}}

# Define order book update functions
def dicttofloat(data):
return float(data[0])

def api_book_update(api_book_side, api_book_data):
for data in api_book_data:
price_level = data[0]
volume = data[1]
if float(volume) > 0.0:
api_book[api_book_side][price_level] = volume
else:
api_book[api_book_side].pop(price_level)
if api_book_side == 'bid':
api_book['bid'] = dict(sorted(api_book['bid'].items(), key=dicttofloat, reverse=True)[:api_depth])
elif api_book_side == 'ask':
api_book['ask'] = dict(sorted(api_book['ask'].items(), key=dicttofloat)[:api_depth])

# Define WebSocket callback functions
def ws_thread(*args):
ws = websocket.WebSocketApp('wss://ws.kraken.com/', on_open=ws_open, on_message=ws_message)
ws.run_forever()

def ws_open(ws):
ws.send('{"event":"subscribe", "subscription":{"name":"book", "depth":%(api_depth)d}, "pair":["%(api_symbol)s"]}' % {'api_depth':api_depth, 'api_symbol':api_symbol})

def ws_message(ws, ws_data):
api_data = json.loads(ws_data)
if 'event' in api_data:
return
else:
if 'as' in api_data[1]:
api_book_update('ask', api_data[1]['as'])
api_book_update('bid', api_data[1]['bs'])
else:
for data in api_data[1:len(api_data)-2]:
if 'a' in data:
api_book_update('ask', data['a'])
elif 'b' in data:
api_book_update('bid', data['b'])

# Start new thread for WebSocket interface
_thread.start_new_thread(ws_thread, ())

# Output order book (once per second) in main thread
try:
while True:
if len(api_book['bid']) < api_depth or len(api_book['ask']) < api_depth:
time.sleep(1)
else:
bid = sorted(api_book['bid'].items(), key=dicttofloat, reverse=True)
ask = sorted(api_book['ask'].items(), key=dicttofloat)
print('Bid\t\t\t\t\t\t\tAsk')
for count in range(api_depth):
print('%(bidprice)s (%(bidvolume)s)\t\t\t\t%(askprice)s (%(askvolume)s)' \
% {'bidprice':bid[count][0], 'bidvolume':bid[count][1], 'askprice':ask[count][0], 'askvolume':ask[count][1]})
time.sleep(1)
except KeyboardInterrupt:
sys.exit(0)

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