Как запустить задачу ECS на AWS с PHP

Question

Я пытаюсь запустить "TaskDefinition" в ECS (служба контейнеров Ec2) с помощью PHP SDK.

1. Я создал TaskDefinition.
2. Я создал кластер.
3. Я создал сервис.

Я думал, что следующий шаг будет "registerContainerInstance", но когда я вызываю этот метод, у меня появляется ошибка:

[Aws \ Ecs \ Exception \ EcsException]
Ошибка выполнения "RegisterContainerInstance" на " https://ecs.eu-west-1.amazonaws.com/"; Ошибка HTTP AWS: ошибка клиента: 400 ClientException (клиент): документ удостоверения личности был предоставлен, но не действителен. - {" __type":"ClientException","message":"Документ, удостоверяющий личность, предоставлен, но недействителен."}

Это потому, что я не отправляю "instanceIdentityDocument" и "instanceIdentityDocumentSignature". Но я не знаю, как получить эти два параметра.

Должен ли я запустить EC2 вручную раньше?

Есть ли другой способ сделать это, я не знаю?

<?php

namespace App\Http\Controllers;

use Aws\Ecs\EcsClient;
use Illuminate\Http\Request;

use App\Http\Requests;
use App\Http\Controllers\Controller;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\Config;

class ECSController extends Controller
{
    protected $ecsClient;

    function __construct() {
        $config = Config::get('aws');
        $this->ecsClient = new EcsClient([
            'version'     => 'latest',
            'region'      => $config['region'],
            'credentials' => [
                'key'    => $config['credentials']['key'],
                'secret' => $config['credentials']['secret'],
            ],
        ]);
    }

    /**
     * Display a listing of the resource.
     *
     * @return Response
     */
    public function index()
    {
/*  $response = [
              'photos'  => []
            ];    
        return Response::json($response, $statusCode); */
    echo "index\n";
    }

    /**
     * Show the form for creating a new resource.
     *
     * @return Response
     */
    public function create()
    {
        $file = file_get_contents('config/configEC2basic.json');

        $data = json_decode($file, true /* associative arrays */);
        $result = $this->ecsClient->registerTaskDefinition($data);

        if ($result['taskDefinition']['status'] == "ACTIVE")
        {
            $taskName = $result['taskDefinition']['containerDefinitions'][0]['name'];

            if ($result['taskDefinition']['revision'] == 1)
                echo "Task : '".$taskName."' has been created\n";
            else
                echo  "Task : '".$taskName."' has been updated\n";
        }
        else
            echo "Error : The task is not active.\n";

        $clusterName = $this->ecsClient->createCluster([
            'clusterName' => 'kaemo',
        ]);

        $result = $this->ecsClient->createService([
            'desiredCount' => 1,
            'serviceName' => 'kaedevAWS1',
            'taskDefinition' => 'testkaeDEV4',
            'cluster' => 'kaemo'
        ]);
     }

    public function start()
    {
        $result = $this->ecsClient->registerContainerInstance([
            'cluster' => 'kae',
            'totalResources' => [
                [
                    'integerValue' => 1,
                    "longValue" => 0,
                    'name' => "CPU",
                    'type' => "INTEGER",
                    "doubleValue" => 0.0,
                ],
                [
                    'integerValue' => 996,
                    "longValue" => 0,
                    'name' => "MEMORY",
                    'type' => "INTEGER",
                    "doubleValue" => 0.0,
                ],
                [
                    'integerValue' => 0,
                    "longValue" => 0,
                    'name' => "PORTS",
                    'type' => "STRINGSET",
                    "doubleValue" => 0.0,
                    "stringSetValue" => [
                        "80",
                        "22"
                    ]
                ]
            ]
        ]);

             echo ">".print_r($result, true);

       /* $result = $this->ecsClient->runTask([
            'taskDefinition' => 'testkaemoDEV4',
            'cluster' => 'kaemo'
        ]);

        echo ">".print_r($result, true); */
    }

    /**
     * Store a newly created resource in storage.
     *
     * @param  Request  $request
     * @return Response
     */
    public function store(Request $request)
    {
        //
    }

    /**
     * Display the specified resource.
     *
     * @param  int  $id
     * @return Response
     */
    public function show($id)
    {
        //
    }

    /**
     * Show the form for editing the specified resource.
     *
     * @param  int  $id
     * @return Response
     */
    public function edit($id)
    {
        //
    }

    /**
     * Update the specified resource in storage.
     *
     * @param  Request  $request
     * @param  int  $id
     * @return Response
     */
    public function update(Request $request, $id)
    {
        //
    }

    /**
     * Remove the specified resource from storage.
     *
     * @param  int  $id
     * @return Response
     */
    public function destroy($id)
    {
        //
    }
}

Answer 1

Я наконец нашел решение для моей проблемы:

Во-первых, вам нужно создать задачу с помощью "registerTaskDefinition":

$file = file_get_contents('config/configEC2basic.json');

        $data = json_decode($file, true /* associative arrays */);
        $result = $this->ecsClient->registerTaskDefinition($data);

        if ($result['taskDefinition']['status'] == "ACTIVE")
        {
            $taskName = $result['taskDefinition']['containerDefinitions'][0]['name'];

            if ($result['taskDefinition']['revision'] == 1)
                echo "Task : '".$taskName."' has been created\n";
            else
                echo  "Task : '".$taskName."' has been updated\n";
        }
        else
            echo "Error : The task is not active.\n";

Файл config/configEC2basic.json:

{
    "containerDefinitions": [{
        "command": [],
        "cpu": 1,
        "entryPoint": ["\/usr\/sbin\/apache2ctl -D FOREGROUND"],
        "environment": [],
        "essential": true,
        "image": "usernamedockerhub\/dockercontainer",
        "links": [],
        "memory": 500,
        "mountPoints": [],
        "name": "nameTask",
        "portMappings": [{
            "containerPort": 80,
            "hostPort": 80,
            "protocol": "tcp"
        }],
        "volumesFrom": []
    }],
    "family": "familyTask",
    "volumes": []
}

Затем вам нужно создать кластер:

$clusterName = $this->ecsClient->createCluster([
            'clusterName' => 'test',
        ]);

Затем служба:

$result = $this->ecsClient->createService([
            'desiredCount' => 1,
            'serviceName' => 'serviceName',
            'taskDefinition' => 'taskName',
            'cluster' => 'test'
        ]);

После этого вы должны запустить свой экземпляр EC2:

$result = $this->ec2Client->runInstances([
            'ImageId'        => 'ami-2aaef35d',
            'MinCount'       => 1,
            'MaxCount'       => 1,
            'InstanceType'   => 't2.micro',
            'UserData'       => base64_encode("#!/bin/bash \r\n echo ECS_CLUSTER=test >> /etc/ecs/ecs.config"),
            'IamInstanceProfile' => [
                'Arn' => 'ARNEC2'
            ],

        ]);

Когда ваш EC2 готов, вы можете начать свою задачу:

$result = $this->ecsClient->runTask([
            'taskDefinition' => 'taskName',
            'cluster' => 'test'
        ]);