如何将 Dialogflow Fulfillment 与 MySQL 数据库连接？

Question

我尝试将我的 Dialogflow 代理连接到我的 GCP 上的 MySQL 数据库，但效果不佳。我只想在控制台中查看结果，但没有相关结果。我只能看到结果“Undefined”，但由于我不熟悉 Node.js，我不确定这是什么意思。由于结果中没有内容，无法进行下一步

这是我的 index.js 脚本：

// See https://github.com/dialogflow/dialogflow-fulfillment-nodejs
// for Dialogflow fulfillment library docs, samples, and to report issues
'use strict';
 
const functions = require('firebase-functions');
const {WebhookClient} = require('dialogflow-fulfillment');
const {Card, Suggestion} = require('dialogflow-fulfillment');

const mysql = require('mysql');
 
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 connectToDatabase() {
    const connection = mysql.createConnection({
      host: '34.64.***.***',
      user: 'username',
      password: 'password',
      database: 'dbname'
    });
    return new Promise((resolve,reject) => {
       connection.connect();
       console.log('connection successed.');
       resolve(connection);
    });
  }
  
  function queryDatabase(connection, name){
    return new Promise((resolve, reject) => {
      connection.query('SELECT * FROM tb_user WHERE name = ?', name, (error, results, fields) => {
        console.log('query successed.');
        resolve(results);
      });
    });
  }
  
  function queryDatabase2(connection){
    return new Promise((resolve, reject) => {
      connection.query('SELECT * FROM tb_user', (error, results, fields) => {
        if (error) console.log(error);
        console.log('results', results);
      });
    });
  }
  
  function handleReadFromMysql(agent) {
    const user_name = agent.parameters.name;
    console.log(user_name.name);
    return connectToDatabase()
    .then(connection => {
      console.log('connectToDatabase passed');
      return queryDatabase(connection, user_name.name)
      //return queryDatabase2(connection)
      .then(result => {
        console.log('queryDatabase passed');
        console.log(result);
        agent.add(`User name is ${user_name} .`);
        //result.map(user => {
          //if(user_name === user.name) {
            //agent.add(`UserID is  ${user.id}`);
          //}
        //});
        connection.end();
      });
    });
  }
  
  let intentMap = new Map();
  intentMap.set('Default Welcome Intent', welcome);
  intentMap.set('Default Fallback Intent', fallback);
  intentMap.set('findName', handleReadFromMysql);
  agent.handleRequest(intentMap);
});

日志是：

enter image description here

请有人帮助我...

Answer 1

我在 4 个月前解决了这个问题，所以我分享我的代码来帮助像我一样的人。

我使用数据库信息的socketPath。原因忘记了

function connectToDatabase() {
    const connection = mysql.createConnection({
        socketPath: '/cloudsql/*************:asia-northeast3:****',
        user: '****',
        password: '****',
        database: '****'
    });
    return new Promise((resolve, reject) => {
        connection.connect();
        console.log('connection successed.');
        resolve(connection);
    });
}

并使查询函数像：

function findNameCountQuery(connection, name) {
return new Promise((resolve, reject) => {
    var sql = `SELECT * FROM tb_user WHERE name = ?`;
    var execSql = connection.query(sql, [name], (error, results) => {
        if (error) throw error;
        resolve(results);
    });
});

然后我使用像这样的代理功能：

async function findName(agent) {
    const user_name = agent.parameters.person.name;
    const connection = await connectToDatabase();
    const result = await findNameQuery(connection, user_name);
    result.map(user => {
        message += `사용자 ID seq number : ${user.seq}\n`;
    });

    agent.add(message);
    connection.end();
}

希望对您有所帮助。

如何将 Dialogflow Fulfillment 与 MySQL 数据库连接？

How to connect Dialogflow Fulfillment with MySQL DB?

javascript

mysql

dialogflow-es