你好 我在启动云引擎的时候遇到以下报错,这是我的reset.js
const AV = require('leanengine')
const Promise = require('bluebird')
//TODO 每天24点 isWorked true设置为false
const _User = AV.object.extend('_User');
AV.Cloud.define('isWorkedReset', async request =>{
//如果request.params.isWorked不存在,则isWorked为true
const isWorked = request.params.isWorked || 'true';
const createQuery = () => {
return new AV.Query(_User).EqualTo('isWorked', isWorked);
};
await isWorkedReset(createQuery, (object) => {
console.log('给一下对象更新isWorked', object.id);
object.set('isWorked', false);
return object.save();
})
console.log('批量更新完成');
});
function isWorkedReset(createQuery, performUpdate, options = {}) {
var batchLimit = options.batchLimit || 1000
var concurrency = options.concurrencyLimit || 3
var ignoreErrors = options.ignoreErrors
function next() {
var query = createQuery()
return query.limit(batchLimit).find().then( results => {
if (results.length > 0) {
return Promise.map(results, (object) => {
return performUpdate(object).catch( err => {
if (ignoreErrors) {
console.error('ignored', err)
} else {
throw err
}
})
}, {concurrency}).then(next)
}
})
}
return next()
}
-
创建时间
19年7月12日
-
最后回复
19年7月12日
-
2
回复
-
1.7K
浏览
-
1
用户