Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import websocket
- import json
- try:
- import thread
- except ImportError:
- import _thread as thread
- import time
- from pandas import DataFrame
- dataFromServer = [ ]
- def on_message(ws, message):
- get_message = json.loads(message.decode('utf-8'))
- dataFromServer.append(get_message)
- print(get_message)
- def on_error(ws, error):
- print(error)
- def on_close(ws):
- df = DataFrame(dataFromServer)
- print(df.head())
- print("close")
- def on_open(ws):
- def run(*args):
- sendData = '[{"ticket":"test"},{"type":"ticker","codes":["KRW-CPT","KRW-ADA"]}]'
- for i in range(3):
- ws.send(sendData)
- time.sleep(1)
- ws.close()
- thread.start_new_thread(run, ())
- ws = websocket.WebSocketApp("wss://api.upbit.com/websocket/v1",
- on_message = on_message,
- on_error = on_error,
- on_close = on_close)
- ws.on_open = on_open
- ws.run_forever()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement