Шаговые функции: как разделить контекст между лямбдами?

У меня такой рабочий процесс обработки данных. Задача загрузки создает идентификатор сеанса (GUID) и передает его задаче анализа, а затем задаче публикации. Если в этих трех задачах возникает какое-либо исключение, рабочий процесс переходит к невыполненной задаче. Сбой задачи обновит статус процесса как сбойный в DynamoDB. Для этого ему нужно получить идентификатор сеанса.

Есть ли способ передать идентификатор сеанса невыполненной задаче?

Или, если идентификатор сеанса создается вне и передается в рабочий процесс, можно ли передать этот идентификатор всем задачам?

конечный автомат


person Ken Zhang    schedule 02.11.2018    source источник


Ответы (1)


Укажите свойство ResultPath в ловушке ошибок. По умолчанию это $, что означает, что вывод сбойного параллельного состояния будет только информацией об ошибке. Однако, если вы установите ResultPath на, например, $.error_info, вы сохраните состояние, и данные об ошибках будут доступны в свойстве error_info.

Для получения дополнительных сведений вас может заинтересовать https://docs.aws.amazon.com/step-functions/latest/dg/concepts-error-handling.html (обработка ошибок).

person Marcin Sucharski    schedule 19.11.2018