当步骤函数python中的某些事情失败时重试逻辑

如何解决当步骤函数python中的某些事情失败时重试逻辑

我有一个需要重新运行函数的场景，我该怎么做。

def test_cpbucket():

    res = s3.copy_object(
       Bucket = 'bucket-name',copySource: 'bucket-name/hello/21-01-2020-12-23-00/testing.ddl',Key: 'hello/21-01-2020-12-23-00/testing.ddl',ACL: 'public-read' 
    )

在上面的例子中，我将对象复制到同一位置，以便它可以触发我的 lambda 函数。

当 lambda 函数失败时，我需要重新运行此复制 s3 函数。我该怎么做？

解决方法

你可以尝试类似下面的步骤函数。 step function definition

步骤：

从 s3-copy-task 开始 - 执行 lambda。
s3-copy-task-choice - 做出选择 - 重新运行、成功、失败。它根据 LastEvaluatedKey 和步骤 1 中从 lambda 函数返回的异常变量做出决定。
s3-copy-task-fail - 如果整个过程失败，可以在此处执行一些后期处理或清理任务。
s3-copy-task-success - 如果整个过程成功，可以在此处执行一些后期处理或清理任务。

步进函数代码如下，

{
  "StartAt": "s3-copy-task","States": {
    "s3-copy-task": {
      "Next": "s3-copy-task-choice","Retry": [
        {
          "ErrorEquals": [
            "Lambda.ServiceException","Lambda.AWSLambdaException","Lambda.SdkClientException"
          ],"IntervalSeconds": 2,"MaxAttempts": 6,"BackoffRate": 2
        }
      ],"Type": "Task","Resource": "arn:aws:states:::lambda:invoke","Parameters": {
        "FunctionName": "arn:aws:lambda:eu-west-1:474496007096:function:ph_offer-synchronization-dev-query-dynamodb-fn","Payload.$": "$"
      }
    },"s3-copy-task-choice": {
      "Type": "Choice","Choices": [
        {
          "Variable": "$.Payload.exception","StringEquals": "true","Next": "s3-copy-task-fail"
        },{
          "Variable": "$.Payload.LastEvaluatedKey","StringEquals": "EMPTY","Next": "s3-copy-task-success"
        }
      ],"Default": "s3-copy-task"
    },"s3-copy-task-fail": {
      "Type": "Fail","Cause": "Error during lambda processing"
    },"s3-copy-task-success": {
      "Type": "Succeed"
    }
  }
}