使用 Step Functions 运行 Amazon ECS 或 Fargate 任务

了解如何将 Step Functions 与 Amazon ECS 或 Fargate 集成来运行和管理任务。在 Amazon ECS 中，任务是基本的计算单位。任务由任务定义所定义，任务定义指定 Docker 容器的运行方式，包括容器映像、CPU 和内存限制、网络配置和其它参数。本页列出了可用的 Amazon ECS API 操作，并提供了有关如何使用 Step Functions 将数据传递给 Amazon ECS 任务的说明。

要了解如何在 Step Functions 中与 Amazon 服务集成，请参阅集成 服务和在 Step Functions 中将参数传递给服务 API。

优化 Amazon ECS/Fargate APIs

向 Amazon ECS 任务传递数据

要了解如何在 Step Functions 中与 Amazon 服务集成，请参阅集成 服务和在 Step Functions 中将参数传递给服务 API。

您可以使用 overrides 覆盖容器的默认命令，并将输入传递给 Amazon ECS 任务。请参阅 ContainerOverride。在示例中，我们习惯 JsonPath 将值Task从输入传递到Task状态。

下面是一个运行 Amazon ECS 任务并等待任务完成的 Task 状态。

{
 "StartAt": "Run an ECS Task and wait for it to complete",
 "States": {
   "Run an ECS Task and wait for it to complete": {
     "Type": "Task",
     "Resource": "arn:aws:states:::ecs:runTask.sync",
     "Arguments": {
                "Cluster": "cluster-arn",
                "TaskDefinition": "job-id",
                "Overrides": {
                    "ContainerOverrides": [
                        {
                            "Name": "container-name",
                            "Command": "{% $state.input.commands %}" 
                        }
                    ]
                }
            },
     "End": true
    }
  }
}

ContainerOverrides 中的 Command 行将命令从状态输入传递到容器。

在前面的状态机示例中，给定以下输入，每个命令都将作为容器覆盖传递：

{
  "commands": [
    "test command 1",
    "test command 2",
    "test command 3"
  ]
}

下面包含一个运行 Amazon ECS 任务，然后等待返回任务令牌的 Task 状态。请参阅等待具有任务令牌的回调。

{  
   "StartAt":"Manage ECS task",
   "States":{  
      "Manage ECS task":{  
         "Type":"Task",
         "Resource":"arn:aws:states:::ecs:runTask.waitForTaskToken",
         "Arguments":{  
            "LaunchType":"FARGATE",
            "Cluster":"cluster-arn",
            "TaskDefinition":"job-id",
            "Overrides":{  
               "ContainerOverrides":[  
                  {  
                     "Name":"container-name",
                     "Environment":[  
                        {  
                           "Name" : "TASK_TOKEN_ENV_VARIABLE",
                           "Value" : "{% $states.context.Task.Token %}"
                        }
                     ]
                  }
               ]
            }
         },
         "End":true
      }
   }
}

用于调用 Amazon ECS/Amazon Fargate的 IAM 策略

以下示例模板展示了如何根据状态机定义中的资源 Amazon Step Functions 生成 IAM 策略。有关更多信息，请参阅Step Functions 如何为集成服务生成 IAM 策略和探索 Step Functions 中的服务集成模式。

由于在提交任务之前 TaskId 的值始终是未知的，因此 Step Functions 会创建具有更高特权的 "Resource": "*" 策略。

如果您计划的 Amazon ECS 任务需要使用任务执行角色、任务角色或任务角色覆盖，则必须将每个任务执行角色、任务角色或任务角色覆盖的iam:PassRole权限添加到调用实体的 Ev CloudWatch ents IAM 角色（在本例中为 Step Functions）中。