Firebase 数据库按顺序获取所有价值 Cloud Functions

Question

我为 Firebase Cloud Functions 开发。我有一个这样的 Firebase 实时数据库：

----- myData 
      -------eqewrwrepere (this one is a device token)
                         ---------Lta+sde-fer (this one is a firebase id)
                                  firstvalue  : "a"
                                  secondvalue : "b"

                        ----------Qrgd+ad-qdda (this one is second firebase id)
                                  firstvalue  : "c"
                                  secondvalue : "d"

      -------eqwerSAsdqe (this one is another device token)
                        ---------Lta+sde-fer (this one is a firebase id)
                                 firstvalue  : "x"
                                 secondvalue : "y"

                       ----------Qrgd+ad-qdda (this one is second firebase id)
                                 firstvalue  : "z"
                                 secondvalue : "t"

我通过这段代码获取这些数据。使用此代码，我获取所有数据并将它们放入一个数组。获取完成后，我循环该数组以查找项目。我是一名 iOS 开发人员，所以我是 NodeJS 的新手。这是我想做的：

1. 为每个数据库数据获取firstvalue。
2. 使用每个数据库数据的第一个值发出 api 请求。
3. Api 返回一张图片。
4. 写入图像临时目录。
5. 为 visionApi 处理此图像。
6. 提取文本。
7. 更新数据库。
8. 为 deviceToken 发送通知

现在我可以在我的数组中检索数据库项目。当我在 for 循环中发出请求时，请求称为异步。所以for循环继续，但请求响应或写入文件和视觉处理只执行一次。

在for循环中，获取databasearray[0]，发出请求，写入文件，使用vision api处理它，更新数据库并进入下一个databasearray[1]项。

我在不同的页面上读到了Promises。但是没看懂。

谢谢。

'use strict';

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp(functions.config().firebase);
var request = require('request');
var fs = require('fs');
//var fs = require("fs");
// Get a reference to the Cloud Vision API component
const Vision = require('@google-cloud/vision');
const vision = new Vision.ImageAnnotatorClient();
// Imports the Google Cloud client library
//const {Storage} = require('@google-cloud/storage');
var fs = require("fs");
var os = require("os");
var databaseArray = [];


exports.hourly_job = functions.pubsub
.topic('hourly-job')
.onPublish((event) => {
    console.log("Hourly Job");


    var db = admin.database();
    var ref = db.ref("myData")


    ref.once("value").then(function(allData) {

        allData.forEach(function(deviceToken) {

            deviceToken.forEach(function(firebaseIDs) {

                var deviceTokenVar = deviceToken.key;
                var firebaseIDVar = firebaseIDs.key;
                var firstvalue = firebaseIDs.child("firstvalue").val();
                var secondvalue = firebaseIDs.child("secondvalue").val();


                var items = [deviceTokenVar, firebaseIDVar, firstvalue, secondvalue];

                databaseArray.push([...items]);


            });

        });
        return databaseArray;
    }).then(function(databasem) {

        var i;
        for (i = 0; i < databaseArray.length; i++) {

            var databaseArrayDeviceToken = databaseArray[i][0];
            console.log("DeviceToken: " + databaseArrayDeviceToken);

            var databaseArrayFirebaseID = databaseArray[i][1];
            console.log("FirebaseID: " + databaseArrayFirebaseID);

            var databaseArrayfirstvalue = databaseArray[i][2];
            console.log("firstval: " + databaseArrayfirstvalue);

            var databaseArraysecondval = databaseArray[i][3];
            console.log("Second: " + databaseArraysecondval);


            var url = "http://api.blabla" + databaseArrayfirstvalue;

            /////////////here make a request, pause loop, process returned image, but how //////////////////////         
            request.get({
                    url: url,
                    encoding: 'binary'
                }, function(error, httpResponse, body) {


                    if (!error && httpResponse.statusCode == 200) {

                        fs.writeFileSync('/tmp/processed.jpg', body, 'binary')
                        console.log("file written");
                    })

            }

        });

        return true;
    });

Answer 1

我发现 Mocas 的解决方案有帮助。这是解决方案。我在代码中使用 async/await 函数。现在 for 循环等待函数响应。但现在我有不同的问题。我认为主要异步功能因等待而挂起。然后下一个每小时触发，它再次运行。因此控制台日志在 for 循环中显示 15-16-17 或更多“i”值。我在数据库数组中有 4 个元素，但控制台日志每小时显示的数量不止这个。而且每次都在增加。所以我想我应该在超时后取消这个等待功能。但我不知道怎么做。这是代码：

    use strict';

    const functions = require('firebase-functions');
    const admin = require('firebase-admin');
    admin.initializeApp(functions.config().firebase);
    var request = require('request-promise').defaults({ encoding: null });
    var fs = require('fs');
    // Get a reference to the Cloud Vision API component
    const Vision = require('@google-cloud/vision');
    const vision = new Vision.ImageAnnotatorClient();
    var os = require("os");
    var databaseArray = [];
    var uniqueFilename = require('unique-filename')

    exports.hourly_job = functions.pubsub
      .topic('hourly-job')
      .onPublish((event) => {
        console.log("Hourly Job");




        var db = admin.database();
        var ref = db.ref("myData")


       ref.once("value").then(function(allData) {

       allData.forEach(function(deviceToken) {

              deviceToken.forEach(function(firebaseIDs) {

            var deviceTokenVar = deviceToken.key;
            var firebaseIDVar = firebaseIDs.key;
            var firstvalue = firebaseIDs.child("firstvalue").val();
            var secondvalue = firebaseIDs.child("secondvalue").val();


            var items = [deviceTokenVar, firebaseIDVar, firstvalue, secondvalue];

            databaseArray.push([...items]);
            //console.log(databaseArray);   
    //return true;
    });   
    //return true;
    });
    return databaseArray;
    }).then(function (databasem) {

        main().catch(console.error);                
            });

    return true;
    });

    const main = async () => {

        var i;
        for (i = 0; i < databaseArray.length; i++) {

            console.log("Database Arrays " + i + ". elements: ");


            var databaseArrayDeviceToken = databaseArray[i][0];
            console.log("DeviceToken: " + databaseArrayDeviceToken);

            var databaseArrayFirebaseID = databaseArray[i][1];
            console.log("FirebaseID: " + databaseArrayFirebaseID);

            var databaseArrayfirst = databaseArray[i][2];
            console.log("first: " + databaseArrayfirst);

            var databaseArraysecond = databaseArray[i][3];
            console.log("second: " + databaseArraysecond);



             if (databaseArrayfirst != "") {

            var apiUrl = "http://api.blabla;

            try {
            const apiBody = await request.get(apiUrl); 


        ///////////////////////////vison start//////////////////////    

            const visionResponseBody = await vision.documentTextDetection(apiBody)

             var visionResponse = visionResponseBody[0].textAnnotations[0].description;

             console.log("Vision response text " + visionResponse );

             ...some logic here about response...

    /////////////////////////////////////////////////   
             var getdatabasevar = await admin.database().ref("myData/" + databaseArrayDeviceToken + "/" + databaseArrayFirebaseID);

             await getdatabasevar.update({
             "firstvalue": visionResponse
             });  


    /////////////////////////////////////////////////  

             var getanotgerdatabasevar = await admin.database().ref("myData/" + databaseArrayDeviceToken + "/" + databaseArrayFirebaseID + "/" + "secondvalue");

             await getanotgerdatabasevar.once("value")
              .then(function(var) {

              ..some logic..


              //send notification


              });
    } catch (error) {
            console.error(error);
            }
    ///////////////////////////vison end//////////////////////  


        }

    };
    return true;
    };