草庐IT

mongodb - 了解为什么 MongoDB 在对整个集合执行 find() 操作期间会跳过某些文档

coder 2023-10-30 原文

因此,我们在工作场所使用 MongoDB 将有关客户的某些信息存储在名为 customers 的集合中。对于一项临时任务,我需要遍历整个集合并对每个文档进行一些处理,这意味着扫描集合中的每个文档而不遗漏任何文档至关重要。

这是我正在运行的查询 -

db.customers.find({}, {"cid":1, "name":1})

customers 集合在 cid 字段上有一个索引,这是查询中 execution-stats 的结果 -

"executionStages" : {
            "stage" : "PROJECTION",
            "nReturned" : 19841,
            "executionTimeMillisEstimate" : 10,
            "works" : 19843,
            "advanced" : 19841,
            "needTime" : 1,
            "needYield" : 0,
            "saveState" : 155,
            "restoreState" : 155,
            "isEOF" : 1,
            "invalidates" : 0,
            "transformBy" : {
                "cid" : 1,
                "name":1
            },
            "inputStage" : {
                "stage" : "COLLSCAN",
                "nReturned" : 19841,
                "executionTimeMillisEstimate" : 0,
                "works" : 19843,
                "advanced" : 19841,
                "needTime" : 1,
                "needYield" : 0,
                "saveState" : 155,
                "restoreState" : 155,
                "isEOF" : 1,
                "invalidates" : 0,
                "direction" : "forward",
                "docsExamined" : 19841
            }
        }

我面临的问题是,当我运行此查询时,MongoDB 没有在游标中包含一些 cid,理想情况下它们应该存在。那些 cid 在查询开始运行之前属于集合的一部分。当我稍后再次运行相同的查询时,碰巧返回了这些文档,但丢失了一些其他文档。

根据我在问这个问题之前阅读的内容,它看起来像 Reads may miss matching documents that are updated during the course of the read operation in MongoDB .然而,这篇文章似乎暗示这仅在查询使用索引时发生,而不是在整个集合扫描期间发生,而这正是我正在做的。我的查询似乎没有使用任何索引,所以我希望不会遇到这个问题。但是,这也确实发生在我的情况下。

那么,两个问题:

  1. 我对问题的理解是否正确?
  2. 如何解决这个问题并检索 customers 集合中的所有现有文档而不丢失任何文档?

谢谢

最佳答案

  1. 您引用的文章提到,如果扫描整个集合,写入可能会更改文档并在文档增长并需要移动时导致集合文档的重新排序。作者的解决方案是使用一个索引,以确保在游标迭代中不会遗漏任何文档。因此,"natural order"在迭代期间可以是易变的。

  2. 我建议使用稳定的索引进行扫描。在你的情况下, db.customers.find({}, {"cid":1, "name":1}).hint({cid: 1}) 将导致索引扫描成为查询规划器的获胜计划(确认 db.customers.find({}, {"cid":1, "name":1}).hint({cid: 1}) .explain()).

关于mongodb - 了解为什么 MongoDB 在对整个集合执行 find() 操作期间会跳过某些文档,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49571179/

有关mongodb - 了解为什么 MongoDB 在对整个集合执行 find() 操作期间会跳过某些文档的更多相关文章

  1. ruby - 为什么我可以在 Ruby 中使用 Object#send 访问私有(private)/ protected 方法? - 2

    类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc

  2. ruby-on-rails - Rails - 子类化模型的设计模式是什么? - 2

    我有一个模型:classItem项目有一个属性“商店”基于存储的值,我希望Item对象对特定方法具有不同的行为。Rails中是否有针对此的通用设计模式?如果方法中没有大的if-else语句,这是如何干净利落地完成的? 最佳答案 通常通过Single-TableInheritance. 关于ruby-on-rails-Rails-子类化模型的设计模式是什么?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.co

  3. ruby-openid:执行发现时未设置@socket - 2

    我在使用omniauth/openid时遇到了一些麻烦。在尝试进行身份验证时,我在日志中发现了这一点:OpenID::FetchingError:Errorfetchinghttps://www.google.com/accounts/o8/.well-known/host-meta?hd=profiles.google.com%2Fmy_username:undefinedmethod`io'fornil:NilClass重要的是undefinedmethodio'fornil:NilClass来自openid/fetchers.rb,在下面的代码片段中:moduleNetclass

  4. ruby - 什么是填充的 Base64 编码字符串以及如何在 ruby​​ 中生成它们? - 2

    我正在使用的第三方API的文档状态:"[O]urAPIonlyacceptspaddedBase64encodedstrings."什么是“填充的Base64编码字符串”以及如何在Ruby中生成它们。下面的代码是我第一次尝试创建转换为Base64的JSON格式数据。xa=Base64.encode64(a.to_json) 最佳答案 他们说的padding其实就是Base64本身的一部分。它是末尾的“=”和“==”。Base64将3个字节的数据包编码为4个编码字符。所以如果你的输入数据有长度n和n%3=1=>"=="末尾用于填充n%

  5. ruby - 解析 RDFa、微数据等的最佳方式是什么,使用统一的模式/词汇(例如 schema.org)存储和显示信息 - 2

    我主要使用Ruby来执行此操作,但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式,例如使用这个yaml文件,它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i

  6. ruby - 为什么 4.1%2 使用 Ruby 返回 0.0999999999999996?但是 4.2%2==0.2 - 2

    为什么4.1%2返回0.0999999999999996?但是4.2%2==0.2。 最佳答案 参见此处:WhatEveryProgrammerShouldKnowAboutFloating-PointArithmetic实数是无限的。计算机使用的位数有限(今天是32位、64位)。因此计算机进行的浮点运算不能代表所有的实数。0.1是这些数字之一。请注意,这不是与Ruby相关的问题,而是与所有编程语言相关的问题,因为它来自计算机表示实数的方式。 关于ruby-为什么4.1%2使用Ruby返

  7. ruby - ruby 中的 TOPLEVEL_BINDING 是什么? - 2

    它不等于主线程的binding,这个toplevel作用域是什么?此作用域与主线程中的binding有何不同?>ruby-e'putsTOPLEVEL_BINDING===binding'false 最佳答案 事实是,TOPLEVEL_BINDING始终引用Binding的预定义全局实例,而Kernel#binding创建的新实例>Binding每次封装当前执行上下文。在顶层,它们都包含相同的绑定(bind),但它们不是同一个对象,您无法使用==或===测试它们的绑定(bind)相等性。putsTOPLEVEL_BINDINGput

  8. ruby - Infinity 和 NaN 的类型是什么? - 2

    我可以得到Infinity和NaNn=9.0/0#=>Infinityn.class#=>Floatm=0/0.0#=>NaNm.class#=>Float但是当我想直接访问Infinity或NaN时:Infinity#=>uninitializedconstantInfinity(NameError)NaN#=>uninitializedconstantNaN(NameError)什么是Infinity和NaN?它们是对象、关键字还是其他东西? 最佳答案 您看到打印为Infinity和NaN的只是Float类的两个特殊实例的字符串

  9. ruby-on-rails - 如果 Object::try 被发送到一个 nil 对象,为什么它会起作用? - 2

    如果您尝试在Ruby中的nil对象上调用方法,则会出现NoMethodError异常并显示消息:"undefinedmethod‘...’fornil:NilClass"然而,有一个tryRails中的方法,如果它被发送到一个nil对象,它只返回nil:require'rubygems'require'active_support/all'nil.try(:nonexisting_method)#noNoMethodErrorexceptionanymore那么try如何在内部工作以防止该异常? 最佳答案 像Ruby中的所有其他对象

  10. ruby - Chef 执行非顺序配方 - 2

    我遵循了教程http://gettingstartedwithchef.com/,第1章。我的运行list是"run_list":["recipe[apt]","recipe[phpap]"]我的phpapRecipe默认Recipeinclude_recipe"apache2"include_recipe"build-essential"include_recipe"openssl"include_recipe"mysql::client"include_recipe"mysql::server"include_recipe"php"include_recipe"php::modul

随机推荐