如何存储来自Binance Websocket的数据

Question

我目前正在尝试从Binance Miniticker Websocket存储一些数据流，但我想不出方法。我想将数据附加到现有的字典中，这样我就可以将其作为历史数据进行访问。

def miniticker_socket(msg):
''' define how to process incoming WebSocket messages '''
if msg[0]['e'] != 'error':
for item in msg:
miniticker["{0}".format(item['s'])] = {'low': [],'high': [], 'open': [], 'close':[],'timestamp':[], 'symbol':[] }
miniticker[item['s']]['close'].append(msg[msg.index(item)]['c'])
print(miniticker[item['s']])
else:
print('there has been an issue')
bsm = BinanceSocketManager(client)
#ticker_key = bsm.start_symbol_ticker_socket(crypto, ticker_socket)
miniticker_key = bsm.start_miniticker_socket(miniticker_socket)
bsm.start()

我在上面的代码中遇到的问题是，数据没有被调用，因为每次Websocket回调函数时，它都会将字典定义为空。我无法在Websocket之外定义字典，因为字典的名称是由socket内的item['s']元素给定的。

我还尝试返回整个数据并在另一个函数中调用回调函数，但这会产生另一个错误，即"；未定义消息">

我非常感谢您对此的反馈！感谢

Answer 1

此外，您可以尝试检查字典miniticker:中是否已经存在密钥

key = "{0}".format(item['s'])
if key not in miniticker.keys():
miniticker["{0}".format(item['s'])] = {...}

所以你不会每次都把它重新定义为一个空字典

Answer 2

我认为您可能想要一个全局变量字典，其中包含来自ticker的字典值。全局字典的关键字需要一些独特的东西。

例如，您可以使用字符串datetime:

timestamp_key = datetime.datetime.now().isoformat()
global_dict[timestamp_key] = miniticker["{0}".format(item['s'])] = {'low': [],'high': [], 'open': [], 'close':[],'timestamp':[], 'symbol':[] }
global_dict[timestamp_key][item['s']]['close'].append(msg[msg.index(item)]['c'])

全球格言最终会是这样的：

{
"2020-03-25T17:14:19.382748": {
"your_data_key1": { "more": "data" }
},
"2021-03-25T17:15:19.249148": {
"your_data_key1": { "more": "data_from_another_update" }
}
}