-
InfluxDB安装
-
websocket下载数据
-
存储数据
import websocket import influxdb try: import thread except ImportError: import _thread as thread import time def on_message(ws, message): # 在这里实现存储 # 首先将message格式转成line protocol格式 # 使用influxdb模块的write_points函数存入 print(message) def on_error(ws, error): print(error) def on_close(ws): print("### closed ###") websocket.enableTrace(True) ws = websocket.WebSocketApp("wss://stream.binance.com:9443/ws/!ticker@arr", on_message = on_message, on_error = on_error, on_close = on_close) ws.run_forever(sslopt={"check_hostname": False})
Python通过websocket向InfluxDB存储数据
猜你喜欢
转载自blog.csdn.net/The_Time_Runner/article/details/105646059
今日推荐
周排行