使用 Step Functions 运行亚马逊ECS或 Fargate 任务

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

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

支持 Amazon ECS /Fargate APIs

向 Amazon ECS 任务传递数据

要了解如何在 Step Functions 中与 AWS 服务集成，请参阅集成 服务和在 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",
     "Parameters": {
                "Cluster": "cluster-arn",
                "TaskDefinition": "job-id",
                "Overrides": {
                    "ContainerOverrides": [
                        {
                            "Name": "container-name",
                            "Command.$": "$.commands" 
                        }
                    ]
                }
            },
     "End": true
    }
  }
}

ContainerOverrides 中的 "Command.$": "$.commands" 行将命令从状态输入传递到容器。

对于上一个示例，如果执行的输入为以下内容，则每个命令都将作为容器覆盖传递。

{
  "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",
         "Parameters":{  
            "LaunchType":"FARGATE",
            "Cluster":"cluster-arn",
            "TaskDefinition":"job-id",
            "Overrides":{  
               "ContainerOverrides":[  
                  {  
                     "Name":"container-name",
                     "Environment":[  
                        {  
                           "Name":"TASK_TOKEN_ENV_VARIABLE",
                           "Value.$":"$$.Task.Token"
                        }
                     ]
                  }
               ]
            }
         },
         "End":true
      }
   }
}

IAM致电亚马逊的政策ECS/AWS Fargate

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

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

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