代码之家 › 专栏 › 技术社区 › Md. Helal Uddin

Lambda函数MySQL result在NodeJs 8.10上不起作用

aws-lambda amazon-web-services node.js mysql

Md. Helal Uddin · 技术社区 · 6 年前

我有一个节点6.10的代码,它正在工作。。。但如果我把它转换成节点8.10,它就不工作了

var mysql = require("mysql");
var connection = mysql.createConnection({
  host: " localhost",
  user: "root",
  password: "",
  database: "parser_db"
});

exports.handler = async event => {
  connection.connect();

  let response = {
    statusCode: 400,
    body: { Method: "Invalid", event }
  };

  var readTable = "SELECT * FROM documents where id = " + mysql.escape(1);
  connection.query(readTable, function(err, results, fields) {
    if (err) throw err;
    else {
      response = {
        statusCode: 200,
        body: { results }
        //body: { results }
      };
      console.log(response);
      return response;
    }
  });
};

注意:如果我用控制台.log(回应)而不是返回显示正确的结果。

2 回复 | 直到 6 年前

jarmod 6 年前

问题是您正在从内部返回响应连接.查询()回调函数。这使response成为回调函数的返回值,而不是外部Lambda函数的返回值。

重构此代码的一种方法如下:

exports.handler = async (event) => {
  connection.connect();
  return new Promise((resolve, reject) => {
    const readTable = `SELECT * FROM documents where id = ${mysql.escape(1)}`;
    connection.query(readTable, (err, results, fields) => {
      if (err) {
        reject(err);
      } else {
        resolve({statusCode: 200, body: {results}});
      }
    });
  });
};

Ayush Gupta 6 年前

除了@jarmod的答案,您还可以使用 util.promisify connection.query 这样你就可以使用 await 关键字,使代码更简单

const util = require('util');
exports.handler = async (event) => {
  connection.connect();
  const readTable = `SELECT * FROM documents where id = ${mysql.escape(1)}`;
  const connQueryPromisified = util.promisify(connection.query).bind(connection);
  const result = await connQueryPromisified(readTable);
  return {statusCode: 200, body: {results}};
};

推荐文章

user433342 · 流式传输SheetJS-xlsx以在节点中形成数据

6 月前

servvs · 如何从javascript中的另一个类回调读取修改后的类属性?

6 月前

Vanortton · 使用Docker开始应用程序开发还是在开发过程中配置Docker?[关闭]

6 月前

ProfessorFinesse · 在默认表单中完成帖子请求时,“res.send”会去哪里?

6 月前

LifeAsPixels · 试图使用Node.js读取我的本地html文件时,此错误的来源是什么?

6 月前

Josue Abotsidia · 创建NextJS项目时出错

6 月前

Soon Winner · TypeError:superheroes.random在使用“超级英雄”npm包时不是函数[关闭]

7 月前

Null Salad · 如何使用postgresql和nodejs将变量安全地插入数组?

7 月前

Zak · 令牌认证路由的页面刷新重定向到React中的404页面

7 月前

DSATH · 我的lambda在代码完成之前就结束了,我不知道为什么

7 月前