将AWS Lambda与Elastic Search结合使用，从搜索客户端获取未定义

Question

我在学习AWS平台的同时尝试学习Nodejs。

我正在构建一个使用AWS Elastic Search实例的Lambda函数的Lex应用程序。

我的搜索是基本的，正在找到它需要的东西，当我测试我的处理程序时，它没有收到数据。当我将结果记录到控制台时，似乎搜索结果对象不会被传递回处理函数，直到处理程序已经打印结果为止。利用一些控制台日志我得到这样的输出：

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

内容项目是不确定的，而应该是从search.js返回的最高命中目标。我可以看到正在找到TopHit对象，但为什么在返回搜索响应之前打印index.handler函数？

我LAMBDA处理函数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); 
}; 

我弹搜索在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); 
} 

在此先感谢您的任何建议。

Answer 1

您的searchQuestion函数是异步的，它返回一个promise。

您的代码应该是这个样子：

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

你的弹性搜索在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); 
    }); 
    }); 
} 

我希望这有助于:)。