AWS Step Function 的操作 startExecution 不会在 mysql .query() 回调上启动

Question

我希望能够使用 mysql 查询的结果开始执行步骤函数，但我无法让它工作。

我在运行nodejs 4.3和mysql package的lambda上使用AWS-SDK。

我成功地使用 AWS-SDK 轻松启动了步骤函数的执行，并将其包装在一个函数中：

function startExecution(){
    var AWS = require('aws-sdk');

    var stepfunctions = new AWS.StepFunctions();

    var params = {
      stateMachineArn: 'arn:aws:states:us-east-1:453687599700:stateMachine:Temp',
      input: '{"OrderID":266}',
      name: '00002'
    };

    stepfunctions.startExecution(params, function(err, data) {
      if (err) console.log(err, err.stack); // an error occurred
      else     console.log(data);           // successful response
    });
}

调用startExecution()下

exports.handler = (event, context, callback) => {

工作完美。

但是，在mysql的connection.query的回调函数中调用相同的startExecution()不起作用：

connection.query('SELECT * FROM `books` WHERE `author` = "David"', function (error, results, fields) {
    startExecution(); //doesn't work :(
});

使用 console.log() 跟踪代码显示该行：

 stepfunctions.startExecution(params, function(err, data) {

似乎它被跳过了。

我们将非常感谢您的帮助！

非常感谢..

Answer 1

可能你的 lambda 在startExecution完成之前完成。

尝试使用以下语法：

const executeResult = await stepfunctions.startExecution(params).promise()

console.log('executeResult: ', executeResult)