веб-сервисы Amazon — AWS SDK (PHP): асинхронный вызов лямбда-функции, получение статуса

У нас есть лямбда-функция AWS, используемая для обработки и настройки некоторых ужасных проприетарных форматов файлов. внизнагрузка, которая запускается из PHP через AWS SDK. Лямбда извлекает файл из корзины s3, вставляет в него некоторые метаданные, сжимает их и помещает во временную корзину s3, чтобы их можно было загрузить во время проверки покупателем.

Лямбда-часть работает без нареканий вызова / invokeAsync:

use Aws\Sdk;
...
$lambdaclient = $this->sdk->createClient('lambda',$region);

$syncresult = $lambdaclient->invoke([
'FunctionName' => $functionName,
'InvocationType' => 'RequestResponse',
'Payload' => json_encode($payload),
]);

$asyncresult = $lambdaclient->invoke([
'FunctionName' => $functionName,
'InvocationType' => 'Event',
'Payload' => json_encode($payload),
]);

$promise = $lambdaclient->invokeAsync([
'FunctionName' => $functionName,
'Payload' => json_encode($payload),
]);

• $ syncresult будет содержать статус успешного / сбой лямбда-функции, опционально с журналом (через LogType Tail).

Проблема в том, что лямбда может занять до минуты, что довольно долго для PHP, чтобы вернуть ответ браузеру.

• $ asyncresult вызовет функцию и вернет HTTP-статус 202, но без возможности позже проверить, действительно ли функция что-то сделала.

• $ обещает жадность обещание которые широко используются в AWS SDK, к которому в PHP может быть привязана функция, которая будет выполняться по окончании лямбды. Это кажется очень полезным, если PHP не возвращает ответ браузеру, потому что в этот момент вы теряете обещание. Ты можешь позвонить $result = $promise->wait() чтобы разрешить это. Основным преимуществом этих обещаний, по-видимому, является одновременное выполнение нескольких лямбд и объединение результатов в одном запросе PHP.

Я хотел бы вызвать функцию асинхронно и проверить состояние функции в потом PHP-запрос (возможно, хранит некоторую ссылку на вызов в данных сеанса?). Таким образом, я мог бы позже опросить статус, используя Ajax-запрос, и убедиться, что когда я создаю подписанный URL-адрес s3 для окончательного файла, все завершается без ошибок.

Будет ли это возможно с помощью AWS SDK? Или есть лучшие решения?

Редактировать:

Я решил использовать invokeAsync, запускаемый из-за вызова ajax на стороне клиента, который прерывается (не дожидаясь ответа). Сценарию PHP дается довольно много времени для завершения (с использованием settimelimit), потому что вызовы лямбды выполняются одновременно, и браузер больше не ждет.

Я храню обещания в массиве и использую:

$values = array_map(function($result){
return json_decode($result->toArray()['Payload']->getContents());
}, Promise\unwrap($promises));

получить ответные полезные нагрузки (они обернуты в streaminterfaces AWS SDK) и записать их (DynamoDB в моем случае, SQL / session / cache, вероятно, все будет работать).

Когда конечному пользователю нужен результат, я просто проверяю сохраненные данные и существуют ли преобразованные файлы на s3.

Я мог бы улучшить обработку ajax, поиграв с очисткой выходного буфера из PHP, правильно завершив вызов с некоторым возвращенным идентификатором, и позволяя PHP ждать обещаний от AWS.