Блог

Это мой первый раз, когда я использую облачные функции. Я пытаюсь сделать простой вызов, чтобы получить доступ ко всем предприятиям, хранящимся в моей коллекции Firestore, но когда я пытаюсь зарегистрировать результаты, я всегда получаю пустой массив.

Все вещи в/ Firebase/хранилище настроены правильно, имя коллекции указано правильно, и подтвержден доступ к базе данных путем входа в БД. Есть ли что-то явно неправильное в моем коде здесь? Спасибо!

 // 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()
});
 

Я изменил способ обработки документов, и я получаю правильные данные из 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();
});
 

Ваша getBusinesses функция такова async : затем вам нужно вызвать ее с await помощью . Затем, поскольку вы используете 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(...);
} 
 

Обновите после комментариев

Можете ли вы попробовать с этим и поделиться тем, что вы получаете из 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);
    }

});