如何将 Step Function 输入传递给批处理作业答案

【问题标题】：How to pass Step Function input to Batch Job如何将 Step Function 输入传递给批处理作业
【发布时间】：2019-06-17 09:06:52
【问题描述】：

将 Step Function 的部分输入发送到批处理作业的正确方法是什么？

我尝试过像这样使用 Parameters.ContainerOverrides.Environment 设置和环境变量：

"Parameters": {
    "ContainerOverrides": {
      "Environment": [
        {
          "Name": "PARAM_1",
          "Value": "$.param_1"
        }

步进函数输入如下所示：

{
  "param_1": "value-goes-here"
}

但是批处理作业最终会被 PARAM_1 环境变量中的文字“$.param_1”调用。

【问题讨论】：

标签： amazon-web-services aws-step-functions aws-batch

【解决方案1】：

已修复。 Value 键只需要“.$”后缀。

"Parameters": {
 "ContainerOverrides": {
  "Environment": [
    {
      "Name": "PARAM_1",
      "Value.$": "$.param_1"
    }

【讨论】：

【解决方案2】：

在“Parameters”中传递它（在父“Parameters”中）。请注意所有参数值都是字符串

"MyStepTask": {
    "Type": "Task",
    "Resource": "arn:aws:states:::batch:submitJob.sync",
    "Parameters": {
      "JobDefinition": "myjobdef",
      "JobName": "myjobname",
      "JobQueue": "myjobqueue",
      "Parameters": { "p_param1":"101",
                      "p_param2":"201"
      }
    },
    "Next": "MyNextStepTask"
}

【讨论】：

【解决方案3】：

如果您想将参数传递给批处理，请将参数部分添加到父参数部分（不是很好的命名！）

    "MyStepTask": {
        "Type": "Task",
        "Resource": "arn:aws:states:::batch:submitJob.sync",
        "Parameters": {
          "JobDefinition": "myjobdef",
          "JobName": "myjobname",
          "JobQueue": "myjobqueue",
          "Parameters": {
              "Name": "PARAM_1",
              "Value.$": "$.param_1"
          }
        },
        "Next": "MyNextStepTask"
    }

【讨论】：