aws-step-functions相关内容

如何将AWS Glue作业的输出返回到调用步骤函数工作流?

AWS步骤函数允许调用AWS Glue作业,如下所述: https://docs.aws.amazon.com/step-functions/latest/dg/connect-glue.html 我要运行该作业,并(在将结果保存到S3之后)将作业期间生成的某些元数据(如行数或筛选的行数)返回到步骤函数流。 我们可以将参数从步骤函数传递到Glue作业,如下所示: ..
发布时间:2022-05-28 11:39:27 其他开发

principal states.amazonaws.com 无权担任提供的角色

我使用 Terraform 创建了一个 AWS 步进函数.目前,step 函数目前只有 1 个 lambda 函数: 资源“aws_iam_role_policy"“sfn_policy"{政策 = jsonencode({“版本":“2012-10-17",“声明":[{“效果":“允许",“动作":“sts:AssumeRole",“资源":“*"},{“Sid":“VisualEditor ..

如何将 stepfunction executionId 解析为 SageMaker 批量转换作业名称?

我创建了一个stepfunction,下面这个状态机的定义(step-function.json)在terraform中使用(使用这个页面中的语法:https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_CreateTransformJob.html) 如果我第一次执行这个状态机,它会创建一个名为 example-jobna ..

如何将 stepfunction 执行 ID 附加到 SageMaker 作业名称?

我有一个创建 SageMaker 批量转换作业的步进函数状态机,定义是用 Terraform 编写的,我想在批量转换作业名称中添加步进函数执行 ID: 在 stepfunction terraform 文件中: 定义 = 模板文件(“stepfuntion.json",{xxxx) 在“stepfuntion.json"中: {...“TransformJobName":“jobna ..

通过 Terraform 运行“aws stepfunctions update-state-machine"时出现 Json 解析错误

我正在关注 这个问题,我尝试启用 X 射线并且它有效,我使用的代码: 资源“null_resource"“enable_step_function_logging"{触发器 = {state_machine_arn = aws_sfn_state_machine.sfn_state_machine.arn}供应商“本地执行"{command = “aws stepfunctions update ..

如何将步进函数执行 ID 附加到 SageMaker 作业名称?

我有一个创建 SageMaker 批量转换作业的步进函数状态机,定义是用 Terraform 编写的,我想将步进函数执行 ID 添加到批量转换作业名称中: 在 stepfunction terraform 文件中: definition = templatefile(“stepfuncion.json",{xxx) 在“stepfuncion.json"中: {...“Transfo ..

如何避免在 aws 步骤函数中同时执行

目前我有一个用例,云监视规则将每 5 分钟触发一次步进函数.如果 step 函数中已经运行了一个执行,我想要一个逻辑来跳过开始另一个执行.有什么办法吗? 解决方案 与其让 CloudWatch 事件规则直接触发 Step Function,您还可以让它触发 Lambda 函数.Lambda 函数可以通过 ListExecutions API.如果没有,Lambda 函数可以通过 Start ..

在 step 函数中获取 AWS 状态机执行 ARN

我需要在状态机本身中获取我的状态机当前执行的 ARN.可能吗? 那么我可以创建一个状态机(比如从 lambda 函数),然后获取它的执行 ARN 并将其作为参数传递给该机器,或者状态机内部是否有任何可用的实用程序允许获取执行 ARN机器? 解决方案 AWS Step Functions 最近发布了一项名为上下文对象的功能. 现在您可以通过 Parameters 块内的 $$ 访 ..
发布时间:2021-10-27 19:14:22 Python

在 AWS Step Functions 中传递变量

我对 AWS Step Functions 和 AWS Lambda Functions 非常陌生,真的可以使用一些帮助.我有一个状态机,我试图在其中检查某个文件是否存在于我的 S3 存储桶中,然后如果文件存在则让状态机遵循一个路径,如果文件不存在则使用不同的路径. 以下显示了我的状态机代码的开头,涵盖了这个问题 {"comment": "这是一个运行 CustomCreate 作业结构的 ..

什么是“hellostepfunc1"?在用于设置 AWS stepfunctions 的无服务器文档中?

在无服务器网站的这些文档中 - 如何使用无服务器管理您的 AWS Step Functions 和 GiTHUB - serverless-step-函数,我们可以在serverless.yml文件中找到这个词hellostepfunc1:.我找不到对它的引用.我不明白它是什么,我找不到任何对它的引用,即使在状态机被创建到 AWS 之后也是如此. 如果我删除它,我会收到以下错误 不能使用' ..
发布时间:2021-07-20 18:59:06 其他开发

如何从Node.js Lambda函数调用步骤函数?

我正在尝试从Node.js lambda函数调用step函数.我从线程尝试了解决方案并更新了实现. > 解决方案显示错误响应,但更新的代码显示成功响应.但是更新后的代码没有调用step函数. 我的代码: console.log('加载函数');const AWS = require('aws-sdk');exports.handler =函数(事件,上下文){console.log ..
发布时间:2021-04-13 18:36:51 其他开发

如何停止特定状态机的所有正在运行的步进功能?

我不小心启动了很多步进功能,现在希望终止所有这些功能. 使用CLI或Web控制台执行此操作的任何聪明方法吗? 解决方案 好的,让我们使用CLI来完成此操作. 您可以使用以下命令停止执行: aws stepfunctions停止执行\--execution-arn 但是由于我开始执行的方式太多,因此能够列出状态机的所有正在运行的执行方式将很有帮助: ..
发布时间:2021-04-13 18:34:01 其他开发

有没有一种方法可以使用CDK创建步骤函数图?

当前,步骤函数图是使用ASL(亚马逊州语言)在json中定义的.没有好的方法可以对正在创建的图形进行单元测试,我们必须依靠在aws帐户上使用lambda函数的模拟/某些实现来运行图形.随着AWS CDK的发布,是否可以用高级语言定义步进函数图,并进行单元测试,模拟等? 解决方案 您是否已给 @ aws-cdk/aws-stepfunctions 库可以尝试吗? 为了后代,从此处的文档 ..
发布时间:2021-04-13 18:33:25 其他开发

AWS Step Function同步任务令牌

我有一个用例,我想使用步进函数来解决,但找不到解决此问题的方法.您的帮助将不胜感激. 问题是这样的:我有一个Amazon API Gateway,该网关具有/start 终端节点.对该端点的 POST 应该会启动数据处理会话,并将URL返回给API客户端可以用来捕获某些数据的应用程序.数据捕获完成后,在通过回调将最终响应发送到API客户端之前,需要进行一些处理. 我的想法(如下所示)是 ..

AWS Step Functions与Luigi进行编排

我的团队为小型项目提供了整体服务,但为了进行重新架构和扩展,我们计划迁移到Amazon AWS的云服务,并评估编排是将Luigi作为容器任务运行还是使用AWS Step用功能代替吗?我对他们中的任何一个都没有任何经验,尤其是Luigi.任何人都可以指出他们在Luigi上遇到的任何问题,或者可以证明它比AWS更好吗?任何其他建议相同. 提前谢谢. 解决方案 我不知道AWS如何进行编排, ..