Dialogflow+外部API+Google Cloud Functions*没有*Firebase：如何返回履行响应？
2022-03-28 00:00:00
dialogflow-es
google-cloud-functions
node.js
javascript
dialogflow-es-fulfillment
我正在尝试构建一个Dialogflow聊天机器人，它通过Google Cloud函数从外部API获取数据，但是没有使用Firebase。尽管进行了广泛的搜索，但我没有找到任何好的示例或模板；似乎所有可用的示例都使用Firebase函数。
我是一个新手程序员，不熟悉Node.js、Promises和所有这些花哨的东西，但我知道即使没有Firebase(我使用的是Google Cloud的付费版本)，也可以通过Dialogflow访问外部API。
我尝试使用以下Dialogflow天气API示例创建我的Google Cloud函数，这是我所能找到的最接近我需要的东西，尽管这也使用了Firebase： https://github.com/dialogflow/fulfillment-weather-nodejs/blob/master/functions/index.js#L72 问题是我的代码在"res.on(‘end’."莱恩和我都不知道为什么。Google Cloud Stackdriver日志只给出了一条相当不具信息性的消息"忽略已完成函数的异常"，但没有告诉我异常是什么。以下是我的index.js代码的编辑版本：
'use strict';
const rpn = require('request-promise-native');
const http = require('http');
const hostAPI = 'my host API URL goes here';
const url = require('url');
const {WebhookClient} = require('dialogflow-fulfillment');
exports.myGoogleCloudSearch = (req, res) => {
const agent = new WebhookClient({request: req, response: res}); // Dialogflow agent
// These are logged in Google Cloud Functions
console.log('Dialogflow Request headers: ' + JSON.stringify(req.headers));
console.log('Dialogflow Request body: ' + JSON.stringify(req.body));
// Default welcome intent, this comes through to Dialogflow
function welcome(agent) {
agent.add('This welcome message comes from Google Cloud Functions.');
}
// Default fallback intent, this also comes through
function fallback(agent) {
agent.add('This is the fallback response from Google Cloud Functions.');
}
function searchMyInfo(agent) {
// get parameters given by user in Dialogflow
const param1 = agent.parameters.param1;
const param2 = agent.parameters.param2;
const param3 = agent.parameters.param3
// this is logged
console.log('Parameters fetched from Dialogflow: ' + param1 + ', ' + param2 + ', ' + param3);
var myUrl = hostAPI + param1 + param2 + param3;
// the URL is correct and also logged
console.log('The URL is ' + myUrl);
// Everything up to here has happened between Dialogflow and Google Cloud Functions
// and inside GCF, and up to here it works
// Next, contact the host API to get the requested information via myUrl
// Using this as an example but *without* Firebase:
// https://github.com/dialogflow/fulfillment-weather-nodejs/blob/master/functions/index.js#L41
function getMyInfo(param1, param2, param3) {
console.log('Inside getMyInfo before Promise'); // this is logged
return new Promise((resolve, reject) => {
console.log('Inside getMyInfo after Promise'); // this is logged
console.log('Should get JSON from ' + myUrl);
rpn.get(myUrl, (res) => {
// The code is run at least up to here, since this is logged:
console.log('Inside rpn.get');
// But then the Google Cloud log just says
// "Ignoring exception from a finished function"
// and nothing below is logged (or run?)
let body = ''; // variable to store response chunks
res.on('data', (chunk) => {body += chunk;}); // store each response chunk
res.on('end', () => {
// this is not logged, so something must go wrong here
console.log('Inside res.on end block');
// Parse the JSON for desired data
var myArray = JSON.parse(body); // fetched JSON parsed into array
console.log(myArray); // not logged
// Here I have more parsing and filtering of the fetched JSON
// to obtain my desired data. This JS works fine for my host API and returns
// the correct data if I just run it in a separate html file,
// so I've left it out of this example because the problem seems
// to be with the Promise(?).
// Create the output from the parsed data
// to be passed on to the Dialogflow agent
let output = agent.add('Parsed data goes here');
console.log(output);
resolve(output); // resolve the promise
}); // res.on end block end
// In case of error
res.on('error', (error) => {
// this is not logged either
console.log('Error calling the host API');
reject();
}); // res.on error end
}); // rpn.get end
}); // Promise end
} // getMyInfo end
// call the host API: this does not seem to work since nothing is logged
// and no error message is returned
getMyInfo(param1, param2, param3).then((output) => {
console.log('getMyInfo call started');
// Return the results of the getMyInfo function to Dialogflow
res.json({'fulfillmentText': output});
}).catch(() => {
// no error message is given either
res.json({'fulfillmentText' : 'There was an error in getting the information'});
console.log('getMyInfo call failed');
});
} // searchMyInfo(agent) end
// Mapping functions to Dialogflow intents
let intentMap = new Map();
intentMap.set('Default Welcome Intent', welcome); // this works
intentMap.set('Default Fallback Intent', fallback); // this works
intentMap.set('my.search', searchMyInfo); // this does not work
agent.handleRequest(intentMap);
}; // exports end所以我的问题是：如何使此代码工作以将实现响应返回到Dialogflow？默认的欢迎和回退响应确实来自Google Cloud函数，但我的自定义意图WebHook响应不是这样(即使在用于my.search的Dialogflow中设置了"enable webhookcall")。
javascript
我确实遇到了同样的问题，正如您所说的，我认为这与推荐答案的承诺和异步行为有关。因为当您调用云函数时，此函数会执行然后响应，但此函数不会等待外部API调用。
我尝试了request客户端，但是当我看到日志视图时，云函数响应之后的外部API响应。
所以我选择使用axios(node.js的基于Promise的HTTP客户端)，然后云函数就可以工作了。
这是Dialogflow+外部API+Google云函数的一个简单示例：
index.js
'use strict';
const functions = require('firebase-functions');
const { WebhookClient } = require('dialogflow-fulfillment');
const { Card, Suggestion } = require('dialogflow-fulfillment');
var axios = require("axios");
process.env.DEBUG = 'dialogflow:debug'; // enables lib debugging statements
exports.dialogflowFirebaseFulfillment = functions.https.onRequest((request, response) => {
const agent = new WebhookClient({ request, response });
console.log('Dialogflow Request headers: ' + JSON.stringify(request.headers));
console.log('Dialogflow Request body: ' + JSON.stringify(request.body));
function welcome(agent) {
agent.add(`Welcome to my agent!`);
}
function fallback(agent) {
agent.add(`I didn't understand`);
agent.add(`I'm sorry, can you try again?`);
}
function helloWorld() {
return axios({
method: "GET",
url: "https://run.mocky.io/v3/197de163-acc3-4c86-a13f-79314fe9da04",
data: "",
})
.then((response) => {
console.log(response.data.body.greeting); //Hello World
agent.add(response.data.body.greeting);
})
.catch((error) => {
console.log(error);
});
}
let intentMap = new Map();
intentMap.set('Default Welcome Intent', welcome);
intentMap.set('Default Fallback Intent', fallback);
intentMap.set('greeting.helloWorld', helloWorld);
agent.handleRequest(intentMap);
});
记住还要将axios包添加到package.json：
{
"name": "dialogflowFirebaseFulfillment",
"description": "This is the default fulfillment for a Dialogflow agents using Cloud Functions for Firebase",
"version": "0.0.1",
"private": true,
"license": "Apache Version 2.0",
"author": "Google Inc.",
"engines": {
"node": "10"
},
"scripts": {
"start": "firebase serve --only functions:dialogflowFirebaseFulfillment",
"deploy": "firebase deploy --only functions:dialogflowFirebaseFulfillment"
},
"dependencies": {
"actions-on-google": "^2.2.0",
"firebase-admin": "^5.13.1",
"firebase-functions": "^2.0.2",
"dialogflow": "^0.6.0",
"dialogflow-fulfillment": "^0.5.0",
"axios": "^0.20.0"
}
}
最后，这是我执行的POST Http查询，也许您会觉得有用。
function consulta() {
// console.log(agent.parameters.consulta);
// console.log(agent.query);
var consulta = agent.query.replace(/(
|
|)/gm, " ");
return axios({
method: "POST",
url: "http://jena-fuseki-api:3030/Matricula",
headers: {
Accept: "application/sparql-results+json,*/*;q=0.9",
"Content-Type": "application/x-www-form-urlencoded",
},
params: {
query: consulta,
},
})
.then((response) => {
var elements = response.data.results.bindings;
for (var i = 0; i < elements.length; i++) {
var result = "";
var obj = elements[i];
var j = 0;
var size = Object.size(obj);
for (var key in obj) {
var attrName = key;
var attrValue = obj[key].value;
result += attrName + ": " + attrValue;
if (j < size - 1) result += " | ";
j++;
}
console.log(result);
agent.add(result);
}
console.log("----------------------------");
})
.catch((error) => {
console.log("Failed calling jena-fuseki API");
console.log(error);
});
}
来自Dialogflow的一些图像：
相关文章