AWS Step Functions SendSQSMessage：动态 MessageGroupId

Question

我正在使用 AWS CDK 创建一个状态机，该状态机将消息发送到 fifo 队列并等待来自 lambda worker 的回调以继续执行。

我希望发送到 fifo 队列的消息具有分配给它们的动态 MessageGroupId，以便我可以控制处理消息的 lambda 工作人员的数量。我能想到的拥有动态 MessageGroupId 的唯一方法是使用 JsonPath 在 step 函数输入上引用一些参数，但是我没有遇到任何关于它的文档。我最初使用 JsonPath 动态传递 MessageGroupId 的测试失败了，只是传递了字符串“$.MessageGroupId”，有效地为每条消息提供了相同的消息组 id，从而为一个 lambda worker 提供了一个。

1. 是否可以在从 step 函数发送消息时为 sqs 消息动态分配消息组 ID？
2. 如果是，怎么做？

Answer 1

在 AWS Support 的帮助下，我设法通过使用 Context Object 或从初始输入中传递一个 ID 并使用 $ 引用它来做到这一点。

这是一个例子：

{
  "Comment": "Generate unique MessageGroupId",
  "StartAt": "Start",
  "States": {
    "Start": {
      "Type": "Task",
      "TimeoutSeconds": 60,
      "Resource": "arn:aws:states:::sqs:sendMessage.waitForTaskToken",
      "Parameters": {
        "QueueUrl": "<YOUR_QUEUE_URL>",
        "MessageBody": {
          "Input.$": "$",
          "TaskToken.$": "$$.Task.Token"
        },
        "MessageGroupId.$": "$$.Execution.Id"
      },
      "ResultPath": "$",
      "End": true
    }
  }
}

我的问题是我试图像这样MessageGroupId：

"MessageGroupId": "$$.Execution.Id"

我应该做的：

"MessageGroupId.$": "$$.Execution.Id"

附加.$ 将解析表达式"$$.Execution.Id"，而不是直接输入字符串"$$.Execution.Id"。