Node.js:Mongoose initializeUnorderedBulk 返回 null

coder 2023-10-28 原文

不久前，我设法编写了一种方法，可以将许多信息批量更新插入到我的数据库中。现在我正在尝试做的是一种清除同一数据库和表上的旧记录的方法。

raidSchema.statics.bulkUpsert = function (raids, callback) {
  var bulk = Raid.collection.initializeUnorderedBulkOp();

  for (var i = 0; i < raids.length; i++) {
    var raid = raids[i];
    var date = new Date();
    bulk.find({id: raid.id, hash: raid.hash}).upsert().update({
      $setOnInsert: {
        ...
      },
      $set: {
        ...
      }
    });
  }

  bulk.execute(callback);
};

这非常有效。然后我这样做了，希望它能清除我不再需要的旧记录:

raidSchema.statics.cleanOldRaids = function (callback) {
  var date = new Date();
  date.setMinutes(date.getMinutes() - 30);

  var bulk = Raid.collection.initializeUnorderedBulkOp();
  bulk.find({$or: [ { maxHealth: {$lte: 0} }, { isComplete: true }, {updatedOn: {$lte: date.getTime()}} ] }).remove();
  bulk.execute(callback);
};

我正在使用此脚本运行此方法，该脚本尝试每 30 分钟运行一次:

var Raid = require('../models/raid');
var async = require('async');

var cleanInterval = 1000 * 60 * 30;

var cleanRaids = function () {
  console.log('cleanRaids: Starting cleaning');

  async.series([
      function (callback) {
        Raid.cleanOldRaids();
        callback(null, 'All servers');
      }],
    function (err, results) {
      if (err) throw err;

      console.log("cleanRaids: Done cleaning (" + results.join() + ")");
      setTimeout(cleanRaids, cleanInterval);
    })
};

cleanRaids();

但是在我运行我的服务器之后它崩溃了，说它无法读取未定义的属性查找:

.../models/raid.js:104
  bulk.find({$or: [ { maxHealth: {$lte: 0} }, { isComplete: true }, {updatedO
       ^
TypeError: Cannot read property 'find' of undefined

我完全迷失了，因为它与 bulkUpsert 方法完美配合，后者由非常相似的代码运行。

有人知道为什么会发生这种情况吗？非常感谢。

最佳答案

这里的问题是 mongoose 还没有连接到数据库，因此没有你通过 .collection 访问器访问的底层驱动程序对象的句柄。

mongoose 方法本身执行了一些“魔法”，实际上是将所有操作排队，直到实际建立数据库连接。即:

Model.find().exec(function(err,docs) { });   // <-- callback queues until connection is ready

但是，如果不存在连接， native 方法将不会返回集合对象:

Model.collection.find({},function(err,docs) { }); <-- collection is undefined

批量方法只返回一个尚未执行的结构，因此在您尝试对该结构调用方法之前不会出现错误。

修复很简单，只需在执行任何代码之前等待连接:

mongoose.connection.on("open",function(err) {
  // body of program in here

});

因此，尽管“ Mongoose 方法”有自己的魔力来“隐藏它”，但在调用 native 方法时需要这样做。唯一逃脱惩罚的方法是当您绝对确定其中一个“mongoose 方法”实际上已经触发，并且已经建立连接时。

安全总比后悔好，因此明智的做法是将主程序的主体初始化和方法放在上面这样的 block 中。

关于Node.js:Mongoose initializeUnorderedBulk 返回 null，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31852797/

有关Node.js:Mongoose initializeUnorderedBulk 返回 null的更多相关文章

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返
ruby - 检查字符串是否包含散列中的任何键并返回它包含的键的值 - 2
我有一个包含多个键的散列和一个字符串，该字符串不包含散列中的任何键或包含一个键。h={"k1"=>"v1","k2"=>"v2","k3"=>"v3"}s="thisisanexamplestringthatmightoccurwithakeysomewhereinthestringk1(withspecialcharacterslike(^&*$#@!^&&*))"检查s是否包含h中的任何键的最佳方法是什么，如果包含，则返回它包含的键的值？例如，对于上面的h和s的例子，输出应该是v1。编辑:只有字符串是用户定义的。哈希将始终相同。最佳答案
ruby - Ruby 中的隐式返回值是怎么回事？ - 2
所以我开始关注ruby，很多东西看起来不错，但我对隐式return语句很反感。我理解默认情况下让所有内容返回self或nil但不是语句的最后一个值。对我来说，它看起来非常脆弱(尤其是)如果你正在使用一个不打算返回某些东西的方法(尤其是一个改变状态/破坏性方法的函数!)，其他人可能最终依赖于一个返回对方法的目的并不重要，并且有很大的改变机会。隐式返回有什么意义？有没有办法让事情变得更简单？总是有返回以防止隐含返回被认为是好的做法吗？我是不是太担心这个了？附言当人们想要从方法中返回特定的东西时，他们是否经常使用隐式返回，这不是让你组中的其他人更容易破坏彼此的代码吗？当然，记录一切并给出
ruby-on-rails - ruby 日期方程不返回预期的真值 - 2
为什么以下不同？Time.now.end_of_day==Time.now.end_of_day-0.days#falseTime.now.end_of_day.to_s==Time.now.end_of_day-0.days.to_s#true 最佳答案因为纳秒数不同:ruby-1.9.2-p180:014>(Time.now.end_of_day-0.days).nsec=>999999000ruby-1.9.2-p180:015>Time.now.end_of_day.nsec=>999999998
ruby - 从 String#split 返回的零长度字符串 - 2
在Ruby1.9.3(可能还有更早的版本，不确定)中，我试图弄清楚为什么Ruby的String#split方法会给我某些结果。我得到的结果似乎与我的预期相反。这是一个例子:"abcabc".split("b")#=>["a","ca","c"]"abcabc".split("a")#=>["","bc","bc"]"abcabc".split("c")#=>["ab","ab"]在这里，第一个示例返回的正是我所期望的。但在第二个示例中，我很困惑为什么#split返回零长度字符串作为返回数组的第一个值。这是什么原因呢？这是我所期望的:"abcabc".split("a")#=>["bc"
"\0"null 的 Ruby 测试？ - 2
我在破坏脚本的字符串中出现了一些奇怪的字符。据我所知，通过putbadstring到控制台，它们是"\0\0\0\0"。我想对此进行测试，以便我可以忽略它们...但是如何呢？以为这就是blank?和empty?的用途？!？:>badstring="\0"=>"\u0000">badstring.blank?NoMethodError:undefinedmethod`blank?'for"\u0000":Stringfrom(irb):97from/Users/meltemi/.rvm/rubies/ruby-2.0.0-p195/bin/irb:16:in`'>badstring.em
ruby - 为什么 Integer.respond_to?( :even? ) 返回 false？ - 2
我一直在研究RubyKoans，我发现about_open_classes.rbkoan很有趣。特别是他们修改Integer#even?方法的最后一个测试。我想尝试一下这个概念，所以我打开了Irb并尝试运行Integer.respond_to?(:even?)，但令我惊讶的是我得到了错误。然后我尝试了Fixnum.respond_to?(:even?)并得到了错误。我还尝试了Integer.respond_to?(:respond_to?)并得到了true，当我执行2.even?时，我也得到了true。我不知道发生了什么。谁能告诉我缺少什么？最佳答案
ruby - Time.to_i 是否总是以 UTC 返回自 EPOCH 以来的秒数？ - 2
无论时间在哪个时区表示，时区差异是否总是被忽略？直觉上，对于那些使用UTC+2的人来说，从EPOCH开始经过的秒数应该更高。然而，事实并非如此。最佳答案 Epoch基于utc时区https://en.wikipedia.org/wiki/Unix_time它与您当前所在的时区无关。关于ruby-Time.to_i是否总是以UTC返回自EPOCH以来的秒数？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.
ruby-on-rails - Ruby 流量控制 : throw an exception, 返回 nil 还是让它失败？ - 2
我在思考流量控制的最佳实践。我应该走哪条路？1)不要检查任何东西并让程序失败(更清晰的代码，自然的错误消息):defself.fetch(feed_id)feed=Feed.find(feed_id)feed.fetchend2)通过返回nil静默失败(但是，“CleanCode”说，你永远不应该返回null):defself.fetch(feed_id)returnunlessfeed_idfeed=Feed.find(feed_id)returnunlessfeedfeed.fetchend3)抛出异常(因为不按id查找feed是异常的):defself.fetch(feed_id
ruby-on-rails - 如何让 Rails View 返回其关联的操作名称？ - 2
我有一个非常简单的Controller来管理我的Rails应用程序中的静态页面:classPagesController我怎样才能让View模板返回它自己的名字，这样我就可以做这样的事情:#pricing.html.erb#-->"Pricing"感谢您的帮助。最佳答案 4.3RoutingParametersTheparamshashwillalwayscontainthe:controllerand:actionkeys,butyoushouldusethemethodscontroller_nameandaction_nam

Node.js:Mongoose initializeUnorderedBulk 返回 null

有关Node.js:Mongoose initializeUnorderedBulk 返回 null的更多相关文章

随机推荐