zaif-realtime.py

import websocket
import time
import sys
from datetime import datetime, timedelta, timezone

import sched, time
import json

JST = timezone(timedelta(hours=+9), 'JST')

class ZaifWebSocketReader():
    endpoint = "wss://ws.zaif.jp/stream?currency_pair=btc_jpy"
    def __init__(self):
        #websocket.enableTrace(True)
        self.ws = websocket.WebSocketApp(
                ZaifWebSocketReader.endpoint,
                on_message = self.on_message,
                on_error = self.on_error,
                on_close = self.on_close
         )
        self.ws.on_open = self.on_open

        try:
            self.run()
        except KeyboardInterrupt:
            self.ws.close()

    def run(self):
        self.ws.run_forever()
        print("### run ###")
        pass

    def on_message(self, ws, message):
        now = datetime.now(JST)
        print(str(now), message)

    def on_error(self, ws, error):
        print(error)
        sys.exit()

    def on_close(self, ws):
        print("### closed ###")

    def on_open(self, ws):
        print("### open ###")

if __name__=="__main__":
    ZaifWebSocketReader()