AWS StepFunctions - SendTaskSuccess/SendTaskFailure 操作 - 任务超时

Question

我正在尝试执行一个步骤函数，该函数具有使用活动资源的任务。

运行我的代码后，我想返回

SendTaskSuccess

或

SendTaskFailure

返回步骤功能。

我偶尔会收到以下错误（不到 10 秒后）：

An error occurred (TaskTimedOut) when calling the SendTaskFailure operation: Task Timed Out: 'arn:aws:states:us-east-1:<....>'

在哪里禁用TaskTimeOut？或者如何增加它？

更多信息

这是步骤功能代码

{
  "Comment": "orchestrator-state-machine",
  "StartAt": "get_data_from_lambda",
  "States": {

    "get_data_from_lambda": {
      "Type": "Pass",
      "Next": "start_task"
    },

    "start_task": {
      "Type": "Task",
      "Resource": "arn:aws:states:us-east-1:<...>",
      "End": true
    }

  }
}

发送成功代码

self._client = boto3.client('stepfunctions', self._region, config=Config(connect_timeout=65,read_timeout=70,region_name=self._region))

...
def task_success(self, token, result):
    self.logger.info(str(token))
    try:
        self._client.send_task_success(taskToken=token, output=result)
        self.logger.info("sending success back to step function")
    except Exception as e:
        self.logger.error("did not send success to step function: {0}".format(str(e)))

    return True

索取详情

{
  'Error': {
    'Message': "Task Timed Out: 'arn:aws:states:us-east-1:<....>t'",
    'Code': 'TaskTimedOut'
  },
  'ResponseMetadata': {
    'RequestId': 'b******d-755a-****-9cef-ad*******a4c',
    'HTTPStatusCode': 400,
    'HTTPHeaders': {
      'x-amzn-requestid': 'b******d-755a-****-9cef-ad*******a4c',
      'content-type': 'application/x-amz-json-1.0',
      'content-length': '154'
    },
    'RetryAttempts': 0
  }
}

Answer 1

我检查了一下并设法使用 AWS 命令行界面

轻松地重现了该问题

似乎是 AWS 的问题，现已解决。

Answer 2

您可以通过添加

Timeout=300

为活动步骤添加超时，其中 300 是以秒为单位的时间。

"start_task": {
      "Type": "Task",
      "Resource": "arn:aws:states:us-east-1:<...>",
      "Timeout":300,
      "End": true
    }

另外，您还需要使资源 arn 是活动 arn 而不是 lambda 函数 arn

Answer 3

这里可能不适用，但如果您的 Step Function 在 30 秒内完成，您可以使用 Express Step Function（和

boto3.resource('stepfunction).start_sync_execution

）来等待响应。

但是从您的其他回复中我发现您的回复时间可能很长。

另一个选项是翻转它，并在您提到的 EC2 实例中使用一个脚本，该脚本定期轮询步骤函数（使用describe_execution boto3 方法）并在成功响应后返回。