From 3d93667e2b332ff6b68ac0672638ea082366f6f1 Mon Sep 17 00:00:00 2001 From: barisusakli Date: Thu, 20 Apr 2017 18:10:31 -0400 Subject: [PATCH] update update script to batch --- src/upgrade.js | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/src/upgrade.js b/src/upgrade.js index 8cba76974d..0621055370 100644 --- a/src/upgrade.js +++ b/src/upgrade.js @@ -440,14 +440,21 @@ Upgrade.upgrade = function (callback) { function (next) { if (isRedisSessionStore) { var rdb = require('./database/redis'); + var batch = require('./batch'); var client = rdb.connect(); async.waterfall([ function (next) { client.keys('sess:*', next); }, function (sessionKeys, next) { - async.eachSeries(sessionKeys, function (key, next) { - client.del(key, next); + batch.processArray(sessionKeys, function (keys, next) { + var multi = client.multi(); + keys.forEach(function (key) { + multi.del(key); + }); + multi.exec(next); + }, { + batch: 1000, }, next); }, ], function (err) {