Firebase Cloud Function执行正常但数据无法写入Firestore求助

核心问题 #

你的代码存在两个关键问题导致数据无法写入Firestore：

1. 未等待异步写入操作完成 #

Firestore的create()方法是异步操作，你的代码中没有用await等待其完成，也没有收集所有写入Promise统一等待。Cloud Functions的异步函数会在主逻辑执行完毕后立即终止，导致未完成的写入被强制中断，数据根本没机会写入Firestore。

2. 字段名可能与API返回不匹配 #

你提到console.log(message.messageType)无输出，说明实际API返回的JSON字段名大概率和你定义的messageType不一致（比如API返回的是message-type或message_type），导致无法读取到对应值，甚至可能因字段缺失引发隐性错误。

修复步骤 #

步骤1：等待所有Firestore写入完成 #

修改代码，收集所有写入操作的Promise，最后用Promise.all()等待全部完成：

import axios from "axios";
import { firestore } from 'firebase-admin';

type SpotResponse = {
  response: {
    feedMessageResponse: {
      count: number,
      messages: {
        message: Array<{
          latitude: number,
          longitude: number,
          unixTime: number,
          messageType: string,
          batteryState: string,
        }>,
      },
    },
    errors: Array<{}>,
  },
}

export default async () => {
  const FirestoreInstance = firestore();
  const feedID = '0u88e3hrgRoCDA4JEqkg41U1jhO25PbvW';
  const url = `https://api.findmespot.com/spot-main-web/consumer/rest-api/2.0/public/feed/${feedID}/latest.json`;
  const response = await axios.get<SpotResponse>(url)
  const messages = response.data.response.feedMessageResponse.messages.message;
  console.log(messages);

  // 收集所有写入操作的Promise
  const writeTasks: Promise<firestore.WriteResult>[] = [];

  while (messages.length > 0) {
    const message = messages.shift();
    if (!message) {
      console.warn('Empty message skipped');
      continue;
    }

    // 跳过缺少核心字段的无效数据
    if (!message.latitude || !message.longitude || !message.unixTime) {
      console.warn('Invalid message, missing core fields:', message);
      continue;
    }

    const formatedMessage: Record<string, any> = {
      timestamp: firestore.Timestamp.fromMillis(message.unixTime * 1000),
      location: new firestore.GeoPoint(message.latitude, message.longitude),
    };

    // 仅添加存在的字段，避免写入undefined
    if (message.messageType) formatedMessage.messageType = message.messageType;
    if (message.batteryState) formatedMessage.batteryState = message.batteryState;

    // 将写入任务加入数组
    const writeTask = FirestoreInstance.collection('locationHistory').doc().create(formatedMessage)
      .then((result) => {
        console.log('Document inserted:', formatedMessage, 'at', result.writeTime);
        return result;
      })
      .catch((err) => {
        console.error('Failed to insert document:', err);
        throw err; // 保留错误，让Promise.all能捕获并抛出
      });

    writeTasks.push(writeTask);
  }

  // 等待所有写入任务完成
  await Promise.all(writeTasks);
}

步骤2：核对API返回的真实字段名 #

查看console.log(messages)的输出，确认每条消息的实际字段名：

• 如果API返回的是message-type而非messageType，需要修改类型定义和代码中的引用：

  // 修改类型定义
  type SpotResponse = {
    response: {
      feedMessageResponse: {
        count: number,
        messages: {
          message: Array<{
            latitude: number,
            longitude: number,
            unixTime: number,
            'message-type': string,
            'battery-state': string,
          }>,
        },
      },
      errors: Array<{}>,
    },
  }
  
  // 代码中使用正确的字段名
  if (message['message-type']) formatedMessage.messageType = message['message-type'];
  if (message['battery-state']) formatedMessage.batteryState = message['battery-state'];
  

步骤3：检查Firestore权限 #

确认Cloud Functions使用的服务账号（你的项目ID@appspot.gserviceaccount.com）拥有Firestore的写入权限。默认情况下该账号有足够权限，但若手动修改过IAM规则或Firestore安全规则，需确保账号具备datastore.user角色或直接的写入权限。

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