我必须将 Amazon lex 与 Amazon lambda 集成。我遇到了一个问题。我是新手,所以请帮助我。我想申请使用 Lex 的产品。“我在哪里可以找到肉”和肉将被存储到插槽'SearchProduct' 然后它将在数据库中搜索并通过 lex 回复。就像“我在 4 号过道里找到了肉”
在这里,我可以通过扫描 dynamodb 获得 Aisle no 4 的值,但我无法发送响应。
'use strict';
const AWS = require('aws-sdk');
const docClient = new AWS.DynamoDB.DocumentClient({ region: "us-east-1" });
var reply = ' ';
// --------------- Helpers to build responses which match the structure of the necessary dialog actions -----------------------
function elicitSlot(sessionAttributes, intentName, slots, slotToElicit, message, responseCard) {
return {
sessionAttributes,
dialogAction: {
type: 'ElicitSlot',
intentName,
slots,
slotToElicit,
message,
responseCard,
},
};
}
function close(sessionAttributes, fulfillmentState, message, responseCard) {
return {
sessionAttributes,
dialogAction: {
type: 'Close',
fulfillmentState,
message,
responseCard,
},
};
}
function delegate(sessionAttributes, slots) {
return {
sessionAttributes,
dialogAction: {
type: 'Delegate',
slots,
},
};
}
// ---------------- Helper Functions --------------------------------------------------
// build a message for Lex responses
function buildMessage(messageContent) {
return {
contentType: 'PlainText',
content: messageContent,
};
}
// --------------- Functions that control the skill's behavior -----------------------
/**
* Performs dialog management and fulfillment for ordering a beverage.
* (we only support ordering a mocha for now)
*/
function ItemSearch(intentRequest, callback) {
const outputSessionAttributes = intentRequest.sessionAttributes;
const source = intentRequest.invocationSource;
if (source === 'FulfillmentCodeHook') {
const slots = intentRequest.currentIntent.slots;
const requestProductName = (slots.SearchProduct ? slots.SearchProduct : null);
var scanningParameters = {
TableName: "my table name",
ProjectionExpression: "#pro, Aisle",
FilterExpression: "contains (#pro, :productname)",
ExpressionAttributeNames: {
"#pro": "ProductName",
},
ExpressionAttributeValues: {
":productname": requestProductName
}
};
docClient.scan(scanningParameters, function(err, data) {
if (err) {
callback(close(outputSessionAttributes, 'Fulfilled', { contentType: 'PlainText', content: 'not found' }));
}
else {
console.log(data);
if (data.Count == 0) {
reply = 'not found';
callback(close(outputSessionAttributes, 'Fulfilled', { contentType: 'PlainText', content: 'not found' }));
}
else {
reply = requestProductName + ' can be found in Aisle No: ' + data.Items[0].Aisle;
callback(close(outputSessionAttributes, 'Fulfilled', { contentType: 'PlainText', content: requestProductName + ' can be found in Aisle No: ' + data.Items[0].Aisle }));
}
}
});
}
callback(close(outputSessionAttributes, 'Fulfilled', {
contentType: 'PlainText',
content: `Thanks for using CoffeeBot! ` // i want the reply from the search here but i always end up with null
}));
}
// --------------- Intents -----------------------
/**
* Called when the user specifies an intent for this skill.
*/
function dispatch(intentRequest, callback) {
console.log(`dispatch userId=${intentRequest.userId}, intent=${intentRequest.currentIntent.name}`);
const name = intentRequest.currentIntent.name;
// dispatch to the intent handlers
if (name.startsWith('Product')) {
return ItemSearch(intentRequest, callback);
}
throw new Error(`Intent with name ${name} not supported`);
}
// --------------- Main handler -----------------------
// Route the incoming request based on intent.
// The JSON body of the request is provided in the event slot.
exports.handler = (event, context, callback) => {
console.log(JSON.stringify(event));
try {
console.log(`event.bot.name=${event.bot.name}`);
// fail if this function is for a different bot
if (!event.bot.name.startsWith('Aowi')) {
callback('Invalid Bot Name');
}
dispatch(event, (response) => callback(null, response));
}
catch (err) {
callback(err);
}
};
我正在从搜索中获得回复,但我无法将回复发送给 Lex。内容部分始终为空。
Response:
{
"sessionAttributes": {},
"dialogAction": {
"type": "Close",
"fulfillmentState": "Fulfilled",
"message": {
"contentType": "PlainText",
"content": " "
}
}
}
Lex 将发送名为 'SearchProduct' == 'meat' 的槽。
我不确定我在哪一部分做错了。如果有人可以帮助我改进代码,请不胜感激。谢谢