mongodb - ReplaceOne 抛出重复键异常

Question

我的应用从远程服务器接收数据，并调用 ReplaceOne 来插入新文档或使用 Upsert = true 的给定键替换现有文档。 ( key 使用 * 进行匿名化)该代码仅在单个线程中运行。

但是，应用程序偶尔会崩溃并出现以下错误:

Unhandled Exception: MongoDB.Driver.MongoWriteException: A write operation resulted in an error.                             
  E11000 duplicate key error collection: ****.orders index: _id_ dup key: { : "****-********-********-************" } ---> MongoDB.Driver.MongoBulkWriteException`1[MongoDB.Bson.BsonDocument]: A bulk write operation resulted in one or more errors.                                                                                                              
  E11000 duplicate key error collection: ****.orders index: _id_ dup key: { : "****-********-********-************" }                                                                                                                  
   at MongoDB.Driver.MongoCollectionImpl`1.BulkWrite(IEnumerable`1 requests, BulkWriteOptions options, CancellationToken cancellationToken)                                                                                                               
   at MongoDB.Driver.MongoCollectionBase`1.ReplaceOne(FilterDefinition`1 filter, TDocument replacement, UpdateOptions options, CancellationToken cancellationToken)                                                                                       
   --- End of inner exception stack trace ---                                                                                
   at MongoDB.Driver.MongoCollectionBase`1.ReplaceOne(FilterDefinition`1 filter, TDocument replacement, UpdateOptions options, CancellationToken cancellationToken)                                                                                       
   at Dashboard.Backend.AccountMonitor.ProcessOrder(OrderField& order)                                                       
   at Dashboard.Backend.AccountMonitor.OnRtnOrder(Object sender, OrderField& order)                                          
   at XAPI.Callback.XApi._OnRtnOrder(IntPtr ptr1, Int32 size1)                                                               
   at XAPI.Callback.XApi.OnRespone(Byte type, IntPtr pApi1, IntPtr pApi2, Double double1, Double double2, IntPtr ptr1, Int32 size1, IntPtr ptr2, Int32 size2, IntPtr ptr3, Int32 size3)                                                                   
Aborted (core dumped) 

我的问题是，为什么当我将 ReplaceOne 与 Upsert = true 选项一起使用时可能会出现重复 key ？

该应用程序在以下环境和运行时运行:

.NET Command Line Tools (1.0.0-preview2-003121)

Product Information:
 Version:            1.0.0-preview2-003121
 Commit SHA-1 hash:  1e9d529bc5

Runtime Environment:
 OS Name:     ubuntu
 OS Version:  16.04
 OS Platform: Linux
 RID:         ubuntu.16.04-x64

和MongoDB.Driver 2.3.0-rc1。

Answer 1

Upsert 基于过滤器查询进行工作。如果过滤器查询不匹配，它将尝试插入文档。

如果过滤器查询找到该文档，它将替换该文档。

就您而言，它可能以任何一种方式进行，即插入/更新。请检查数据来分析场景。

插入场景:-

如果过滤条件中不存在 _id，则更新插入会自动创建实际 _id。因此，_id 不应产生唯一性问题。如果其他一些字段是唯一索引的一部分，则会产生唯一性问题。

替换场景:-

您尝试更新的字段应该定义有唯一索引。请检查集合的索引及其属性。

Optional. When true, replaceOne() either: Inserts the document from the replacement parameter if no document matches the filter. Replaces the document that matches the filter with the replacement document.

To avoid multiple upserts, ensure that the query fields are uniquely indexed.

Defaults to false.

MongoDB will add the _id field to the replacement document if it is not specified in either the filter or replacement documents. If _id is present in both, the values must be equal.