sur l'événement de firebase ne fonctionne pas avec AWS lambda

Question

En cas de d'événement suivant .Une fois fonctionne très bien

'use strict'; 

let firebase = require('firebase'); 

exports.handler = function(event, context) 
{ 
    context.callbackWaitsForEmptyEventLoop = false; 
    firebase.initializeApp({ 
     serviceAccount: {}, 
     databaseURL: "https://harmanconnectedcar-180411.firebaseio.com/" 
    }); 

    firebase.database().ref('events').once('value').then(function(snapshot) { 
     console.log("*************event**********************") 
     console.log (snapshot.val()) ; 
     context.succeed() ; 
    }); 


     var starCountRef = firebase.database().ref('events'); 
starCountRef.on('value', function(snapshot) { 
    console.log("*************snapshot*****snapshot*****************") 
    console.log (snapshot.val()) ; 
    context.succeed(); 
}) 

}

Quand j'essaye starCountRef.on je ne suis pas en mesure de voir les journaux imprimés Une fois que j'ai mis la fonction lambda dans AWS et écrire dans Firebase à partir de la console Firebase, je ne peux pas voir les événements où dois-je voir les journaux comment vérifier l'événement starCountRef.on (je veux dire les journaux en temps réel)

Answer 1

Vous démarrez deux écouteurs asynchrones. Puis, lorsque le premier d'entre eux se termine, vous appelez context.succeed(). À ce stade, Lambda termine votre fonction, de sorte que le second écouteur ne se termine jamais.

Pour que ce code fonctionne, vous devez vous assurer que vous n'appelez que context.succeed() lorsque toutes les données ont été chargées. Un moyen facile de le faire est à l'aide Promise.all():

exports.handler = function(event, context) 
{ 
    context.callbackWaitsForEmptyEventLoop = false; 
    firebase.initializeApp({ 
     serviceAccount: {}, 
     databaseURL: "https://harmanconnectedcar-180411.firebaseio.com/" 
    }); 


    var starCountRef = firebase.database().ref('events'); 

    var promises = []; 
    promises.push(firebase.database().ref('events').once('value')); 
    promises.push(starCountRef.once('value'); 

    Promises.all(promises).then(function(snapshots) { 
     snapshot.forEach(function(snapshot) { 
     console.log(snapshot.val(); 
     }); 
     context.succeed(); 
    }); 
} 

Answer 2

Vous semblez mélanger deux technologies ici.

La méthode onWrite est une construction de Cloud Functions for Firebase, qui (pour autant que je sache) ne peut pas être déployée sur Amazon lambda.

Si vous souhaitez accéder à votre base de données Firebase Realtime à partir d'Amazon Lambda, vous pouvez utiliser le Firebase Admin SDK. Mais cela n'inclut pas un moyen de déclencher votre code à chaque fois que la base de données est écrite.