问题描述
我正在从币安接收交易数据。我订阅了所有 USDT 对(目前为 303)。
await _binanceSocketClient.Spot.SubscribetoTradeUpdatesAsync(symbols.Select(x=>x.Name),data =>
{
_dbClient.UpsertRecord(data.Symbol,(PairTrade)data);
Debug.WriteLine(JsonSerializer.Serialize(data,new JsonSerializerOptions {
WriteIndented = true }));
});
此数据在接收时也被保存到 MongoDb。我正在使用符号作为 ID 对其进行更新。该数据库旨在提供所有 USDT 对的最新价格。
public async Task UpsertRecord(string symbol,PairTrade record)
{
_Trades.ReplaceOne(new BsonDocument("_id",symbol),record,new ReplaceOptions {
IsUpsert = true });
}
问题是MongoDB的写入速度跟不上输入数据的速度,导致保存的数据滞后,最终导致WebSocket停止。
有没有更好的方法来处理这个问题并尽快处理数据?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)