AWS Step Functions有助于使用可视化工作流协调分布式应用程序和微服务的组件。例如,可以链接多个AWS Lambda函数,通过决策分支连接它们或并行运行它们。
如何传递参数存储的参数名称和值,以便步骤函数更新它? 输入:参数存储-参数名称=“foo”,值=“bar”。步...
AWS Step Function - 等待一组其他 Step Function 完成,然后触发不同的 Step Function
我有一个场景,我需要发布由一组离散 Step Functions 生成的处理结果。我如何编排这种安排,如果我有步骤功能 A、B ...
AWS Step Function 中的 lambda 能否知道 AWS Step Function 的当前执行 ID?
对于在步骤函数中执行的 lambda,我想知道其中 AWS 状态机的当前执行 id。有没有办法在步骤函数中知道这一点?
从 Step Functions 调用 AWS Glue 工作流
部署 Cloudformation 时从 Step Functions 调用 Glue 工作流程出现以下错误: 资源处理程序返回消息:“状态机定义无效:'SCHEMA_VALIDATION_FAI...
Node20x 运行时 lambda 在 AWS Step Functions 中抛出格式错误的错误,而 Node18x 则抛出预期的错误格式
在 Node18x 运行时上运行的 AWS lambda 在 Node20x 运行时上运行时会引发不同的异常。 我有一个在 AWS 状态机中使用的 lambda 函数。状态机具有重试机制
我正在设计一个状态机,它将运行两个 lambda 函数,每个函数并行返回一个 Json 数组。此外,这些函数的结果随后会传递给另外两个 lambda 函数,它们将...
向 AWS StepFunction 传递整数参数会导致状态机定义无效
我正在使用无服务器框架堆栈定义一个等待类型步骤函数,该函数采用变量作为其超时设置,如下所示: 等待审核: 类型:任务 超时秒数:$.submission.dura...
在 AWS Step 函数中,有没有一种好方法可以根据输入列表执行步骤子集?
我是 AWS Step Functions 的新手,我希望创建一个具有以下功能的步骤函数: 例如,我有一个接受 JSON 有效负载的 lambda { "ExecutionType":&quo...
我有多个胶水作业,它们都具有相同的作业参数 --param1 和 --param2 在粘合作业中使用。 我在步骤函数中连接了两个粘合作业。 但不知道如何...
有没有办法根据发送到其调用的数据在 Step Function 控制台中搜索特定的 Step Function 执行?
我正在尝试查看是否有一种方法可以根据发送来启动它的数据来查找特定的 Step Function 执行。 例如,我在发布到 API Gateway 的数据中有一个 CustomerNumber...
AWS 部署选项:ECS、Batch、Step Functions,该使用哪一个?
我目前有一个相对庞大的批量逻辑分析交易和购买数据,并相应地应用动态定价。每天运行两次,运行时间约为 2 小时。我是...
通过使用aws-step-functions,我尝试将Item放入dynamodb中。 这是 .yml 的摘录,它按预期工作。 ... 添加网址: 类型: 地图 项目路径:“$.vidPosts”
AWS Step Function Lambda 返回空输出负载
我创建了一个基本状态机,它运行 lambda,然后使用该 lambda 的输出来决定选择。但是,我无法接收 lambda 函数的输出,因为...
AWS 步骤函数:lambda 中的错误处理程序未将正确的数据传递到 AWS 状态机
我有状态机,它使用 lambdas,s3 复制/删除对象,传递状态,选择状态,... 简单来说,它的作用就是从“pending”文件夹中获取对象,处理它(使用 lambda)然后...
使用 Activity 将 Step Function Json 转换为 Definition 对象
我是 CDK L2 构造的新手。我正在尝试为我的步骤函数定义之一创建 L2 构造。目前它是 JSON 格式,希望将其编码。我尝试使用stepFunction.Activity ...
我在步骤函数 waitForTaskToken 模式中错误配置了 lambda 调用,如 “有效负载”:{ "taskToken": "$$.Task.Token", “字段1”:“...
这是我在无服务器 yml 中的步骤函数定义的一部分。 创建问题: 类型: 地图 ItemsPath:“$.data.questions” 迭代器: 斯塔...
我基本上想在状态失败或超时后重试粘合作业两次,然后再进入下一阶段。我的状态机如下所示: { “评论”:“对我的状态的描述
AWS CDK:通过赋予 Step Function 的 ARN 调用 Lambda
由于我正在处理一些安全限制,我需要创建一个 Step Function,它可以执行在 Step Function 的 JSON 输入中标识的 Lambda。我创建了这样一个步骤
我有一个步骤函数工作流程,需要触发以下序列:Lambda1 → AnotherStep → Lambda2。如果一切顺利,我想最后更新数据库中的状态。如果有的话