# 适用于 Java 2.x 的 AWS 开发工具包 - AWS Lambda ## 概述 AWS Lambda 是一种无需管理服务器即可运行代码的计算服务。您的代码会自动运行，并按按使用付费的定价进行扩展和缩减。使用此技能可在应用程序和服务中使用 AWS SDK for Java 2.x 实施 AWS Lambda 操作。 ## 何时使用在以下情况下使用此技能： * 以编程方式调用 Lambda 函数 * 创建或更新 Lambda 函数 * 管理Lambda函数配置 * 使用 Lambda 环境变量 * 管理 Lambda 层和别名 * 实现异步Lambda调用 * Lambda 与 Spring Boot 集成 ## 说明请按照以下步骤使用 AWS Lambda： 1. **添加依赖项** \- 包含 Lambda SDK 依赖项 2. **创建客户端** \- 使用正确的配置实例化 LambdaClient 3. **调用函数** \- 使用invoke()和适当的调用类型 4. **处理响应** \- 解析响应负载并处理函数错误 5. **管理函数** \- 创建、更新或删除 Lambda 函数 6. **配置环境** \- 设置环境变量和并发限制 7. **与 Spring 集成** \- 配置 Lambda beans 和服务 8. **本地测试** \- 使用mocks或LocalStack进行开发测试 ## 依赖关系 <依赖关系> software.amazon.awssdk lambda ## 客户端设置要使用 AWS Lambda，请创建具有所需区域配置的 LambdaClient：导入软件.amazon.awssdk.regions.Region; 导入 software.amazon.awssdk.services.lambda.LambdaClient; LambdaClient lambdaClient = LambdaClient.builder() .region(区域.US_EAST_1) .build(); 对于异步操作，请使用 LambdaAsyncClient：导入 software.amazon.awssdk.services.lambda.LambdaAsyncClient; LambdaAsyncClient asyncLambdaClient = LambdaAsyncClient.builder() .region(区域.US_EAST_1) .build(); ## 调用 Lambda 函数 ### 同步调用同步调用 Lambda 函数以立即获得结果：导入软件.amazon.awssdk.services.lambda.model.*; 导入 software.amazon.awssdk.core.SdkBytes; 公共字符串 invokeLambda(LambdaClient lambdaClient, 字符串函数名，字符串有效负载）{ InvokeRequest 请求 = InvokeRequest.builder() .函数名(函数名) .payload(SdkBytes.fromUtf8String(payload)) .build(); InvokeResponse 响应 = lambdaClient.invoke(request); 返回response.payload().asUtf8String(); } ### 异步调用对“即发即忘”场景使用异步调用：公共无效invokeLambdaAsync（LambdaClient lambdaClient，字符串函数名，字符串有效负载）{ InvokeRequest 请求 = InvokeRequest.builder() .函数名(函数名) .invocationType(InvokingType.EVENT) // 异步 .payload(SdkBytes.fromUtf8String(payload)) .build(); InvokeResponse 响应 = lambdaClient.invoke(request); System.out.println("状态：" + response.statusCode()); } ### 使用 JSON 对象调用使用 JSON 有效负载来处理复杂的数据结构：导入 com.fasterxml.jackson.databind.ObjectMapper; 公共字符串 invokeLambdaWithObject(LambdaClient lambdaClient, 字符串函数名， T requestObject) 抛出异常 { ObjectMapper 映射器 = new ObjectMapper(); String jsonPayload = mapper.writeValueAsString(requestObject); InvokeRequest 请求 = InvokeRequest.builder() .函数名(函数名) .payload(SdkBytes.fromUtf8String(jsonPayload)) .build(); InvokeResponse 响应 = lambdaClient.invoke(request); 返回response.payload().asUtf8String(); } ### 解析类型响应将 JSON 响应解析为类型化对象：公共 T invokeLambdaAndParse(LambdaClient lambdaClient, 字符串函数名，对象请求，类 responseType) 抛出异常 { ObjectMapper 映射器 = new ObjectMapper(); 字符串 jsonPayload = mapper.writeValueAsString(request); InvokeRequest invokeRequest = InvokeRequest.builder() .函数名(函数名) .payload(SdkBytes.fromUtf8String(jsonPayload)) .build(); InvokeResponse 响应 = lambdaClient.invoke(invokeRequest); 字符串responseJson = response.payload().asUtf8String(); 返回mapper.readValue(responseJson,responseType); } ## 功能管理 ### 列表函数列出当前账户的所有 Lambda 函数：公共列表 listFunctions(LambdaClient lambdaClient) { ListFunctionsResponse 响应 = lambdaClient.listFunctions(); 返回response.functions(); } ### 获取函数配置检索函数配置和元数据：公共 FunctionConfiguration getFunctionConfig(LambdaClient lambdaClient, 字符串函数名) { GetFunctionRequest 请求 = GetFunctionRequest.builder() .函数名(函数名) .build(); GetFunctionResponse 响应 = lambdaClient.getFunction(request); 返回response.configuration(); } ### 更新函数代码使用新的部署包更新 Lambda 函数代码：导入java.nio.file.Files；导入java.nio.file.Paths；公共无效 updateFunctionCode（LambdaClient lambdaClient，字符串函数名，字符串 zipFilePath) 抛出 IOException { byte[] zipBytes = Files.readAllBytes(Paths.get(zipFilePath)); UpdateFunctionCodeRequest 请求 = UpdateFunctionCodeRequest.builder() .函数名(函数名) .zipFile(SdkBytes.fromByteArray(zipBytes)) .发布（真） .build(); UpdateFunctionCodeResponse 响应 = lambdaClient.updateFunctionCode(request); System.out.println("更新后的函数版本：" + response.version()); } ### 更新功能配置修改函数设置，如超时、内存和环境变量：公共无效 updateFunctionConfiguration（LambdaClient lambdaClient，字符串函数名， Map 环境) { 环境 env = Environment.builder() .变量（环境） .build(); UpdateFunctionConfigurationRequest 请求 = UpdateFunctionConfigurationRequest.builder() .函数名(函数名) .环境（env） .超时(60) .内存大小(512) .build(); lambdaClient.updateFunctionConfiguration（请求）； } ### 创建函数使用代码和配置创建新的 Lambda 函数：公共无效createFunction（LambdaClient lambdaClient，字符串函数名，字符串角色Arn, 字符串处理程序，字符串 zipFilePath) 抛出 IOException { byte[] zipBytes = Files.readAllBytes(Paths.get(zipFilePath)); FunctionCode 代码 = FunctionCode.builder() .zipFile(SdkBytes.fromByteArray(zipBytes)) .build(); CreateFunctionRequest 请求 = CreateFunctionRequest.builder() .函数名(函数名) .runtime(运行时.JAVA17) .role(roleArn) .handler(处理程序) .code(代码) .超时(60) .内存大小(512) .build(); CreateFunctionResponse 响应 = lambdaClient.createFunction(request); System.out.println("函数ARN：" + response.functionArn()); } ### 删除函数不再需要时删除 Lambda 函数：公共无效deleteFunction（LambdaClient lambdaClient，字符串函数名）{ DeleteFunctionRequest请求=DeleteFunctionRequest.builder() .函数名(函数名) .build(); lambdaClient.deleteFunction(请求); } ## Spring Boot 集成 ### 配置将 Lambda 客户端配置为 Spring bean：导入 org.springframework.context.annotation.Bean; 导入 org.springframework.context.annotation.Configuration; @配置公共类 LambdaConfiguration { @豆子公共 LambdaClient lambdaClient() { 返回 LambdaClient.builder() .region(区域.US_EAST_1) .build(); } } ### Lambda 调用程序服务创建用于 Lambda 函数调用的服务：导入 org.springframework.stereotype.Service; 导入 org.springframework.beans.factory.annotation.Autowired; @服务公共类 LambdaInvokerService { 私有最终 LambdaClient lambdaClient; 私有最终 ObjectMapper 对象映射器； @Autowired 公共 LambdaInvokerService(LambdaClient lambdaClient, ObjectMapper objectMapper) { this.lambdaClient = lambdaClient; this.objectMapper = objectMapper; } public R invoke(String functionName, T request, Class responseType) { 尝试{ String jsonPayload = objectMapper.writeValueAsString(request); InvokeRequest invokeRequest = InvokeRequest.builder() .函数名(函数名) .payload(SdkBytes.fromUtf8String(jsonPayload)) .build(); InvokeResponse 响应 = lambdaClient.invoke(invokeRequest); if (response.functionError() != null) { 抛出新的 LambdaInvocationException( “Lambda 函数错误：” + response.functionError()); } 字符串responseJson = response.payload().asUtf8String(); 返回objectMapper.readValue(responseJson,responseType); } catch (异常 e) { throw new RuntimeException("调用 Lambda 函数失败", e); } } 公共无效invokeAsync（字符串函数名，对象请求）{ 尝试{ String jsonPayload = objectMapper.writeValueAsString(request); InvokeRequest invokeRequest = InvokeRequest.builder() .函数名(函数名) .invokingType(InvokingType.EVENT) .payload(SdkBytes.fromUtf8String(jsonPayload)) .build(); lambdaClient.invoke(invokeRequest); } catch (异常 e) { throw new RuntimeException("无法调用 Lambda 函数异步", e); } } } ### 类型化 Lambda 客户端为 Lambda 服务创建类型安全的接口：公共接口订单处理器{ OrderResponse processOrder(OrderRequest 请求); } @服务公共类 LambdaOrderProcessor 实现 OrderProcessor { 私有最终 LambdaInvokerService lambdaInvoker； @Value("${lambda.order-processor.function-name}") 私有字符串函数名；公共 LambdaOrderProcessor(LambdaInvokerService lambdaInvoker) { this.lambdaInvoker = lambdaInvoker; } @覆盖公共 OrderResponse processOrder(OrderRequest 请求) { return lambdaInvoker.invoke(functionName, request, OrderResponse.class); } } ## 错误处理为 Lambda 操作实施全面的错误处理：公共字符串 invokeLambdaSafe(LambdaClient lambdaClient, 字符串函数名，字符串有效负载）{ 尝试{ InvokeRequest 请求 = InvokeRequest.builder() .函数名(函数名) .payload(SdkBytes.fromUtf8String(payload)) .build(); InvokeResponse 响应 = lambdaClient.invoke(request); // 检查函数错误 if (response.functionError() != null) { String errorMessage = response.payload().asUtf8String(); 抛出新的 RuntimeException("Lambda 错误：" + errorMessage); } // 检查状态码 if (response.statusCode() != 200) { throw new RuntimeException("Lambda 调用失败，状态：" + 响应.statusCode()); } 返回response.payload().asUtf8String(); } catch (LambdaException e) { System.err.println("Lambda 错误：" + e.awsErrorDetails().errorMessage()); 扔 e； } } 公共类 LambdaIncationException 扩展 RuntimeException { 公共 LambdaInvocationException（字符串消息）{ 超级（消息）； } 公共 LambdaInvocationException（字符串消息，可抛出原因）{ 超级（消息，原因）； } } ## 示例 ### 示例 1：基本 Lambda 调用公共字符串invokeFunction（LambdaClient客户端，字符串函数名称，字符串有效负载）{ InvokeRequest 请求 = InvokeRequest.builder() .函数名(函数名) .payload(SdkBytes.fromUtf8String(payload)) .build(); InvokeResponse 响应 = client.invoke(request); if (response.functionError() != null) { 抛出新的 RuntimeException("Lambda 错误：" + response.functionError()); } 返回response.payload().asUtf8String(); } ### 示例 2：异步调用公共无效invokeAsync（LambdaClient客户端，字符串函数名称，Map 事件）{ 尝试{ String jsonPayload = new ObjectMapper().writeValueAsString(event); InvokeRequest 请求 = InvokeRequest.builder() .函数名(函数名) .invokingType(InvokingType.EVENT) .payload(SdkBytes.fromUtf8String(jsonPayload)) .build(); 客户端.调用（请求）； } catch (异常 e) { throw new RuntimeException("异步调用失败", e); } } ### 示例 3：Spring Boot 服务 @服务公共类 LambdaService { 私有最终 LambdaClient lambdaClient; 私有最终 ObjectMapper 对象映射器； @Value("${lambda.用户处理器函数}") 私有字符串 userProcessorFunction；公共 UserResponse processUser(UserRequest 请求) { 尝试{ 字符串有效负载 = objectMapper.writeValueAsString(request); InvokeResponse 响应 = lambdaClient.invoke( InvokeRequest.builder() .functionName(用户处理器函数) .payload(SdkBytes.fromUtf8String(payload)) .build() ）；返回 objectMapper.readValue( response.payload().asUtf8String(), 用户响应.class ）； } catch (异常 e) { throw new RuntimeException("用户处理失败", e); } } } 有关完整的代码示例，请参阅参考资料部分： * **基本示例** \- 简单的调用模式和功能管理 * **Spring Boot集成** \- 完整的Spring Boot配置和服务模式 * **测试示例** \- 单元和集成测试模式 * **高级模式** \- 复杂场景和最佳实践 ## 限制和警告 * **有效负载大小**：同步调用的 Lambda 有效负载限制为 6MB，异步调用限制为 256KB * **超时** ：最大功能超时为 15 分钟 * **内存** ：内存配置影响CPU和网络性能 * **并发** ：帐户级并发限制可能会导致限制 * **冷启动** ：新调用可能会延迟初始化 * **VPC** ：VPC功能需要正确的安全组和子网配置 * **层** ：Lambda 层计入部署包大小限制 * **保留并发**：防止限制但限制最大扩展 * **事件源映射** ：某些事件源需要特殊配置 * **成本** ：意外的使用可能会导致高额账单；设置预算和警报 ## 最佳实践 1. **重用 Lambda 客户端**：创建一次并在调用之间重用 2. **设置适当的超时**：将客户端超时与 Lambda 函数超时相匹配 3. **使用异步调用**：适用于即发即忘场景 4. **正确处理错误**：检查功能错误和状态代码 5. **使用环境变量** ：用于功能配置 6. **实现重试逻辑**：针对瞬时故障 7. **监控调用**：使用 CloudWatch 指标 8. **版本功能** ：使用别名和版本进行生产 9. **使用VPC**：用于访问私有子网中的资源 10. **优化有效负载大小**：保持较小的有效负载以获得更好的性能 ## 测试使用模拟和测试断言测试 Lambda 服务：导入 org.junit.jupiter.api.Test; 导入 org.junit.jupiter.api.extension.ExtendWith; 导入 org.mockito.InjectMocks; 导入 org.mockito.Mock; 导入 org.mockito.junit.jupiter.MockitoExtension; @ExtendWith(MockitoExtension.class) 类 LambdaInvokerServiceTest { @模拟私人 LambdaClient lambdaClient; @模拟私有 ObjectMapper 对象映射器； @InjectMocks 私有 LambdaInvokerService 服务； @测试 void shouldInvokeLambdaSuccessively() 抛出异常 { // 测试实现 } } ## 相关技能 * @aws-sdk-java-v2-core - 核心AWS SDK模式和客户端配置 * @spring-boot-dependency-injection - Spring 依赖注入最佳实践 * @unit-test-service-layer - 使用 Mockito 进行服务测试模式 * @spring-boot-actuator - 生产监控和健康检查 ## 参考文献有关详细信息和示例，请参阅以下参考文件： * **[官方文档]()** \- AWS Lambda 概念、API 参考和官方指南 * **[示例]()** \- 完整的代码示例和集成模式 ## 其他资源 * [GitHub 上的 Lambda 示例]() * [Lambda API 参考]() * [AWS Lambda 开发人员指南]()

AWS SDK Java V2 Lambda

包含技能