Firebase定时Pub Sub Cloud Function部署失败与本地运行异常求助

1. 函数部署失败修复 #

• 先检查package.json的dependencies字段是否添加了axios依赖，云端部署时只会安装该字段下的包，缺失会直接导致代码加载失败
• 修正请求URL格式：axios的请求URL必须带http://或https://前缀，否则会抛出无效URL错误，触发代码加载失败
• 确认Node.js版本兼容，在package.json中指定Firebase官方支持的版本即可，示例："engines": {"node": "18"}

2. 本地Emulator数据库不更新修复 #

• 确认本地函数连接的是本地Emulator而非线上生产库，在代码开头添加如下配置：

if (process.env.FUNCTIONS_EMULATOR) {
  process.env.FIRESTORE_EMULATOR_HOST = "localhost:8080";
}

• 定时调度的函数在Emulator中不会自动运行，需要手动进入Emulator UI的函数页面，点击「触发」按钮才能调试运行
• 打开Emulator的函数日志面板，确认没有被catch捕获的隐藏错误阻塞了数据库操作

3. onRun箭头函数Lint错误修复 #

• 检查项目根目录下的.eslintrc.js配置，将ecmaVersion设置为2017及以上，支持async/await语法：

module.exports = {
  env: {
    es6: true,
    node: true,
  },
  parserOptions: {
    ecmaVersion: 2017,
  },
  // 其余原有配置保留
}

• 如果使用Firebase默认生成的ESLint配置，直接运行npm install eslint@latest --save-dev更新ESLint版本即可解决兼容问题

原有代码还存在两处逻辑错误会导致功能异常：

1. 新增文档参数错误：遍历响应数组时，传入add方法的是完整的parsedResponse数组，而不是单个响应项，会导致所有新增文档都是重复的完整数组内容
2. 多余的JSON序列化：axios默认会自动解析JSON格式的响应，手动调用JSON.parse会抛出格式错误，直接取axiosResponse.data即可

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const axios = require('axios');

// 本地Emulator连接配置
if (process.env.FUNCTIONS_EMULATOR) {
  process.env.FIRESTORE_EMULATOR_HOST = "localhost:8080";
}

admin.initializeApp();
const db = admin.firestore();

exports.scheduledFunction = functions.pubsub
    .schedule("every 2 minutes")
    .timeZone("America/New_York")
    .onRun(async (context) => {
      try {
        // 删除集合全量文档
        const querySnapshot = await db.collection("my_collection").get();
        const deletePromises = querySnapshot.docs.map(doc => doc.ref.delete());
        await Promise.all(deletePromises);

        // 发起外部API请求
        const options = {
          method: "get",
          // 补充http/https协议前缀
          url: "https://www.myUrl.com",
          headers: {
            "Cookie": "...",
          },
        };
        const axiosResponse = await axios(options);
        // 移除多余JSON.parse操作
        const parsedResponse = axiosResponse.data.news_results;

        // 批量写入新文档
        const createPromises = parsedResponse.map(item => db.collection("my_collection").add(item));
        await Promise.all(createPromises);

        return null;
      } catch (error) {
        console.error("运行出错：", error);
        return null;
      }
    });

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