如何阻止Firebase Firestore在批量写入进行时发起新批量写入？

一、先修复代码里的异步逻辑漏洞 #

你当前的代码存在异步顺序错误：循环里用getDoc().then()是异步执行的，导致判断i === response.events.length - 1时，前面的文档检查请求可能还没完成，batch里的操作没加全就提交了，多个这样的无效批量操作会加剧Firestore的写入队列压力。

改成用await和Promise.all确保所有操作都添加到batch后再提交：

$.ajax(apiMLB).done(async (response) => {
    try {
        const batch = writeBatch(db);
        // 收集所有文档检查的异步任务
        const docTasks = response.events.map(async (ev) => {
            const docRef = doc(db, "events", `${ev.id}`);
            const docSnap = await getDoc(docRef);
            if (docSnap.exists()) {
                batch.update(docRef, ev);
            } else {
                batch.set(docRef, ev);
            }
        });
        // 等所有任务完成再提交batch
        await Promise.all(docTasks);
        console.log("提交批量操作:", batch);
        await batch.commit();
    } catch (e) { 
        console.error("写入失败:", e); 
    }
});

二、控制写入并发，避免重叠 #

方法1：用状态标记跳过并发写入 #

全局维护一个标记，只有当没有写入在执行时才发起新的批量写入：

// 全局标记：是否正在执行Firestore写入
let isWriting = false;

// 封装通用的批量写入函数
async function batchWriteEvents(events) {
    if (isWriting) {
        console.log("已有写入任务在跑，跳过本次");
        return;
    }
    isWriting = true;
    try {
        const batch = writeBatch(db);
        const docTasks = events.map(async (ev) => {
            const docRef = doc(db, "events", `${ev.id}`);
            const docSnap = await getDoc(docRef);
            docSnap.exists() ? batch.update(docRef, ev) : batch.set(docRef, ev);
        });
        await Promise.all(docTasks);
        await batch.commit();
        console.log("批量写入完成");
    } catch (e) {
        console.error("写入出错:", e);
    } finally {
        // 无论成功失败，都重置标记
        isWriting = false;
    }
}

// 三个API请求的调用方式
$.ajax(apiMLB).done(async (res) => await batchWriteEvents(res.events));
$.ajax(apiNFL).done(async (res) => await batchWriteEvents(res.events));
$.ajax(apiCollegeFootball).done(async (res) => await batchWriteEvents(res.events));

方法2：用任务队列串行执行所有写入 #

如果不想跳过任务，而是把后续写入排队等待，可以用队列管理，确保任务按顺序执行：

const writeQueue = [];
let isProcessing = false;

async function runQueue() {
    if (isProcessing || writeQueue.length === 0) return;
    isProcessing = true;
    // 取出第一个任务执行
    const task = writeQueue.shift();
    try {
        await task();
    } catch (e) {
        console.error("队列任务失败:", e);
    } finally {
        isProcessing = false;
        // 继续执行下一个任务
        runQueue();
    }
}

// 添加任务到队列
function addWriteTask(events) {
    writeQueue.push(async () => {
        const batch = writeBatch(db);
        const docTasks = events.map(async (ev) => {
            const docRef = doc(db, "events", `${ev.id}`);
            const docSnap = await getDoc(docRef);
            docSnap.exists() ? batch.update(docRef, ev) : batch.set(docRef, ev);
        });
        await Promise.all(docTasks);
        await batch.commit();
        console.log("队列任务完成");
    });
    runQueue();
}

// API请求调用
$.ajax(apiMLB).done(res => addWriteTask(res.events));
$.ajax(apiNFL).done(res => addWriteTask(res.events));
$.ajax(apiCollegeFootball).done(res => addWriteTask(res.events));

三、额外优化建议 #

1. 省去文档存在性检查：Firestore的set方法支持merge: true参数，直接用batch.set(docRef, ev, { merge: true })就能实现“存在则更新，不存在则创建”，不用再调用getDoc，减少网络请求，提升效率：

   // 替换原有的判断逻辑
   batch.set(docRef, ev, { merge: true });
   

2. 错开API请求时间：不要同时发起三个API请求，比如MLB在第0秒，NFL在第10秒，大学橄榄球在第20秒，避免三个批量写入同时触发。
3. 调整请求间隔：30秒一次可能过于频繁，根据数据更新频率调整为1分钟或更久，减轻Firestore压力。

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