Firebase Cloud Functions报DEADLINE_EXCEEDED超时错误如何解决

首先需要纠正你的误解：你的代码实际上存在严重的Promise处理问题，这是触发超时的核心诱因之一：

• Array.prototype.forEach不会等待内部的async回调执行完成，你遍历plans.results和projects时使用的async回调都会直接并行触发，还没等所有查询、API拉取、batch.set操作完成，代码就已经执行到await batch.commit()，此时批次要么是空的，要么只写入了部分数据，大量异步操作挂起直到函数超时被强制终止，就会抛出DEADLINE_EXCEEDED错误。
• 循环内嵌套了大量重复的Firestore查询和外部API调用，请求链路过长，加上Firestore单批次写入最多支持500条操作，数据量稍大就会触达批次上限、拉长整体执行时间。
• Cloud Functions默认超时时间较短（1代HTTP函数默认仅60秒，后台函数默认60秒），无法覆盖大量数据的处理时长。

• 替换所有异步遍历的forEach为for...of，或使用Promise.all收集所有异步任务后等待执行完成，确保batch.commit前所有操作都已处理完毕
• 拆分批量写入操作：统计批次内的操作数，满500条就提前提交批次并新建新批次，避免触达Firestore批次写入上限
• 提前拉取所需的映射数据：把循环内重复的projects、users集合查询提前批量拉取，缓存为键值对映射，避免循环内重复发起查询请求
• 调整云函数超时配置：在云函数的部署配置里把超时时间调整到最大允许值（1/2代后台函数、2代HTTP函数最高可设为9分钟）
• 拆分处理流程：如果数据量极大，可将数据拆分后通过Pub/Sub队列分发为多个子任务并行处理，避免单函数承担所有处理压力
• 优化外部API调用：尽量将多次单查询API请求合并为批量查询，添加本地缓存减少重复调用耗时

if (plans.results.length !== 0) {
    let batch = db.batch()
    let batchOperationCount = 0
    const BATCH_LIMIT = 500 // Firestore单批次操作上限

    try {
        // 替换forEach为for...of等待异步操作完成
        for (const plan of plans.results) {
            const jiraKey = plan.planItem.self.split('/').pop()
            const projects = await db.collection('projects').where('jiraKey', '==', jiraKey).get()
            
            if (projects.empty) {
                const key = "tempo_plan_" + plan.jiraWorkLogId + "_no_ref_project"
                const message = "Impossible d'ajouter le plan : " + plan.jiraWorkLogId + ", il n'appartient à aucun projet de la base de données"
                await notifications.addNotifications(db, key, message)
                continue
            }

            // 替换内部async forEach为for...of
            for (const project of projects.docs) {
                const wyzioProjectId = project.data().wyzioId
                const jiraUserId = plan.assignee.self.split('=').pop()
                const username = await user.findOne('user?accountId=' + jiraUserId)
                
                if (username === null) continue

                let wyzioUserId
                const users = await db.collection('users').where('name', '==', username).get()
                if (!users.empty) {
                    wyzioUserId = users.docs[0].data().id
                }

                batch.set(
                    db.collection('plans').doc(JSON.stringify(plan.id)),
                    {
                        'TempoId': plan.id,
                        'jiraKey': jiraKey,
                        'projectId': wyzioProjectId,
                        'userId': wyzioUserId,
                        'username': username,
                        'startDate': plan.startDate,
                        'values': plan.dates.values,
                        'status': 1,
                        'syncStatus': 1
                    }, 
                    { merge: true }
                )
                batchOperationCount++

                // 触达批次上限时提前提交
                if (batchOperationCount >= BATCH_LIMIT) {
                    await batch.commit()
                    batch = db.batch()
                    batchOperationCount = 0
                }
            }
        }

        // 提交剩余的批次操作
        if (batchOperationCount > 0) {
            await batch.commit()
        }
        await incrementOffsetTempo(db, 'tempo_plans')
        console.log("--- tempo_plans_done ---")
    } catch (err) {
        const key = "tempo_plan_error_sync"
        const message = "Impossible d'ajouter les plans, veuillez contrôler leurs informations"
        await notifications.addNotifications(db, key, message)
    }
}

内容的提问来源于stack exchange，提问作者MVT KVM