如何从 Google Cloud Function 中访问 Firestore 数据？

Question

这是我第一次使用 Cloud Functions。我正在尝试进行一个简单的调用来访问存储在我的 Firestore 集合中的所有业务，但是当我尝试记录结果时，我总是得到一个空数组。

所有带有 Firebase/store 的东西都已正确设置，集合名称已正确列出，并已通过记录 db 确认对数据库的访问。我的代码在这里明显有问题吗？谢谢！

// The Cloud Functions for Firebase SDK to create Cloud Functions and setup triggers.
const functions = require('firebase-functions');

// The Firebase Admin SDK to access Firestore.
const admin = require('firebase-admin');
admin.initializeApp();


exports.updateBusinessData = functions.https.onRequest((request, response) => {
  const db = admin.firestore()

  const businessesReference = db.collection('businesses')
  var businesses = []

  const getBusinesses = async () => {
    const businessData = await businessesReference.get()

    businesses = [...businessData.docs.map(doc => ({...doc.data()}))]

    for (let business in businesses) {
      console.log(business)
    }

    response.send("Businesses Updated")

  }

  getBusinesses()
});

Answer 1

我调整了您处理文档的方式，并且我正在从 firestore 获取正确的数据。

exports.updateBusinessData = functions.https.onRequest((request, response) => {
  const db = admin.firestore();

  const businessesReference = db.collection("businesses");
  const businesses = [];

  const getBusinesses = async () => {
    const businessData = await businessesReference.get();

    businessData.forEach((item)=> {
      businesses.push({
        id: item.id,
        ...item.data(),
      });
    });

    // used for of instead of in
    for (const business of businesses) {
      console.log(business);
    }

    response.send(businesses);
  };
  
  getBusinesses();
});

Answer 2

您的getBusinesses 函数是async：然后您需要使用await 调用它。然后，由于您在 Cloud Function 中使用 await，因此您需要将其声明为 async。

以下应该可以解决问题（未经测试）：

exports.updateBusinessData = functions.https.onRequest(async (request, response) => {

    try {
        const db = admin.firestore()

        const businessesReference = db.collection('businesses')
        var businesses = []

        const getBusinesses = async () => {
            const businessData = await businessesReference.get()

            businesses = businessData.docs.map(doc => doc.data());

            for (let business in businesses) {
                console.log(business)
            }
        }

        await getBusinesses();
        // Send back the response only when all the asynchronous
        // work is done => This is why we use await above
        response.send("Businesses Updated")
        
    } catch (error) {
        response.status(500).send(error);
    }

});

---

您可能会更新for (let business in businesses) 循环中的文档以使用await。将其更改为 for … of 循环，如下所示：

for (const business of businesses) {
    await db.collection('businesses').doc(...business...).update(...);
} 

跟随 cmets 更新

你能试试这个并分享你从 console.logs 得到的东西吗？

exports.updateBusinessData = functions.https.onRequest(async (request, response) => {

    try {

        console.log("Function started");
        const db = admin.firestore()

        const businessesReference = db.collection('businesses');
        const businessData = await businessesReference.get();
        console.log("Snapshot size = " + businessData.size);
        const businesses = businessData.docs.map(doc => doc.data());
        for (const business of businesses) {
            console.log(business);
        }
        response.send("Businesses Updated")

    } catch (error) {
        console.log(error);
        response.status(500).send(error);
    }

});