代码之家 › 专栏 › 技术社区 › PPShein

如何在承诺内停止进程nodejs

firebase-realtime-database firebase node.js

PPShein · 技术社区 · 8 年前

我创建了nodejs来触发(使用cronjobs)firebase实时数据库,如下所示:

var db = admin.database();
var ref = db.ref('myusers');

var promises = [];

function updateUnlocked(isLocked, locked, msisdn) {
    return new Promise(function (resolve, reject) {
        if (isLocked === 1) {
            var startDate = moment(locked);
            var endDate = moment();
            var result = endDate.diff(startDate, 'minutes');
            if (result > 5) {
                var ref = db.ref('myusers/' + msisdn);
                ref.update({isLocked: 2});
            }   
        }
        resolve('done');
    });
}

ref.once('value', function(snapshot) {
    snapshot.forEach(childSnapshot => {
        promises.push(updateUnlocked(childSnapshot.val().isLocked, childSnapshot.val().locked, childSnapshot.key));
    });
});


Promise.all(promises).then(function(data) {
    console.log(data);
}).catch(function(err) {
    console.log('error');
});

请告诉我在哪里可以添加 process.exit() . 谢谢。

2 回复 | 直到 8 年前

lipp 8 年前

必须等待“一次”回调执行。否则promise数组为空,进程可以立即退出。

var db = admin.database();
var ref = db.ref('myusers');


function updateUnlocked(isLocked, locked, msisdn) {
  ...
}

ref.once('value', function(snapshot) {
   const promises = snapshot.map(childSnapshot => {
     return updateUnlocked(childSnapshot.val().isLocked, childSnapshot.val().locked, childSnapshot.key);
   })
   Promise.all(promises).then(() => {
     console.log('done')
     process.exit(0)
   }).catch(err => {
     console.log('error', err)
     process.exit(1)
   })
});

演示控制流程。

setTimeout(() => {
  const x = [1, 2, 3]
  const promises = x.map(i => {
    return new Promise(resolve => resolve(i))
  })
  Promise.all(promises).then(() => {
    console.log('done. process.exit(0) here')
  })
}, 200)

DHIRAJ KATEKAR 8 年前

如果要在成功完成时退出,请参阅以下代码:

Promise.all(promises).then(function(data) {
 console.log(data);
 process.exit(0);

}).catch(function(err) {
console.log('error');
});

如果您也希望在出错时退出,请在catch块中添加process.exit(1)。

推荐文章

TOM · 检查Firebase数据库子项是否已存在,如果不存在,添加它的最佳方法是什么?

1 年前

Guy Sadoun · 如果正在监听的引用被删除,ValueEventListener是否会继续监听?

1 年前

moco · 通过CLI向Firebase实时数据库发送有效JSON文件时出现错误400

2 年前

MN Dijital · 为什么只显示新添加的数据而不显示所有数据?

2 年前

Computable · 未验证请求的Firebase应用程序检查(RTDB)失败模式

2 年前

Harsh Master · 为android应用程序实现自动通知

2 年前

Jakub Olszewski · com.google.firebase.database.DatabaseException:无法将java.lang.Boolean类型的值转换为String这是怎么回事?

2 年前

mkty · 如何使用react中的map打印JSON数据

2 年前

Rohan Raj · 如何在函数中更改firebase实时数据库的子级值,我试过了,但不起作用。请使用kotlin

2 年前

Michel · 使用Firebase CLI选择文档

2 年前