API WebSocket v1/v2 - Zalecana biblioteka Python i przykłady użycia

Ostatnia aktualizacja: 1 kwi 2025

Nasze API WebSocket jest dostępne za pośrednictwem dowolnego języka programowania obsługującego WebSocket (Python, Javascript, C#, Go itp.). Wiele języków programowania oferuje biblioteki WebSocket, które umożliwiają programistom korzystanie z interfejsu WebSocket bez zrozumienia skomplikowanych szczegółów protokołu WebSocket.

Python jest jednym z przykładów, który oferuje wiele różnych bibliotek WebSocket, więc skąd programista wie, której biblioteki użyć lub jak najlepiej wykorzystać wybraną bibliotekę. Poniżej przedstawiamy naszą zalecaną bibliotekę Python WebSocket i podajemy kilka przykładów, jak używać tej biblioteki w różnych scenariuszach.

Klient WebSocket

Naszą zalecaną biblioteką Python WebSocket jest biblioteka websocket-client. Biblioteka jest kompatybilna zarówno z Pythonem 2, jak i Pythonem 3, ale w przypadku nowego kodu zalecamy używanie wyłącznie Pythona 3, ponieważ Python 2 jest w trakcie wycofywania.

Bibliotekę websocket-client można pobrać z Python Package Index (pypi.org) i zainstalować za pomocą dołączonego pliku setup.py:

  • •

    python setup.py install

lub pobrać i zainstalować jednocześnie za pomocą standardowego narzędzia instalacyjnego Pythona (pip):

  • •

    pip install websocket-client

Użycie

Biblioteka klienta WebSocket może być używana do tworzenia synchronicznego (blokującego) klienta WebSocket lub asynchronicznego (nieblokującego, sterowanego zdarzeniami) klienta. Obie wersje mogą pomyślnie współpracować z naszym API, więc wybór zależałby od specyficznych wymagań implementacji (takich jak to, czy inne zadania muszą odbywać się równolegle).

Na przykład, prosta aplikacja do monitorowania cen rynkowych mogłaby używać klienta synchronicznego, który po prostu czekałby na nowe dane rynkowe i porównywał cenę rynkową z określoną wartością, podczas gdy w pełni funkcjonalny bot handlowy musiałby używać klienta asynchronicznego z danymi rynkowymi w oddzielnych wątkach (aby zadania analizy i handlu mogły być kontynuowane równolegle).

Poniżej przedstawiono podstawowe przykłady klientów synchronicznych i asynchronicznych, które mogą posłużyć jako punkt wyjścia do bardziej złożonego kodu API.

Synchroniczny interfejs API WebSocket

# Import WebSocket client libraryfrom websocket import create_connection# Connect to WebSocket API and subscribe to trade feed for XBT/USD and XRP/USDws = create_connection("wss://ws.kraken.com/")ws.send('{"event":"subscribe", "subscription":{"name":"trade"}, "pair":["XBT/USD","XRP/USD"]}')# Infinite loop waiting for WebSocket datawhile True:   print(ws.recv())

Asynchroniczny interfejs API WebSocket

# Import WebSocket client library (and others)import websocketimport _threadimport time# Define WebSocket callback functionsdef ws_message(ws, message):    print("WebSocket thread: %s" % message)def ws_open(ws):    ws.send('{"event":"subscribe", "subscription":{"name":"trade"}, "pair":["XBT/USD","XRP/USD"]}')def ws_thread(*args):    ws = websocket.WebSocketApp("wss://ws.kraken.com/", on_open = ws_open, on_message = ws_message)    ws.run_forever()# Start a new thread for the WebSocket interface_thread.start_new_thread(ws_thread, ())# Continue other (non WebSocket) tasks in the main threadwhile True:    time.sleep(5)    print("Main thread: %d" % time.time())

Pełne szczegóły i instrukcje dotyczące biblioteki klienta WebSocket są dostępne w archiwum kodu biblioteki.

Potrzebujesz więcej pomocy?