基于AWS Step Functions实现带提醒与超时的邮件验证工作流

核心思路 #

用AWS Step Functions的并行分支拆分两个任务流：一个负责监听用户点击回调，另一个按时间节点发送提醒并处理最终超时失败逻辑。借助Step Functions的并行分支自动取消机制，解决你之前遇到的子工作流无法终止的问题——只要用户点击触发回调分支完成，提醒分支会被自动终止，不会再发送多余提醒。

具体实现步骤 #

1. 发送初始邮件

   • 调用Lambda函数发送含专属链接的邮件，链接中需携带当前Step Functions执行的唯一ID。用户点击链接时，通过API Gateway触发Lambda函数，调用aws stepfunctions send-task-success向对应执行ID发送回调信号。

2. 配置Parallel状态的两个分支

   • 分支A：等待用户点击回调
     • 使用Wait for Callback类型的Task，设置超时时间为2个月（换算为秒：60*60*24*60=5184000）。一旦收到用户点击的回调信号，立即执行后续业务步骤，同时Step Functions会自动终止并行的分支B。
   • 分支B：提醒与最终超时判定
     • 第一步：等待2天（Wait状态，设置Seconds=172800）
     • 第二步：添加Choice状态判断：若分支A已完成，则终止当前分支；未完成则调用Lambda发送第一次提醒邮件。
     • 第三步：等待3天（Wait状态，设置Seconds=259200）
     • 第四步：再次添加Choice状态判断：若分支A已完成，则终止当前分支；未完成则调用Lambda发送第二次提醒邮件。
     • 第五步：等待剩余时长（2个月减去5天，即5184000-172800-259200=4752000秒）
     • 第六步：若此时分支A仍未完成，调用aws stepfunctions send-task-failure标记整个工作流失败。

关键细节处理 #

• 链接中的执行ID是核心标识，确保用户点击时能精准触发对应工作流的回调。
• 分支B中每个Wait状态后必须添加Choice判断，避免分支A已完成后仍继续执行提醒逻辑。
• 所有超时时间需精确计算，确保总时长不超过2个月的限制。

备选方案：使用EventBridge Scheduler #

如果觉得Step Functions并行分支配置复杂，可改用EventBridge Scheduler实现：

• 发送初始邮件后，创建三个定时任务：2天后触发提醒、5天后触发第二次提醒、2个月后标记工作流失败。每个任务需绑定当前工作流的执行ID。
• 用户点击链接时，触发Lambda函数取消这三个定时任务，并进入后续业务步骤。

内容的提问来源于stack exchange，提问作者CroaToa