从步骤函数向lambda任务传递并使用输入(参数)

基于您所说的："寻找传递参数的方法(事件/上下文)到若干后续任务中的每一个">我以为您希望将非静态值传递给lambdas。

有两种方法通过状态机传递参数。经由CCD_ 1和CCD_。如有差异，请查看此处。

如果没有任何要传递给lambda的静态值，我将执行以下操作。以json格式将所有参数传递给step函数。

为状态机输入JSON

{
"foo": 123,
"bar": ["a", "b", "c"],
"car": {
"cdr": true
}
"TableName": "table_example"
}

在步骤函数中，使用"InputPath": "$"将整个JSON显式传递给lambda，但第一步是隐式传递的。有关$路径语法的更多信息，请查看此处。您还需要注意任务结果，使用ResultPath的多种方法之一。在大多数情况下，最安全的解决方案是将任务结果保持在特殊变量"ResultPath": "$.taskresult"中

{
"Comment": "A Hello World example of the Amazon States Language using an AWS Lambda function",
"StartAt": "HelloWorld",
"States": {
"HelloWorld": {
"Type": "Task",
"Resource": "arn:aws:lambda:ap-southeast-2:XXXXXXX:function:fields_sync",
"Next": "HelloWorld2"
},
"HelloWorld2": {
"Type": "Task",
"InputPath": "$",
"ResultPath": "$.taskresult"
"Resource": "arn:aws:lambda:ap-southeast-2:XXXXXXX:function:fields_sync_2",
"End": true
}
}
}

lambda中的哪个成为事件变量，可以作为python字典访问

def lambda_handler(event, context):
table_example = event["TableName"]
a = event["bar"][0]
cdr_value = event["car"]["cdr"]
# taskresult will not exist as event key 
# only on lambda triggered by first state
# in the rest of subsequent states
# it will hold a task result of last executed state
taskresult = event["taskresult"]

使用这种方法，您可以使用多个步骤函数和不同的lambda，并且通过移动lambdas中的所有逻辑，仍然保持它们干净且小。此外，它更容易调试，因为所有Lambda中的所有事件变量都是相同的，所以通过简单的print(event)，您可以看到整个状态机所需的所有参数以及可能出现的问题。

很明显，当Resource设置为lambda ARN(例如"arn:aws:lambda:ap-southeast-2:XXXXXXX:function:fields_sync")时，您不能使用InputPath0来指定输入，而是传递步骤函数的状态(如果之前没有步骤，则可能是状态函数的输入)。

要通过Parameters传递函数输入，您可以将Resource指定为"arn:aws:states:::lambda:invoke"，并在Parameters部分提供您的FunctionName：

{
"StartAt": "HelloWorld",
"States": {
"HelloWorld": {
"Type": "Task",
"Resource": "arn:aws:states:::lambda:invoke",
"Parameters": {
"FunctionName": "YOUR_FUNCTION_NAME",
"Payload": {
"SOMEPAYLOAD": "YOUR PAYLOAD"
}
},
"End": true
}
}
}

您可以在这里找到调用Lambda函数的文档：https://docs.aws.amazon.com/step-functions/latest/dg/connect-lambda.html

您也可以潜在地使用inputPath，或者也可以使用步骤函数状态函数中的元素：https://docs.aws.amazon.com/step-functions/latest/dg/input-output-inputpath-params.html

就像Milan在评论中提到的那样，您可以将数据从Step function State传递给Lambda函数。

在Lambda函数中，您需要读取event的内容。

import json
def lambda_handler(event, context):
TableName = event['TableName']