實作 AWS Lambda 任務

開啟 Amazon IAM 主控台。

選擇 Roles (角色)，然後選擇 Create New Role (建立新角色)。

為您的角色提供名稱，例如 swf-lambda，然後選擇 Next Step (下一步)。

UNDERAWS服務角色，選擇Amazon SWF，然後選擇後續步驟。

在連接政策屏幕上，選擇AWSLambdaRole從清單中。

當您檢閱好角色後，請選擇 Next Step (下一步)，然後選擇 Create Role (建立角色)。

開啟 Amazon IAM 主控台。

選擇 Policies (政策)，然後選擇 Create Policy (建立政策)。

選擇複製AWS托管策略，然後選取AWSLambdaRole從清單中。即會為您產生政策。您可選擇性編輯其名稱及描述，以符合您的需求。

在 中資源欄位Policy Document (政策文件)，添加 Lambda 函數的 ARN。例如：

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": [
        "lambda:InvokeFunction"
      ],
      "Resource": [
        "arn:aws:lambda:us-east-1:111111000000:function:hello_lambda_function"
      ]
    }
  ]
}

選擇 Create Policy (建立政策) 來完成您的政策建立程序。

開啟 Amazon IAM 主控台。

選擇 Roles (角色)，然後選擇 Create New Role (建立新角色)。

為您的角色提供名稱，例如 swf-lambda-function，然後選擇 Next Step (下一步)。

UNDERAWS服務角色，選擇Amazon SWF，然後選擇後續步驟。

在連接政策窗口中，從清單中選取 Lambda 函數專用政策。

當您檢閱好角色後，請選擇 Next Step (下一步)，然後選擇 Create Role (建立角色)。

在您的工作流程實作中，於 DecisionContext 執行個體上呼叫 getLambdaFunctionClient() 以取得 LambdaFunctionClient 執行個體。

// Get a LambdaFunctionClient instance
DecisionContextProvider decisionProvider = new DecisionContextProviderImpl();
DecisionContext decisionContext = decisionProvider.getDecisionContext();
LambdaFunctionClient lambdaClient = decisionContext.getLambdaFunctionClient();

使用scheduleLambdaFunction()方法LambdaFunctionClient，將您建立的 Lambda 函數名稱和 Lambda 任務的所有輸入數據傳遞給它。

// Schedule the Lambda function for execution, using your IAM role for access.
String lambda_function_name = "The name of your Lambda function.";
String lambda_function_input = "Input data for your Lambda task.";

lambdaClient.scheduleLambdaFunction(lambda_function_name, lambda_function_input);

在您的工作流程執行啟動者中，使用StartWorkflowOptions.withLambdaRole()，然後在啟動工作流時傳遞選項。

// Workflow client classes are generated for you when you use the @Workflow
// annotation on your workflow interface declaration.
MyWorkflowClientExternalFactory clientFactory =
  new MyWorkflowClientExternalFactoryImpl(sdk_swf_client, swf_domain);

MyWorkflowClientExternal workflow_client = clientFactory.getClient();

// Give the ARN of an IAM role that allows SWF to invoke Lambda functions on
// your behalf.
String lambda_iam_role = "arn:aws:iam::111111000000:role/swf_lambda_role";

StartWorkflowOptions workflow_options =
  new StartWorkflowOptions().withLambdaRole(lambda_iam_role);

// Start the workflow execution
workflow_client.helloWorld("User", workflow_options);