3

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

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

我使用 AWS-SDK 轻松地开始执行 step-function，并将其包装在一个函数中：

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) {

好像它被跳过了。

您的帮助将不胜感激！

非常感谢..

4

1 回答 1

1

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

请尝试以下语法：

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

console.log('executeResult: ', executeResult)
于 2021-06-23T22:48:48.470 回答