AWS Lambda mit Elastic Search verwenden, Undefined vom Such-Client erhalten

Question

Ich versuche Nodejs zu lernen und gleichzeitig AWS-Plattform zu lernen.

Ich erstelle eine Lex-Anwendung, die eine Lambda-Funktion mit einer AWS Elastic Search-Instanz verwendet.

Meine Suche ist grundlegend und findet, was es benötigt, die Sache ist, wenn ich meinen Handler teste, er empfängt die Daten nicht. Wenn ich die Ergebnisse in der Konsole protokolliere, scheint es so, als ob das Suchergebnisobjekt erst dann an die Handlerfunktion zurückgegeben wird, nachdem der Handler die Ergebnisse bereits gedruckt hat. Mit einigen Konsolenprotokollen ich diese Ausgabe:

Starting handler function 
Starting search 
{ dialogAction: 
    { type: 'Close', 
    fulfillmentState: 'Fulfilled', 
    message: { contentType: 'PlainText', content: undefined } } } 
Top hit: [object Object] 

Der Inhalt Artikel ist nicht definiert, sondern stattdessen das Top Hit Objekt sein, das von Search.js zurückgegeben. Ich kann sehen, dass das TopHit-Objekt gefunden wird, aber warum druckt die index.handler-Funktion, bevor die Suchantwort zurückgegeben wird?

Meine Lambda-Handler-Funktion in index.js:

const search = require("./search.js"); 
exports.handler = (event, context, callback) => { 

console.log("Starting handler function"); 

const questionReq = event.currentIntent.slots.question; 
//console.log(questionReq); 
// call Exported function from search js.Pass in string as question 
const results = search.searchQuestion(questionReq); 

const eventResponse = { 
    "dialogAction": { 
    "type": "Close", 
    "fulfillmentState": "Fulfilled", 
    "message": { 
     "contentType": "PlainText", 
     "content": results 
    } 
    } 
}; 

callback(null, eventResponse); 
}; 

Mein Elastic Suche in Search.js:

const client = require('./connection.js'); 

exports.searchQuestion = function(question) 
{ 
    var topHit = ""; 
    console.log("Starting search"); 
    client.search({ 
     index: 'library', 
     type: 'dsa', 
     body: { 
     query: { 
      match: { "q": question } 
     }, 
     } 
    }).then(function (resp){ 
     topHit = resp.hits.hits[0]; 
     console.log("Top hit: " + topHit); 
    }, function(err){ 
     console.trace(err.message); 
    }) 
    return JSON.stringify(topHit); 
} 

Vielen Dank im Voraus für alle Anregungen.

Answer 1

Ihre searchQuestion-Funktion ist asynchron, sie gibt ein Versprechen zurück.

Der Code sollte wie folgt aussehen:

const search = require("./search.js"); 
exports.handler = (event, context, callback) => { 
    console.log("Starting handler function"); 

    const questionReq = event.currentIntent.slots.question; 
    //console.log(questionReq); 
    // call Exported function from search js.Pass in string as question 
    search.searchQuestion(questionReq) 
     .then(result => { 
      const eventResponse = { 
       "dialogAction": { 
        "type": "Close", 
        "fulfillmentState": "Fulfilled", 
        "message": { 
         "contentType": "PlainText", 
         "content": results 
        } 
       } 
      }; 
      callback(null, eventResponse); 
     }); 
}; 

Ihre Elastic Suche in Search.js:

const client = require('./connection.js'); 

exports.searchQuestion = function(question) 
{ 
    return new Promise(function(resolve, reject) { 
     var topHit = ""; 
     console.log("Starting search"); 
     client.search({ 
     index: 'library', 
     type: 'dsa', 
     body: { 
      query: { 
      match: { "q": question } 
      }, 
     } 
    }).then(function (resp){ 
     topHit = resp.hits.hits[0]; 
     return resolve(topHit); 
    }, function(err){ 
     console.trace(err.message); 
    }); 
    }); 
} 

Ich hoffe, das hilft :).