使用 Labix mgo API对于 MongoDB，我正在尝试对分片集合执行增量操作。我可以使用通常的 mgo.Change 结构在未分片集合上很好地执行此操作，但是当我尝试在分片集合上执行此操作时，出现错误:完整分片键必须在更新对象中以进行收集: db_name.collection_name

用于未分片集合的原始代码如下所示:

            change := mgo.Change{
                ReturnNew: true,
                Upsert: true,
                Update: bson.M{
                    "$setOnInsert": bson.M{
                        "ci": r.Ci,
                        "dt": r.Dt,
                        "zi": r.Zi,
                    },
                    "$inc": &data,
                },
            }

            _, err := collection.Upsert(bson.M{"_id": id, "ci": r.Ci, "dt": r.Dt, "zi": r.Zi}, change); if err != nil {
                log.Println("FAILURE", err)
            }

但是，当我切换到分片集合时，在键 {ci: 1, dt: 1, zi: 1} 上分片，我得到了上面提到的错误。

在尝试调试时，我试图弄清楚 mgo 在幕后发生了什么，并试图直接插入 mongo 终端。

db.collection.update({ "_id" : "98364_2013-12-11", "ci" : "16326", "dt" : "2013-12-11", "zi" : "98364"}, {$setOnInsert: { "ci" : "16326", "dt" : "2013-12-11", "zi" : "98364"} , $inc: {test :1}}, { upsert: true });

但是，这给我带来了一个单独的错误:无法修改分片键的值。 field: ci: "16326"collection: db.collection 这是我想一旦我弄清楚我的初始错误就必须弄清楚的东西，但我觉得它用 $ 抛出这个错误似乎很奇怪setOnInsert 命令因为它不应该修改值，只需在初始插入时设置它。当我删除命令的 $setOnInsert 部分时，所有错误都消失了，但我需要一种方法来确保设置这些值，因为它们在我编写的用于取回数据的查询中很重要。

回到我的主要问题:我确实发现，当我在与 MongoDB 终端交互时重新排列更新和插入文档的顺序时，我遇到了我在通过 mgo 时遇到的错误，所以我尝试非常严格控制 mgo 中传递的文档的顺序。通过切换到 bson.D 更改结构:

            change := bson.D{
                {
                     "Update",
                     bson.D{
                         {"$setOnInsert", bson.D{
                                {"_id", id},
                                {"ci", r.Ci},
                                {"dt", r.Dt},
                                {"zi", r.Zi},
                                },
                         },
                         {"$inc", &data},
                     },
                },
                {
                    "Upsert",
                    true,
                },
            }
            log.Println(change)
            err := collection.Update(bson.D{{"_id", id},{ "ci", r.Ci},{ "dt", r.Dt}, {"zi", r.Zi}},change); if err != nil {
                log.Println("FAILURE", err)
            }

此时，打印变更对象产生:[{Update [{$setOnInsert [{_id 11635_2013-12-11} {ci 3599} {dt 2013-12-11} {zi 11635}]} {$inc 0xc21dd9d8d0}]} {Upsert true}] 我相信这正是我应该根据 Mongo's documentation 以完全正确的顺序作为更改对象传递的内容, 但我仍然得到相同的 full shard key must be in update object for collection: db.collection 错误。

我意识到使用 collection.Find({_id: ... }).Apply(change, ...) 是一种可能的替代方法，当我使用它时它可以正常工作，但在我对未分片集合的测试中，我发现使用 Upsert(或更新)函数可以获得更高的性能(如快 20 倍)，而且速度绝对是一个优先事项，因为我每秒要处理数万个事件。

我已经到了这样的地步，我觉得我已经尝试了我能想到的每一个想法，并且会感谢一双新的眼睛试图帮助我弄清楚正在发生的事情，所以任何帮助都将不胜感激。

最佳答案

mgo.Change类型特定于 Query.Apply方法，它运行 MongoDB findAndModify命令并立即执行任何支持的修改。 Upsert另一方面，方法采用修改文档，该文档将直接提供给 mgo/bson 进行编码。这些修改文件具有相同的format您是否通过 Query.Apply 提供它们(在 mgo.Change 的 Update 字段中)，或通过 Collection.Upsert或 Collection.Update方法。

因此，观察到的错误是由于它试图将 mgo.Change 用作插入的普通结构(换句话说，带有键“returnnew”等的文档)而引起的，这是绝对不是你想要的。例如，您提供的 shell 命令等同于使用 mgo 的直接翻译:

type M map[string]interface{}
err := collection.Upsert(
    M{
        "_id": "98364_2013-12-11",
        "ci":  "16326",
        "dt":  "2013-12-11",
        "zi":  "98364",
    },
    M{
        "$setOnInsert": M{"ci": "16326", "dt": "2013-12-11", "zi": "98364"},
        "$inc":         M{"test": 1},
    },
)

不过，这仍然坏了，但原因不同。正如错误消息中提到的服务器，这是第二次尝试设置分片键。请注意，upsert 操作将使用查询文档中提供的字段，并且 merge both查询文档和修改文档以创建用于插入的最终文档。这意味着 $setOnInsert 文档中的分片键字段与查询文档中的分片键字段是冗余的。

我将改进该领域的文档，以减少人们因使用 mgo.Change 而感到困惑的可能性。抱歉给您带来麻烦。

关于mongodb - 使用 mgo 错误 "full shard key must be in update object for collection:..."更新到分片 MongoDB，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/21266978/