使用适用于 s3 的 Java 开发工具包将触发器添加到 AWS Lambda 函数

Question

如何使用 Java SDK 为现有 AWS Lambda 函数添​​加新触发器？

我想添加S3 trigger。

我有将图像从一种格式转换为另一种格式的程序。 我首先有两个桶，当我在第二个添加源图像时，我想得到结果。

任何示例都将不胜感激。

谢谢。

像这样触发：

我尝试这样做，但它不起作用：

    final AWSLambda client = AWSLambdaClientBuilder.standard()
                                                   .withCredentials(credentials)
                                                   .build();

  client.listFunctions().getFunctions()
        .stream()
        .filter(f -> f.getFunctionName().equals(FUNCTION_NAME))
        .findFirst()
        .ifPresent(lambda -> {
          final AddPermissionRequest addPermissionRequest = new AddPermissionRequest();
          addPermissionRequest.setStatementId("s3triggerId");
          addPermissionRequest.withSourceArn("arn:aws:s3:::" + INPUT_BUCKET_NAME);
          addPermissionRequest.setAction("lambda:InvokeFunction");
          addPermissionRequest.setPrincipal("events.amazonaws.com");
          addPermissionRequest.setFunctionName(lambda.getFunctionName());

          AddPermissionResult addPermissionResult = client.addPermission(addPermissionRequest);
          System.out.println("Trigger was added to lambda " + addPermissionResult.getStatement());
        });

Answer 1

对于 aws java sdk v2：

您可以通过添加通知配置来添加触发器，例如：

• PutBucketNotificationConfiguration

您可以通过以下方式查看您当前的配置：

• GetBucketNotificationConfiguration

并检查其他来自：https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/s3/S3Client.html

1. 使用 region 和 credentials 提供程序初始化 S3Client（在我的 case,Region.US_WEST_2 和 ProfileCredentialsProvider 分别）。
2. 从 s3client 中选择方法（操作的配置类型） 你的操作（在我的例子中是 putBucketNotificationConfiguration）。
3. 使用bucketName和通知配置为您的通知配置构建请求。
4. 构建通知配置：（类型： topicConfiguration(SNS)、queueConfiguration(SQS)、lambdaFunctionConfiguration(Lambda)) 在我的例子中是 lambdaFunctionConfiguration。
5. 使用 arn 和 events 构建 lambdaFunctionConfiguration，这将 触发您的 lambda 函数（在我的例子中，“arn:aws:lambda:us-west-2:12345678912:function:your-lambda”和 Event.S3_OBJECT_CREATED_PUT；我分配了一个事件，但您可以添加更多）。

另请阅读：https://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html

对于这个例子：

S3lient s3Client = S3Client.builder()
                .region(Region.US_WEST_2)
                .credentialsProvider(ProfileCredentialsProvider.create())
                .build();

s3Client.putBucketNotificationConfiguration(PutBucketNotificationConfigurationRequest.builder()
                .bucket(BUCKET_NAME)
                .notificationConfiguration(NotificationConfiguration.builder()
                        .lambdaFunctionConfigurations(LambdaFunctionConfiguration.builder()
                                .lambdaFunctionArn("arn:aws:lambda:us-west-2:12345678912:function:your-lambda")
                                .events(Event.S3_OBJECT_CREATED_PUT)
                                .build())
                        .build())
                .build());

Answer 2

您可以通过in the console 或via SAM. 进行操作