Firebase Node.js异步云函数未完成执行问题求助

你遇到的问题确实是典型的异步流程管理不当导致的——当你在snapshot.forEach里使用async回调时，forEach并不会等待每个异步任务完成，外层的then会直接执行完毕，触发云函数返回，而后面的用户心愿单检查和通知发送还没做完。再加上几个异步函数里没有正确返回Promise，整个流程的异步链条断了，自然会提前结束。

我帮你梳理了具体问题点，并给出修复后的完整代码：

主要问题点分析 #

• forEach不支持异步等待：snapshot.forEach(async (child) => {...}) 这种写法里，forEach会快速遍历所有子节点，不会等待每个checkUserWishlists执行完成，外层的Promise会直接resolve，云函数就提前终止了。
• 异步函数未正确返回Promise：checkUserWishlists、getUserFirestoreFCM里的Promise没有正确返回，导致调用方无法等待这些异步操作完成。
• 嵌套异步逻辑混乱：checkUserWishlists里获取FCM Token的写法用了立即执行异步函数，却没有等待，导致fcmToken可能还没拿到就去发送通知了。

修复后的完整代码 #

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const runtimeOpts = { timeoutSeconds: 180, memory: '1GB' }
admin.initializeApp(functions.config().firebase);

exports.sendAdminNotificationForEmptyWishlists = functions.runWith(runtimeOpts)
.database.ref('/dev/fireNotifCloudFunc')
.onWrite(async () => {
    // 获取所有用户UID，改用Promise.all等待所有用户处理完成
    const ref = admin.database().ref().child('Influencers');
    const snapshot = await ref.once("value");
    
    // 将snapshot转为数组，生成每个用户的处理Promise
    const userPromises = [];
    snapshot.forEach((child) => {
        userPromises.push(checkUserWishlists(child.key));
    });
    
    // 等待所有用户处理完成后再返回
    await Promise.all(userPromises);
});

// 检查用户心愿单，修复异步返回逻辑
async function checkUserWishlists(uid){
    const ref = admin.database().ref().child('Articles').child(uid);
    const snapshot = await ref.once("value");
    
    if(!snapshot.exists()){
        console.log(`用户 ${uid} 在articles节点中不存在`);
        return;
    }
    
    const wishlistsNumber = snapshot.numChildren();
    let wishlistCount = 0;
    let userHasProduct = false;
    
    // 遍历心愿单，简化中断逻辑
    snapshot.forEach((child) => {
        wishlistCount++;
        if(child.child("articles").exists()){
            userHasProduct = true;
            // 找到非空心愿单后直接停止遍历
            return true;
        }
    });
    
    // 所有心愿单都为空的情况
    if(wishlistCount === wishlistsNumber && !userHasProduct){
        try {
            const fcmToken = await getUserFirestoreFCM(uid);
            if(fcmToken){
                await sendPushNotificationToUser(fcmToken, "emptyWishlists");
                console.log(`已给用户 ${uid} 发送空心愿单通知`);
            } else {
                console.log(`用户 ${uid} 未找到FCM Token`);
            }
        } catch(error){
            console.log(`处理用户 ${uid} 时出错:`, error);
        }
    }
}

// 获取FCM Token，改用await并正确返回Promise
async function getUserFirestoreFCM(uid){
    const documentRef = admin.firestore().doc(`users_table/${uid}`);
    const documentSnapshot = await documentRef.get();
    
    if (documentSnapshot.exists) {
        console.log(`用户 ${uid} 的Firestore文档存在`);
        return documentSnapshot.get('fcmToken');
    } else {
        console.log(`用户 ${uid} 的Firestore文档不存在`);
        return null;
    }
}

// 发送通知，保持原逻辑但确保返回Promise
async function sendPushNotificationToUser(fcm, type){
    if(type === "emptyWishlists"){
        const payloadEmptyWishlists = {
            notification: {
                title: `Vos wishlists sont vides !`,
                body: "Hello veuillez ajouter des produits dans vos wishlists pour joindre les influenceurs dans le fil d'acceil, cheers ! ",
                icon: "default",
                sound: "default"
            }
        };
        const options = {
            priority: "high",
            timeToLive: 60 * 60 * 24
        };
        
        return admin.messaging().sendToDevice(fcm, payloadEmptyWishlists, options)
        .then(response => {
            console.log('Notification sent successfully:', response);
            return response;
        })
        .catch(error => {
            console.log('Notification sent failed:', error);
            throw error;
        });
    }
}

关键修改说明 #

1. 用Promise.all替代forEach：将用户节点转为Promise数组，通过Promise.all等待所有用户的心愿单检查和通知发送完成，确保云函数不会提前终止。
2. 统一使用await简化异步逻辑：把所有嵌套的then改为await，让异步流程更清晰，避免回调地狱。
3. 修复函数返回值：确保所有异步函数都返回Promise或具体值，让调用方能正确等待操作完成。
4. 简化遍历中断逻辑：去掉自定义的BreakException，利用forEach的返回值(true)直接终止遍历，代码更简洁。

这样修改后，云函数会完整遍历所有用户，等待每个用户的处理逻辑完成后才会结束，不会再出现提前终止的问题。

内容的提问来源于stack exchange，提问作者Hamza Mansour