diff --git a/examples/websocket/crypto.py b/examples/websocket/crypto.py new file mode 100644 index 00000000..87bfb8c9 --- /dev/null +++ b/examples/websocket/crypto.py @@ -0,0 +1,11 @@ +from polygon import WebSocketClient +from polygon.websocket.models import WebSocketMessage, Market +from typing import List + +c = WebSocketClient(market=Market.Crypto, subscriptions=['XT.*']) + +def handle_msg(msgs: List[WebSocketMessage]): + for m in msgs: + print(m) + +c.run(handle_msg) diff --git a/polygon/websocket/models/models.py b/polygon/websocket/models/models.py index d4b1d322..53f7743d 100644 --- a/polygon/websocket/models/models.py +++ b/polygon/websocket/models/models.py @@ -107,7 +107,7 @@ def from_dict(d): class CryptoTrade: "CryptoTrade contains trade data for a crypto pair." event_type: Optional[Union[str, EventType]] = None - symbol: Optional[str] = None + pair: Optional[str] = None exchange: Optional[int] = None id: Optional[str] = None price: Optional[float] = None @@ -120,7 +120,7 @@ class CryptoTrade: def from_dict(d): return CryptoTrade( d.get("ev", None), - d.get("sym", None), + d.get("pair", None), d.get("x", None), d.get("i", None), d.get("p", None),