使用 Lambda 和 Amazon 创建任务计时器 SNS - AWS Step Functions

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

使用 Lambda 和 Amazon 创建任务计时器 SNS

本示例项目将创建一个任务计时器。它实现了一个 AWS Step Functions 实现状态的Wait状态机,并使用 AWS Lambda 发送亚马逊简单通知服务 (AmazonSNS) 通知的函数。等待工作流程状态 状态是等待触发器执行单个工作单元的状态类型。

注意

此示例项目实现了 AWS Lambda 用于发送亚马逊简单通知服务 (AmazonSNS) 通知的函数。您也可以直接使用亚马逊州语言发送亚马逊SNS通知。请参阅 将服务与 Step Functions 集成

此示例项目创建了状态机、一个 Lambda 函数和一个 Amazon SNS 主题,并配置了相关的 AWS Identity and Access Management (IAM) 权限。有关使用任务计时器 示例项目创建的资源的更多信息,请参阅下面内容:

有关如何操作的更多信息 AWS Step Functions 可以控制其他 AWS 服务,请参阅将服务与 Step Functions 集成

第 1 步:创建状态机

  1. 打开 Step Functions 控制台,然后选择创建状态机

  2. 在搜索框中键入 Task Timer,然后从返回的搜索结果中选择任务计时器

  3. 选择下一步以继续。

  4. 选择 “运行演示” 以创建只读和 ready-to-deploy 工作流程,或者选择 “在其上构建” 以创建可编辑的状态机定义,您可以在此基础上构建并稍后部署。

    该示例项目部署了以下资源:

    • 一个用于发送亚马逊SNS通知的 Lambda 函数。

    • 网络 ACL 和安全组都允许 (因此可到达您的实例) 的发起 ping 的 AWS Step Functions 状态机

    • 相关 AWS Identity and Access Management (IAM) 角色

    下图显示了任务计时器示例项目的工作流图:

    任务计时器示例项目的工作流图。
  5. 选择使用模板继续进行选择。

后续步骤取决于您之前的选择:

  1. 运行演示 — 您可以先查看状态机,然后再使用部署的资源创建只读项目 AWS CloudFormation 给你的 AWS 账户.

    您可以查看状态机定义,准备就绪后,选择 Deploy 并运行以部署项目并创建资源。

    部署最多可能需要 10 分钟才能创建资源和权限。您可以使用堆栈 ID 链接来监控进度 AWS CloudFormation.

    部署完成后,您应该会在控制台中看到您的新状态机。

  2. 在此基础上再接再厉 — 您可以查看和编辑工作流程定义。在尝试运行自定义工作流程之前,您可能需要为示例项目中的占位符设置值。

注意

部署到您的账户的服务可能会收取标准费用。

第 2 步:运行状态机

配置并部署完所有资源后,将显示启动执行对话框,其中包含类似于以下内容的示例输入。

{ "jobName": "my-job",{ "topic": "arn:aws:sns:us-east-2:123456789012:StepFunctionsSample-TaskTimercc68840e-c3d3-42a8-911e-821b7ce248e5-SNSTopic-44UjcFxzhACT", "message": "HelloWorld", "timer_seconds": 10 }
  • 启动执行对话框中,执行以下操作:

    1. (可选)输入自定义执行名称以覆盖生成的默认执行名称。

      非ASCII姓名和日志

      Step Functions 接受状态机、执行、活动和包含非ASCII字符的标签的名称。由于此类字符不适用于亚马逊 CloudWatch,因此我们建议您仅使用ASCII字符,以便您可以跟踪中的指标 CloudWatch。

    2. (可选)在 “输入” 框中,将输入值输入为JSON。如果您正在运行演示,则可以跳过此步骤。

    3. 选择启动执行

    Step Functions 控制台将引导您进入执行详情页面,您可以在图表视图中选择状态以浏览步骤详细信息窗格中的相关信息。

    例如,下图显示了所选步骤等待时间戳的输出。此步骤的输出作为输入传递给 “发送SNS消息” 步骤。

    图表视图中选择的等待时间戳步骤的执行结果。