7

我正在设计一个状态机，它将运行两个 lambda 函数，每个函数并行返回一个 Json 数组。此外，这些函数的结果随后将传递给另外两个 lambda 函数，这些函数将接受这些输入并添加到数据库中。我已经准备好所有功能并单独工作，但是当我执行状态机时，它说其中一个执行由于 DataLimitExceeded 而失败。我检查了文档，它说输入或输出结果的限制是 32.768 个字符。奇怪的是，成功的执行是 Json 对象返回的大约 50k 个字符，而失败的执行大约是 46k 个字符。所以，如果两者都超过限制，为什么其中一个失败而另一个没有！

{
  "StartAt": "Sync",
  "States": {
    "Sync": {
      "Type": "Parallel",
      "Next": "EnviarNotificacion",
      "Branches": [
        {
          "StartAt": "SyncClientes",
          "States": {
            "SyncClientes": {
              "Type": "Task",
              "Resource": "arn...",
              "Next": "AddClientes"
            },
            "AddClientes" : {
              "Type": "Task",
              "Resource": "arn...",
              "End": true
            }
          }
        },
        {
          "StartAt": "SyncArticulos",
          "States": {
            "SyncArticulos": {
              "Type": "Task",
              "Resource": "arn...",
              "Next": "AddArticulos"
            },
            "AddArticulos": {
              "Type": "Task",
              "Resource": "arn...",
              "End": true
            }
          }
        }
      ]
    },
    "EnviarNotificacion": {
      "Type": "Pass",
      "End": true
    }
  }
}

非常感谢！

4

1 回答 1

11

好吧，有人给了我另一个对我很好的解决方案，所以如果有人遇到类似的问题，我会在这里发布。我所做的只是将我需要的数据保存在 S3 上的一个文件中，然后在第二个函数中，我从 S3 读取这个文件并且工作得很好。我注意到的一件事是，当我将文件保存在 S3 上时，运行良好的函数的数据为 31kb，而失败的数据为 35kb，因此最大大小可能为 32kb，而不是文档中所说的字符。

于 2017-08-11T13:49:02.060 回答