如何快速处理 Websocket 数据

如何解决如何快速处理 Websocket 数据

我正在从币安接收交易数据。我订阅了所有 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停止。

有没有更好的方法来处理这个问题并尽快处理数据？