如何在Twilio无服务器函数中用Await/Promise等待MySQL调用

1. 正确封装MySQL查询为Promise #

将MySQL的回调式查询封装为Promise，是实现异步等待的基础。以下是标准封装方式：

const mysql = require('mysql');

// 使用连接池提升性能（推荐替代单次连接）
const pool = mysql.createPool({
  host: process.env.MYSQL_HOST,
  user: process.env.MYSQL_USER,
  password: process.env.MYSQL_PASSWORD,
  database: process.env.MYSQL_DB
});

// 封装查询逻辑为Promise
function queryDatabase(sql, params) {
  return new Promise((resolve, reject) => {
    pool.query(sql, params, (error, results) => {
      if (error) {
        return reject(error);
      }
      resolve(results);
    });
  });
}

2. 在Async Handler中用Await等待MySQL操作完成 #

修改exports.handler为异步函数，通过await等待MySQL查询完成后，再执行后续的/respond函数调用。同时完善错误处理避免超时：

exports.handler = async function(context, event, callback) {
  try {
    // 等待MySQL查询结果返回
    const dbResults = await queryDatabase('SELECT key_column FROM your_table WHERE call_sid = ?', [event.CallSid]);
    
    // 提取关键值
    const criticalKey = dbResults[0]?.key_column;
    if (!criticalKey) {
      throw new Error('未获取到关键数据');
    }

    // 调用/respond函数，传入已获取的关键值
    const twilioClient = context.getTwilioClient();
    await twilioClient.serverless.services(context.SERVICE_SID)
      .functions('respond')
      .invoke({
        parameters: {
          criticalKey: criticalKey,
          callSid: event.CallSid,
          // 其他必要参数
        }
      });

    // 返回TwiML维持通话流程
    const twiml = new Twilio.twiml.VoiceResponse();
    twiml.pause({ length: 2 });
    callback(null, twiml);
  } catch (error) {
    // 捕获所有异常，避免函数无响应超时
    console.error('处理失败:', error);
    const twiml = new Twilio.twiml.VoiceResponse();
    twiml.say('抱歉，请求处理出现问题');
    callback(null, twiml);
  }
};

3. 避免超时的核心注意事项 #

• 复用连接池：连接池减少了重复建立数据库连接的耗时，比单次连接更高效。
• 优化SQL查询：为查询字段添加索引，避免全表扫描，缩短MySQL执行时间。
• 控制总执行时长：Twilio无服务器函数有最大执行时间限制（免费版默认10秒，付费版可延长），确保MySQL查询+后续操作的总时长不超过阈值。
• 强制错误处理：必须通过try/catch捕获所有异步异常，防止未处理错误导致函数超时或崩溃。

内容的提问来源于stack exchange，提问作者Michael7S