Блог

я знаю, что в пошаговых функциях AWS мы можем использовать resultPath для передачи вывода текущего состояния в следующее состояние вместе с его входными данными. Допустим, у меня есть 3 состояния A, B и C, когда A завершает выполнение, он передает свои входные данные и выходные данные в B в качестве входных данных, когда B завершает, есть ли способ передать выходные данные B вместе с выходными данными A вход в C в качестве входных данных? Пожалуйста, посоветуйте, спасибо!

если у вас есть только a resultPath в вашей задаче, то он добавляет результат к входящему событию этой задачи, поэтому, если задача A принимает входные данные

 {  TaskAInput: Stuff }  

И имеет только a resultPath: TaskAOutput , то входные данные для задачи B будут:

 {  TaskAInput: Stuff  TaskAOutput: TaskAResult }  

Это входит в задачу B. Если задача B имеет только a resultPath: TaskBOutput , то

 {  TaskAInput: Stuff  TaskAOutput: TaskAResult  TaskBOutput: TaskBesult }  

и так далее по цепочке.

Примечание. Если вы присоедините an outputPath к любому из вышеперечисленных шагов, он выведет только этот путь json из конечного комбинированного ввода и результатов. Если вы вообще используете входной путь, он сократит ввод только до этого в будущем.

Вам просто нужно сделать следующее:

Функция:

 def lambda_handler(event, context):  ...  result = ...  return {  "Ainput":event,  "Aoutput": result  }  

B функция:

 def lambda_handler(event, context):  ...  result = ...  return {  "Ainput": event['Ainput'],  "Aoutput": event['Aoutput'],  "Boutput": result  }    

Функция C:

 def lambda_handler(event, context):  Ainput = event['Ainput']  Aoutput = event['Aoutput']  Boutput = event['Boutput']  

Теперь вы можете использовать эти результаты в своей функции C по своему усмотрению.