Блог

Как я могу добавить новый триггер для существующей функции AWS Lambda с помощью Java SDK ?

Я хотел бы добавить 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());
        });
 

Для aws java sdk v2:

Вы можете добавить триггер, добавив конфигурацию уведомлений, такую:

• PutBucketNotificationConfiguration

Вы можете просмотреть свою текущую конфигурацию через:

• GetBucketNotificationConfiguration

И проверьте другое из: https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/s3/S3Client.html

1. Инициализируйте S3Client с регионом и поставщиком учетных данных (в моем случае, Region.US_WEST_2 и ProfileCredentialsProvider соответственно).
2. Выберите метод (тип конфигурации действия) из s3client для вашего действия (в моем случае putBucketNotificationConfiguration).
3. Создайте запрос для вашей конфигурации уведомлений с помощью bucketName и конфигурации уведомлений.
4. Создайте конфигурацию уведомлений: (типы: topicConfiguration (SNS), queueConfiguration (SQS), lambdaFunctionConfiguration (Lambda)) в моем случае lambdaFunctionConfiguration.
5. Создайте конфигурацию lambdaFunctionConfiguration с помощью arn и событий, которые будут запускать вашу лямбда-функцию (в моем случае «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());
 

Вы можете сделать это либо в консоли, либо через SAM.