如何使用Java代码移除Lambda的SQS事件源映射

完全可以通过Java编程实现该操作，不需要手动在控制台操作。SQS和Lambda的触发绑定本质是Lambda侧维护的*事件源映射（Event Source Mapping）*资源，移除操作的核心就是删除对应的事件源映射配置，不会删除SQS队列本身或者Lambda函数。

前置准备 #

• 使用AWS官方Java SDK 2.x版本，相比旧版v1性能更好、API设计更简洁
• 执行代码的身份（本地用户、EC2/ECS实例角色等）需要分配对应Lambda权限：已知事件源映射ID时仅需lambda:DeleteEventSourceMapping权限；需要先查询映射ID时额外需要lambda:ListEventSourceMappings权限
• 每个SQS和Lambda的绑定对应唯一的事件源映射UUID，这是删除操作的必填参数，可以在之前创建绑定的返回结果中获取，也可以通过SDK查询得到

代码实现 #

首先引入SDK依赖，以Maven为例：

<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>lambda</artifactId>
    <version>2.25.0</version>
    <!-- 版本可替换为你实际使用的兼容版本 -->
</dependency>

场景1：已知事件源映射UUID，直接删除 #

import software.amazon.awssdk.services.lambda.LambdaClient;
import software.amazon.awssdk.services.lambda.model.DeleteEventSourceMappingRequest;

public class RemoveSqsTrigger {
    public static void main(String[] args) {
        // 替换为实际的事件源映射UUID
        String targetMappingUuid = "a1b2c3d4-1234-5678-90ab-cdef01234567";
        try (LambdaClient lambdaClient = LambdaClient.create()) {
            DeleteEventSourceMappingRequest deleteReq = DeleteEventSourceMappingRequest.builder()
                    .uuid(targetMappingUuid)
                    .build();
            lambdaClient.deleteEventSourceMapping(deleteReq);
            System.out.println("SQS事件源移除请求已提交");
        }
    }
}

场景2：未知映射UUID，先查询再删除 #

如果没有提前保存映射UUID，可以通过Lambda函数标识、SQS队列ARN筛选出对应的映射配置，再执行删除：

import software.amazon.awssdk.services.lambda.model.EventSourceMappingConfiguration;
import software.amazon.awssdk.services.lambda.model.ListEventSourceMappingsRequest;
import software.amazon.awssdk.services.lambda.model.ListEventSourceMappingsResponse;

// 替换为实际的Lambda函数名/ARN、SQS队列ARN
String lambdaFunctionName = "your-order-process-lambda";
String sqsArn = "arn:aws:sqs:cn-north-1:123456789012:order-queue";

ListEventSourceMappingsRequest listReq = ListEventSourceMappingsRequest.builder()
        .functionName(lambdaFunctionName)
        .eventSourceArn(sqsArn)
        .build();

ListEventSourceMappingsResponse listResp = lambdaClient.listEventSourceMappings(listReq);
for (EventSourceMappingConfiguration mapping : listResp.eventSourceMappings()) {
    // 拿到匹配的映射UUID后，调用前面的删除逻辑即可
    System.out.printf("找到匹配的事件源映射，UUID：%s，当前状态：%s%n", 
            mapping.uuid(), mapping.state());
}

注意：删除事件源映射的接口是异步生效的，提交请求后可能需要等待10-30秒同步，期间控制台可能还会显示该事件源条目，同步完成后会自动消失。删除绑定后SQS队列中未消费的消息会正常保留在队列中，不会丢失，只是不会再触发Lambda执行。

内容的提问来源于stack exchange，提问作者fanando