1
import sys
2
import websockets
3
import asyncio
4
import json
5
6
#connects to endpoint ENDPOINT
7
async def main():
8
ENDPOINT = 'wss://ws.shared.projectx.network'
9
async with websockets.connect(ENDPOINT) as websocket:
10
await websocket.send('{"action": "subscribe", "exchange" : "%s", "channel": "%s", "symbol": "%s"}' % (sys.argv[1], sys.argv[2], sys.argv[3]))
11
async for message in websocket:
12
msg = json.loads(message)
13
print(json.dumps(msg, indent=4, default=str))
14
15
if __name__ == "__main__":
16
try:
17
asyncio.run(main())
18
except KeyboardInterrupt:
19
print("\nExiting...")