###謎すぎる不具合
python:sample.py
1import websocket 2import json 3from pprint import pprint 4import time 5from datetime import datetime 6from dateutil import parser,tz 7import csv 8import threading 9 10f = open("exec_data.csv","w") 11writer = csv.writer(f) 12writer.writerow([2,3,4]) 13 14 15 16class RealtimeAPI(object): 17 18 def __init__(self,url,channel): 19 self.url = url 20 self.channel = channel 21 self.ws = websocket.WebSocketApp(self.url,header=None,on_message=self.on_message,\ 22 on_open=self.on_open,on_close=self.on_close,on_error=self.on_error) 23 websocket.enableTrace(True) 24 25 def run(self): 26 self.ws.run_forever() 27 28 def on_message(self,message): 29 message = json.loads(message) 30 pprint(message) 31 32 33 def on_error(self,error): 34 print(error) 35 36 def on_open(self): 37 print("websocket connection started.") 38 self.ws.send(json.dumps({"method": "subscribe","params": {"channel": self.channel}})) 39 40 def on_close(self): 41 print("###websocket connection closed.###") 42 43if __name__ == "__main__": 44 url = "wss://ws.lightstream.bitflyer.com/json-rpc" 45 channel = "lightning_executions_FX_BTC_JPY" 46 json_rpc = RealtimeAPI(url=url,channel=channel) 47 json_rpc.run()
このコードを実行しても最初の"exec_data.csv"
への書き込みが行われません。なお、最後の行json_rps.run()
をコメントアウトすると書き込めます。どう修正すればいいか見当もつかなく困っています。どなたかお力をお貸しください。
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。