如何使用 Async/Await 来保持执行？ [关闭]

Question

我正在尝试根据某些参数的验证来获取用户 ID。问题是代码没有按正确的顺序！！

执行

输出是

1. KlFHdAgDUUUIKaPeObs9RiSBlOp1
2. 通知正确
3. 动物真实

输出应该是

4. 通知正确
5. 动物真实
6. KlFHdAgDUUUIKaPeObs9RiSBlOp1

exports.bulkMsg = functions.firestore
    .document('/bulkMsgs/{bulkMsgsId}').onUpdate(async(snap, context) => {

        function processBulKMsg(onUsers) {
            anPromises = [];
            notPromises = [];

            onUsers.forEach((oneUser) => {
                var status = false;
                if (oneUser.id === 'KlFHdAgDUUUIKaPeObs9RiSBlOp1') {


                    const onNot = admin.firestore().collection('users').doc(oneUser.id).collection('notifications').get().then(oneNot => {
                        if (notNumStatus === true) {
                            if ((oneNot.size >= notNumMin) && (oneNot.size <= notNumMax)) {
                                status = status ? true : false;
                            } else {
                                status = false;
                            }
                        }
                        console.log('Notifications', status);
                        return oneNot;
                    }).catch(err => {
                        console.log('Error getting notifications', err);
                        return null;
                    });

                    notPromises.push(onNot);


                    const allAn = admin.firestore().collection('users').doc(oneUser.id).collection('animals').get().then(oneAn => {
                        if (anCountStatus === true) {
                            if ((oneAn.size >= inFarmMin) && (oneAn.size <= inFarmMax)) {
                                status = status ? true : false;
                            } else {
                                status = false;
                            }
                        }
                        console.log('Animals', status);
                        return oneAn;
                    }).catch(err => {
                        console.log('Error getting animals', err);
                        return null;
                    });

                    anPromises.push(allAn);

                    if (status) {
                        console.log(oneUser.id);
                    }

                }
            });
            return Promise.all([anPromises, notPromises]);
        }

        return admin.firestore().collection('users/')
            .where("notification", "==", "true")
            .get().then(onUsers => {
                return processBulKMsg(onUsers);
            }).catch(err => {
                console.log('Error getting user', err);
                return null;
            });

    });

Answer 1

代码按预期工作。数据从 Firestore 异步加载，在加载数据时，您的主代码路径会继续执行。

此代码位于您的processBulKMsg 函数的主代码路径中：

if (status) {
    console.log(oneUser.id);
}

所以当你调用processBulKMsg 时，这个console.log 会立即打印出来。如果你想稍后记录用户 ID，你应该只在 promise 解决后调用它。像这样的

return admin.firestore().collection('users/')
    .where("notification", "==", "true")
    .get().then(onUsers => {
        let result = processBulKMsg(onUsers);
        console.log(oneUser.id);
        return result;
    })...

---

或者，您可以将oneUser.id 添加到承诺数组中，然后从那里使用它。

所以在processBulKMsg，你会这样做：

...
return Promise.all([anPromises, notPromises, oneUser.id]);

然后

return admin.firestore().collection('users/')
    .where("notification", "==", "true")
    .get().then(onUsers => {
        let result = processBulKMsg(onUsers);
        console.log(result[result.length -1]);
        return result;
    })...