问题标签 [serverless-framework-step-functions]

考虑一个代码：

无服务器.yml

包.json

失败并出现错误：

所以看起来在创建状态机时没有SnsTopic资源。但是如何在状态机之前创建呢？ DependsOn状态机上的属性导致相同的错误。有任何想法吗？

我已经将 MaxConcurrency 设置为 300，但是当我启动它时仍将 MaxConcurrency 执行为 57，我该如何更改它？Step 函数如何决定 MaxConcurrency？

来自 Step Function 的 JSON：

我是第一次使用状态机，在我的 Lambda 函数中引用状态机 arn 时遇到问题。我试过关注这篇文章和文档，但我一定遗漏了一些东西，因为我得到的不是 arn，而是“[object Object]”。

环境变量：

输出：

状态机：

我读过的所有东西都有相同的设置，所以我知道我一定遗漏了一些明显的东西。

从先前状态发送的输入采用以下形式：

状态机工作流程设计：

如何从上述输入中提取“feedType”值并转换到下一个状态，并将整个输入传递到下一个状态？

谢谢

我们有一个 Step Function 状态机，它具有以 json 格式编写的状态语言规范，它在工作流执行期间根据输入和条件调用多个 Lambda 函数。

有没有办法通过模拟 Lambda 依赖项来单元/集成测试这个 json 代码（工作流程）？例如。测试特定 Lambda 的输出何时为 XXX，然后 YYY 步骤被步骤函数工作流调用。

我检查了“本地开发和测试 AWS Step Functions 工作流程”文档，但它似乎提供了一种在本地测试 Lambda 的步骤函数的方法。我想要的是模拟 Lambda 并测试 json（工作流/状态语言）。

单元测试用例在 awsStepFunctionsAsyncClient.startExecutionAsync 时通过，但对于 awsStepFunctionsAsyncClient.startExecution 失败

我有一个主 lambda 函数（比如 X），它异步调用另一个 lambda 函数（比如 Y）。一旦触发并执行了 lambda 函数 Y 的一个实例，它会将数据转储到 kinesis 或 s3，然后是最终的 lambda 函数（例如 Z），它从 kinesis 或 s3 获取该数据并作为输入并被触发。这是整个流程过程，并且该过程完全是事件驱动的。

现在，每次运行都会使用不同的输入触发主功能 (X)。对于第一个 lambda 函数调用 (Y)，它会创建与 master 的输入一样多的实例数，并为每个实例创建不同的 AWS 请求 ID。但是对于第二个从属 lambda 函数 (Z)，这并没有被创建。它只创建一个 aws 请求 ID（这意味着该过程不是异步的）。但是，如果我为主 lambda 函数 (X) 分配 20 秒的等待时间，那么这个问题就不再存在了。我正在使用 Python 3.6 进行该过程。

为什么会这样？这是一个已知的问题 ？有没有更好的方法来做同样的事情来实现完整的端到端流程？

这是我的主 lambda 函数（X）的代码：

******************************示例代码********************* **************

我正在使用步进功能data science SDK using python。我有一个每天运行的任务，并且在步骤函数的某些步骤中要访问的数据的路径每天都在变化，因为它具有日期参数。

如何在执行 step 函数并使用它时传递 date 参数，以便我可以每天自动访问新数据。

这是我添加到工作流中的一个步骤的示例。

我想将日期变量添加到 S3_DEST。如果我使用 execution_input，则类型不是字符串，因此我无法将其连接为路径。

安装 serverless step 功能插件后

...并通过成功部署 step 功能

...然后我尝试运行：无服务器调用 stepf

...我得到“stepf”不是有效的子命令

为什么不能使用 serverless-step-functions 插件中的功能来调用 step 函数？

在 serverless-step-functions git-hub 页面上描述了调用命令： https ://github.com/serverless-operations/serverless-step-functions#invoke

插件 serverless-step-functions 使用的版本是 2.21.1

编辑

一条重要信息是调用命令是从不包含 serverless.yml 文件的文件夹中执行的

如图所示，我创建了一个阶梯函数。现在我需要在 StepK 之后执行 StepX（然后 ChoiceA 流程将结束）。所以基本上 StepX 应该像现在一样与 StepY->StepZ 并行执行，但也应该在 StepK 之后执行。但是我找不到访问并行块内的舞台的方法”。有没有办法解决这个问题？

这是我的Json-