| 직접 재개 가능한 객체 | 지원되지 않음 |
### 결과 객체
| V1 클래스 | V2 클래스 | 마이그레이션 상태 |
| --- | --- | --- |
| CopyResult | CompletedCopy | 지원됨 |
| UploadResult | CompletedUpload | 지원됨 |
### 구성 객체
| V1 클래스 | V2 클래스 | 마이그레이션 상태 |
| --- | --- | --- |
| TransferManagerConfiguration | MultipartConfiguration(Amazon S3 클라이언트 기반) | 지원됨 |
| TransferProgress | TransferProgress \$1 TransferProgressSnapshot | 지원됨 |
| KeyFilter | DownloadFilter | 지원됨 |
### 지원되지 않는 객체
| V1 클래스 | V2 대안 | 마이그레이션 상태 |
| --- | --- | --- |
| PauseStatus | 지원되지 않음 | 지원되지 않음 |
| UploadContext | 지원되지 않음 | 지원되지 않음 |
| ObjectCannedAclProvider | PutObjectRequest.builder().acl() | 지원되지 않음 |
| ObjectMetadataProvider | PutObjectRequest.builder().metadata() | 지원되지 않음 |
| ObjectTaggingProvider | PutObjectRequest.builder().tagging() | 지원되지 않음 |
| PresignedUrlDownload | 지원되지 않음 | 지원되지 않음 |
## TransferManagerBuilder 구성 마이그레이션
### 구성 변경
v2 Transfer Manager에 대해 설정해야 하는 구성 변경 사항은 사용하는 S3 클라이언트에 따라 다릅니다. AWS CRT 기반 S3 클라이언트 또는 표준 Java 기반 S3 비동기 클라이언트 중에서 선택할 수 있습니다. 차이점에 대한 자세한 내용은 [의 S3 클라이언트 AWS SDK for Java 2.x](examples-s3.md#s3-clients) 주제를 참조하세요.
------
#### [ Use the AWS CRT-based S3 client ]
****
| 설정 | v1 | v2 - AWS CRT 기반 S3 클라이언트를 사용하는 Transfer Manager |
| --- | --- | --- |
| (빌더 구하기) | TransferManagerBuilder tmBuilder =
TransferManagerBuilder.standard();
| S3TransferManager.Builder tmBuilder =
S3TransferManager.builder();
|
| S3 클라이언트 | tmBuilder.withS3Client(...);
tmBuilder.setS3Client(...);
| tmBuilder.s3Client(...);
|
| 실행자 | tmBuilder.withExecutorFactory(...);
tmBuilder.setExecutorFactory(...);
| tmBuilder.executor(...);
|
| 스레드 풀 종료 | tmBuilder.withShutDownThreadPools(...);
tmBuilder.setShutdownThreadPools(...);
| 지원되지 않음. 제공된 실행기는 S3TransferManager가 닫힐 때 종료되지 않습니다. |
| 최소 업로드 파트 크기 | tmBuilder.withMinimumUploadPartSize(...);
tmBuilder.setMinimumUploadPartSize(...);
| S3AsyncClient s3 = S3AsyncClient.crtBuilder().
minimumPartSizeInBytes(...).build();
tmBuilder.s3Client(s3);
|
| 멀티파트 업로드 임계값 | tmBuilder.withMultipartUploadThreshold(...);
tmBuilder.setMultipartUploadThreshold(...);
| S3AsyncClient s3 = S3AsyncClient.crtBuilder().
thresholdInBytes(...).build();
tmBuilder.s3Client(s3);
|
| 최소 복사 파트 크기 | tmBuilder.withMultipartCopyPartSize(...);
tmBuilder.setMultipartCopyPartSize(...);
| S3AsyncClient s3 = S3AsyncClient.crtBuilder().
minimumPartSizeInBytes(...).build();
tmBuilder.s3Client(s3);
|
| 멀티파트 복사 임계값 | tmBuilder.withMultipartCopyThreshold(...);
tmBuilder.setMultipartCopyThreshold(...);
| S3AsyncClient s3 = S3AsyncClient.crtBuilder().
thresholdInBytes(...).build();
tmBuilder.s3Client(s3);
|
| 병렬 다운로드 비활성화 | tmBuilder.withDisableParallelDownloads(...);
tmBuilder.setDisableParallelDownloads(...);
| 멀티파트 비활성화(기본값)으로 설정된 표준 Java 기반 S3 클라이언트를 Transfer Manager에 전달하여 병렬 다운로드를 비활성화합니다.S3AsyncClient s3 =
S3AsyncClient.builder().build();
tmBuilder.s3Client(s3);
|
| 항상 멀티파트 md5를 계산하세요. | tmBuilder.withAlwaysCalculateMultipartMd5(...);
tmBuilder.setAlwaysCalculateMultipartMd5(...);
| 지원되지 않음. |
------
#### [ Use Java-based S3 async client ]
****
| 설정 | v1 | v2 - Java 기반 S3 비동기식 클라이언트를 사용하는 Transfer Manager |
| --- | --- | --- |
| (빌더 구하기) | TransferManagerBuilder tmBuilder =
TransferManagerBuilder.standard();
| S3TransferManager.Builder tmBuilder =
S3TransferManager.builder();
|
| S3 클라이언트 | tmBuilder.withS3Client(...);
tmBuilder.setS3Client(...);
| tmBuilder.s3Client(...);
|
| 실행자 | tmBuilder.withExecutorFactory(...);
tmBuilder.setExecutorFactory(...);
| tmBuilder.executor(...);
|
| 스레드 풀 종료 | tmBuilder.withShutDownThreadPools(...);
tmBuilder.setShutdownThreadPools(...);
| 지원되지 않음. 제공된 실행기는 S3TransferManager가 닫힐 때 종료되지 않습니다. |
| 최소 업로드 파트 크기 | tmBuilder.withMinimumUploadPartSize(...);
tmBuilder.setMinimumUploadPartSize(...);
| S3AsyncClient s3 = S3AsyncClient.builder()
.multipartConfiguration(cfg ->
cfg.minimumPartSizeInBytes(...)).build();
tmBuilder.s3Client(s3);
|
| 멀티파트 업로드 임계값 | tmBuilder.withMultipartUploadThreshold(...);
tmBuilder.setMultipartUploadThreshold(...);
| S3AsyncClient s3 = S3AsyncClient.builder()
.multipartConfiguration(cfg ->
cfg.thresholdInBytes(...)).build();
tmBuilder.s3Client(s3);
|
| 최소 복사 파트 크기 | tmBuilder.withMultipartCopyPartSize(...);
tmBuilder.setMultipartCopyPartSize(...);
| S3AsyncClient s3 = S3AsyncClient.builder()
.multipartConfiguration(cfg ->
cfg.minimumPartSizeInBytes(...)).build();
tmBuilder.s3Client(s3);
|
| 멀티파트 복사 임계값 | tmBuilder.withMultipartCopyThreshold(...);
tmBuilder.setMultipartCopyThreshold(...);
| S3AsyncClient s3 = S3AsyncClient.builder()
.multipartConfiguration(cfg ->
cfg.thresholdInBytes(...)).build();
tmBuilder.s3Client(s3);
|
| 병렬 다운로드 비활성화 | tmBuilder.withDisableParallelDownloads(...);
tmBuilder.setDisableParallelDownloads(...);
| 멀티파트 비활성화(기본값)으로 설정된 표준 Java 기반 S3 클라이언트를 Transfer Manager에 전달하여 병렬 다운로드를 비활성화합니다.S3AsyncClient s3 =
S3AsyncClient.builder().build();
tmBuilder.s3Client(s3);
|
| 항상 멀티파트 md5를 계산하세요. | tmBuilder.withAlwaysCalculateMultipartMd5(...);
tmBuilder.setAlwaysCalculateMultipartMd5(...);
| 지원되지 않음. |
------
## 동작 변경 사항
### 비동기식 운영
**V1(차단):**
```
Upload upload = transferManager.upload("amzn-s3-demo-bucket", "key", file);
upload.waitForCompletion(); // Blocks until complete
```
**V2(비동기식):**
```
FileUpload upload = transferManager.uploadFile(UploadFileRequest.builder()
.putObjectRequest(PutObjectRequest.builder()
.bucket("amzn-s3-demo-bucket")
.key("key")
.build())
.source(file)
.build());
CompletedFileUpload result = upload.completionFuture().join(); // Blocks until complete
// Or handle asynchronously:
upload.completionFuture().thenAccept(result -> {
System.out.println("Upload completed: " + result.response().eTag());
});
```
### 오류 처리
**V1:** 하위 요청이 실패하면 디렉터리 전송이 완전히 실패합니다.
**V2:** 일부 하위 요청이 실패하더라도 디렉터리 전송이 성공적으로 완료됩니다. 다음과 같이 오류를 명시적으로 확인합니다.
```
DirectoryUpload directoryUpload = transferManager.uploadDirectory(request);
CompletedDirectoryUpload result = directoryUpload.completionFuture().join();
// Check for failed transfers
if (!result.failedTransfers().isEmpty()) {
System.out.println("Some uploads failed:");
result.failedTransfers().forEach(failed ->
System.out.println("Failed: " + failed.exception().getMessage()));
}
```
### 바이트 범위 페치를 통한 병렬 다운로드
v2 SDK에서 자동 병렬 전송 기능이 활성화되면 S3 Transfer Manager v2는 [바이트 범위 가져오기](https://docs.aws.amazon.com/AmazonS3/latest/userguide/optimizing-performance-guidelines.html#optimizing-performance-guidelines-get-range)를 사용하여 객체의 특정 부분을 병렬로 검색(멀티파트 다운로드)합니다. v2를 사용하여 객체를 다운로드하는 방법은 객체가 처음 업로드된 방식에 따라 달라지지 않습니다. 모든 다운로드는 높은 처리량과 동시성의 이점을 누릴 수 있습니다.
이와 대조적으로 v1의 S3 Transfer Manager에서는 객체가 원래 업로드된 방식이 중요합니다. v1 Transfer Manager는 일부가 업로드된 것과 동일한 방식으로 객체의 일부를 검색합니다. 객체가 원래 단일 객체로 업로드된 경우 v1 Transfer Manager는 하위 요청을 사용하여 다운로드 프로세스를 가속화할 수 없습니다.
# 버전 1에서 버전 2로 Amazon S3 URI 구문 분석에 관한 변경 사항
이 주제에서는 버전 1(v1)에서 버전 2(v2)로의 Amazon S3 URI 구문 분석의 변경 사항에 대해 자세히 설명합니다.
## 높은 수준의 변경 사항
v1에서 S3 URI 구문 분석을 시작하려면 생성자를 사용하여 `AmazonS3URI`를 인스턴스화합니다. v2에서는 `S3Utilities`의 인스턴스에서 `parseUri()`를 직접적으로 호출하여 `S3URI`를 반환합니다.
****
| 변경 | v1 | v2 |
| --- | --- | --- |
| Maven 종속성 |
com.amazonaws
aws-java-sdk-bom
1.12.5871
pom
import
com.amazonaws
s3
|
software.amazon.awssdk
bom
2.27.212
pom
import
software.amazon.awssdk
s3
|
| 패키지 이름 | com.amazonaws.services.s3 | software.amazon.awssdk.services.s3 |
| 클래스 이름 | [AmazonS3URI](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/AmazonS3URI.html) | [S3URI](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/s3/S3Uri.html) |
1 [최신 버전](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [최신 버전](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API 변경 사항
| 동작 | v1 | v2 |
| --- | --- | --- |
| S3 URI를 구문 분석합니다. | URI uri = URI.create( "https://s3.amazonaws.com");
AmazonS3Uri s3Uri =
new AmazonS3URI(uri, false);
| S3Client s3Client = S3Client.create();
S3Utilities s3Utilities =
s3Client.utilities();
S3Uri s3Uri =
s3Utilities.parseUri(uri);
|
| S3 버킷에서 버킷 이름을 검색합니다. | String bucket = s3Uri.getBucket();
| Optional bucket = s3Uri.bucket();
|
| 키를 검색합니다. | String key = s3Uri.getKey();
| Optional key = s3Uri.key();
|
| 리전을 검색합니다. | String region = s3Uri.getRegion();
| Optional region = s3Uri.region();
String region;
if (s3Uri.region().isPresent()) {
region = s3Uri.region().get().id();
}
|
| S3 URI가 경로형인지 검색합니다. | boolean isPathStyle = s3Uri.isPathStyle();
| boolean isPathStyle = s3Uri.isPathStyle();
|
| 버전 ID를 검색합니다. | String versionId = s3Uri.getVersionId();
| Optional versionId =
s3Uri.firstMatchingRawQueryParameter("versionId");
|
| 쿼리 파라미터를 검색합니다. | 해당 사항 없음 | Map> queryParams =
s3Uri.rawQueryParameters();
|
### 동작 변경 사항
#### URL 인코딩
v1은 플래그를 전달하여 URI를 URL로 인코딩할지 여부를 지정하는 옵션을 제공합니다. 기본값은 `true`입니다.
v2에서는 URL 인코딩이 지원되지 않습니다. 예약되었거나 안전하지 않은 문자가 있는 객체 키 또는 쿼리 파라미터로 작업하는 경우 URL 인코딩해야 합니다. 예를 들어 공백(`" "`)을 `%20`으로 바꿔야 합니다.
# S3 이벤트 알림 API를 버전 1에서 버전 2로 변경
이 주제에서는 S3 이벤트 알림 API를 AWS SDK for Java의 버전 1.x(v1)에서 버전 2 .x(v2)로 변경에 대해 자세히 설명합니다.
## 높은 수준의 변경 사항
### 구문 변경 사항
V1은 `EventNotificationRecord` 유형 및 속성에 정적 내부 클래스를 사용하는 반면, v2는 `EventNotificationRecord` 유형에 대해 별도의 퍼블릭 클래스를 사용합니다.
### 이름 지정 규칙 변경 사항
V1에서 속성 클래스 이름에는 접미사 *엔터티*가 포함되는 반면, V2에서는 보다 간단한 이름 지정을 위해 이 접미사를 생략합니다. 예를 들어 *eventDataEntity*가 아닌 *eventData*입니다.
## 종속성, 패키지 및 클래스 이름의 변경 사항
V1에서 S3 이벤트 알림 API 클래스는 S3 모듈(artifactId `aws-java-sdk-s3`)과 함께 사용하여 전이적으로 가져옵니다. 그러나 V2에서는 `s3-event-notifications` 아티팩트에 대한 종속성을 추가해야 합니다.
****
| 변경 | v1 | v2 |
| --- | --- | --- |
| Maven 종속성 |
com.amazonaws
aws-java-sdk-bom
1.X.X
pom
import
com.amazonaws
aws-java-sdk-s3
|
software.amazon.awssdk
bom
2.X.X1
pom
import
software.amazon.awssdk
s3-event-notifications
|
| 패키지 이름 | com.amazonaws.services.s3.event | software.amazon.awssdk.eventnotifications.s3.model |
| 클래스 이름 | [S3EventNotification](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.html) [S3EventNotification.S3EventNotificationRecord](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.S3EventNotificationRecord.html) [S3EventNotification.GlacierEventDataEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.GlacierEventDataEntity.html) [S3EventNotification.IntelligentTieringEventDataEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.IntelligentTieringEventDataEntity.html) [S3EventNotification.LifecycleEventDataEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.LifecycleEventDataEntity.html) [S3EventNotification.ReplicationEventDataEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.ReplicationEventDataEntity.html) [S3EventNotification.RequestParametersEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.RequestParametersEntity.html) [S3EventNotification.ResponseElementsEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.ResponseElementsEntity.html) [S3EventNotification.RestoreEventDataEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.RestoreEventDataEntity.html) [S3EventNotification.S3BucketEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.S3BucketEntity.html) [S3EventNotification.S3Entity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.S3Entity.html) [S3EventNotification.S3ObjectEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.S3ObjectEntity.html) [S3EventNotification.TransitionEventDataEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.TransitionEventDataEntity.html) [S3EventNotification.UserIdentityEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.UserIdentityEntity.html) | [S3EventNotification](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/S3EventNotification.html) [S3EventNotificationRecord](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/S3EventNotificationRecord.html) [GlacierEventData](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/GlacierEventData.html) [IntelligentTieringEventData](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/IntelligentTieringEventData.html) [LifecycleEventData](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/LifecycleEventData.html) [ReplicationEventData](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/ReplicationEventData.html) [RequestParameters](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/RequestParameters.html) [ResponseElements](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/ResponseElements.html) [RestoreEventData](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/RestoreEventData.html) [S3Bucket](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/S3Bucket.html) [S3](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/S3.html) [S3Object](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/S3Object.html) [TransitionEventData](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/TransitionEventData.html) [UserIdentity](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/eventnotifications/s3/model/UserIdentity.html) |
1 [최신 버전](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API 변경 사항
### `S3EventNotification`에 대한 JSON 및 역방향
| 사용 사례: | v1 | v2 |
| --- | --- | --- |
| JSON 문자열에서 S3EventNotification 만들기 | S3EventNotification notification =
S3EventNotification.parseJson(message.body());
| S3EventNotification notification =
S3EventNotification.fromJson(message.body());
|
| JSON 문자열로 S3EventNotification 변환 | String json = notification.toJson();
| String json = notification.toJson();
|
### `S3EventNotification`의 액세스 속성
| 사용 사례: | v1 | v2 |
| --- | --- | --- |
| 알림에서 레코드 검색 | List records =
notifcation.getRecords();
| List records =
notification.getRecords();
|
| 레코드 목록에서 레코드 검색 | S3EventNotification.S3EventNotificationRecord record =
records.stream().findAny().get();
| S3EventNotificationRecord record =
records.stream().findAny().get();
|
| Glacier 이벤트 데이터 검색 | S3EventNotification.GlacierEventDataEntity glacierEventData =
record.getGlacierEventData();
| GlacierEventData glacierEventData =
record.getGlacierEventData();
|
| Glacier 이벤트에서 복원 이벤트 데이터 검색 | S3EventNotification.RestoreEventDataEntity restoreEventData =
glacierEventData.getRestoreEventDataEntity();
| RestoreEventData restoreEventData =
glacierEventData.getRestoreEventData();
|
| 요청 파라미터 검색 | S3EventNotification.RequestParametersEntity requestParameters =
record.getRequestParameters();
| RequestParameters requestParameters =
record.getRequestParameters();
|
| 지능형 계층화 이벤트 데이터 검색 | S3EventNotification.IntelligentTieringEventDataEntity tieringEventData =
record.getIntelligentTieringEventData();
| IntelligentTieringEventData intelligentTieringEventData =
record.getIntelligentTieringEventData();
|
| 수명 주기 이벤트 데이터 검색 | S3EventNotification.LifecycleEventDataEntity lifecycleEventData =
record.getLifecycleEventData();
| LifecycleEventData lifecycleEventData =
record.getLifecycleEventData();
|
| 이벤트 이름을 열거형으로 검색 | S3Event eventNameAsEnum = record.getEventNameAsEnum();
| //getEventNameAsEnum does not exist; use 'getEventName()'
String eventName = record.getEventName();
|
| 복제 이벤트 데이터 검색 | S3EventNotification.ReplicationEventDataEntity replicationEntity =
record.getReplicationEventDataEntity();
| ReplicationEventData replicationEventData =
record.getReplicationEventData();
|
| S3 버킷 및 객체 정보 검색 | S3EventNotification.S3Entity s3 = record.getS3();
| S3 s3 = record.getS3();
|
| 사용자 자격 증명 정보 검색 | S3EventNotification.UserIdentityEntity userIdentity =
record.getUserIdentity();
| UserIdentity userIdentity =
record.getUserIdentity();
|
| 응답 요소 검색 | S3EventNotification.ResponseElementsEntity responseElements =
record.getResponseElements();
| ResponseElements responseElements =
record.getResponseElements();
|
## `aws-lambda-java-events` 라이브러리 버전 마이그레이션
[aws-lambda-java-events](https://github.com/aws/aws-lambda-java-libs/tree/main/aws-lambda-java-events)를 사용하여 Lambda 함수 내에서 S3 알림 이벤트를 사용하는 경우 최신 3.x.x 버전으로 업그레이드하는 것이 좋습니다. 최신 버전은 S3 이벤트 알림 API에서 AWS SDK for Java 1.x의 모든 종속성을 제거합니다.
`aws-lambda-java-events` 라이브러리와 SDK for Java 2.x 간의 S3 이벤트 알림 처리 차이점에 대한 자세한 내용은 [Java 라이브러리를 사용하여 Lambda에서 S3 이벤트 처리: AWS SDK for Java 2.x 및 `aws-lambda-java-events`](examples-s3-event-notifications.md#s3-event-notif-processing-options) 섹션을 참조하세요.
# 프로필 파일 변경 사항
AWS SDK for Java 2.x는 `~/.aws/config` 및 `~/.aws/credentials`에서 프로필 정의를 구문 분석하여 AWS CLI가 파일을 구문 분석하는 방법을 더 자세히 에뮬레이션합니다.
SDK for Java 2.x:
+ `$HOME`, `$USERPROFILE`(Windows만 해당), `$HOMEDRIVE`, `$HOMEPATH`(Windows만 해당) 및 `user.home` 시스템 속성을 순서대로 확인하여 경로 시작 시 파일 시스템의 기본 경로 구분자가 뒤따르는 `~/` 또는 `~` 코드를 해결합니다.
+ `AWS_CREDENTIAL_PROFILES_FILE` 대신 `AWS_SHARED_CREDENTIALS_FILE` 환경 변수를 찾습니다.
+ 프로필 이름의 시작 부분에 `profile` 단어 없이 구성 파일의 프로필 정의를 자동으로 삭제합니다.
+ 영숫자, 밑줄 또는 대시 문자로 구성되지 않은 프로필 정의를 자동으로 삭제합니다(구성 파일에 대해 선행 `profile` 단어를 제거한 후).
+ 동일한 파일 내에 복제된 프로필 정의의 설정을 병합합니다.
+ 구성 파일과 자격 증명 파일 모두에 중복된 프로필 정의의 설정을 병합합니다.
+ 동일한 파일에서 `[profile foo]` 및 `[foo]`가 모두 발견되면 설정을 병합하지 않습니다.
+ 구성 파일에서 `[profile foo]` 및 `[foo]`를 모두 찾을 경우 `[profile foo]`의 설정을 사용합니다.
+ 동일한 파일 및 프로필에서 마지막으로 복제된 설정의 값을 사용합니다.
+ 주석을 정의하기 위해 `;` 및 `#` 기호를 모두 인식합니다.
+ 문자가 닫는 대괄호 옆에 있더라도 프로필 정의에서 `;` 및 `#` 기호를 인식하여 주석을 정의합니다.
+ 설정 값 앞에 공백이 있는 경우에만 주석을 정의하기 위해 `;` 및 `#` 기호를 인식합니다.
+ 앞에 공백이 없는 경우 설정 값에서 `;` 및 `#`, 다음 모든 콘텐츠를 인식합니다.
+ 역할 기반 자격 증명을 우선순위가 가장 높은 자격 증명으로 간주합니다. 사용자가 `role_arn` 속성을 지정하는 경우 2.x SDK는 항상 역할 기반 자격 증명을 사용합니다.
+ 세션 기반 자격 증명을 차순위 자격 증명으로 간주합니다. 역할 기반 자격 증명을 사용하지 않고 사용자가 `aws_access_key_id` 및 `aws_session_token` 속성을 지정하는 경우 2.x SDK는 항상 세션 기반 자격 증명을 사용합니다.
+ 역할 기반 및 세션 기반 자격 증명을 사용하지 않고 사용자가 `aws_access_key_id` 속성을 지정한 경우 기본 자격 증명을 사용합니다.
# 환경 변수 및 시스템 속성 변경
| 1.x 환경 변수 | 1.x 시스템 속성 | 2.x 환경 변수 | 2.x 시스템 속성 |
| --- | --- | --- | --- |
| AWS\$1ACCESS\$1KEY\$1IDAWS\$1ACCESS\$1KEY | aws.accessKeyId | AWS\$1ACCESS\$1KEY\$1ID | aws.accessKeyId |
| AWS\$1SECRET\$1KEYAWS\$1SECRET\$1ACCESS\$1KEY | aws.secretKey | AWS\$1SECRET\$1ACCESS\$1KEY | aws.secretAccessKey |
| AWS\$1SESSION\$1TOKEN | aws.sessionToken | AWS\$1SESSION\$1TOKEN | aws.sessionToken |
| AWS\$1REGION | aws.region | AWS\$1REGION | aws.region |
| AWS\$1CONFIG\$1FILE | | AWS\$1CONFIG\$1FILE | aws.configFile |
| AWS\$1CREDENTIAL\$1PROFILES\$1FILE | | AWS\$1SHARED\$1CREDENTIALS\$1FILE | aws.sharedCredentialsFile |
| AWS\$1PROFILE | aws.profile | AWS\$1PROFILE | aws.profile |
| AWS\$1EC2\$1METADATA\$1DISABLED | com.amazonaws.sdk.disableEc2Metadata | AWS\$1EC2\$1METADATA\$1DISABLED | aws.disableEc2Metadata |
| | com.amazonaws.sdk.ec2MetadataServiceEndpointOverride | AWS\$1EC2\$1METADATA\$1SERVICE\$1ENDPOINT | aws.ec2MetadataServiceEndpoint |
| AWS\$1CONTAINER\$1CREDENTIALS\$1RELATIVE\$1URI | | AWS\$1CONTAINER\$1CREDENTIALS\$1RELATIVE\$1URI | aws.containerCredentialsPath |
| AWS\$1CONTAINER\$1CREDENTIALS\$1FULL\$1URI | | AWS\$1CONTAINER\$1CREDENTIALS\$1FULL\$1URI | aws.containerCredentialsFullUri |
| AWS\$1CONTAINER\$1AUTHORIZATION\$1TOKEN | | AWS\$1CONTAINER\$1AUTHORIZATION\$1TOKEN | aws.containerAuthorizationToken |
| AWS\$1CBOR\$1DISABLED | com.amazonaws.sdk.disableCbor | CBOR\$1ENABLED | aws.cborEnabled |
| AWS\$1ION\$1BINARY\$1DISABLE | com.amazonaws.sdk.disableIonBinary | BINARY\$1ION\$1ENABLED | aws.binaryIonEnabled |
| AWS\$1EXECUTION\$1ENV | | AWS\$1EXECUTION\$1ENV | aws.executionEnvironment |
| | com.amazonaws.sdk.disableCertChecking | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
| | com.amazonaws.sdk.enableDefaultMetrics | [지원되지 않음](https://github.com/aws/aws-sdk-java-v2/issues/23) | [지원되지 않음](https://github.com/aws/aws-sdk-java-v2/issues/23) |
| | com.amazonaws.sdk.enableThrottledRetry | [지원되지 않음](https://github.com/aws/aws-sdk-java-v2/issues/645) | [지원되지 않음](https://github.com/aws/aws-sdk-java-v2/issues/645) |
| | com.amazonaws.regions.RegionUtils.fileOverride | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
| | com.amazonaws.regions.RegionUtils.disableRemote | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
| | com.amazonaws.services.s3.disableImplicitGlobalClients | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
| | com.amazonaws.sdk.enableInRegionOptimizedMode | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) | 비지원([요청 기능](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
# 웨이터를 버전 1에서 버전 2로 변경
이 주제에서는 버전 1(v1)에서 버전 2(v2)로 변환 시 웨이터 기능의 변경 사항을 자세히 설명합니다.
다음 표에서는 DynamoDB 웨이터의 차이점을 구체적으로 보여줍니다. 다른 서비스의 웨이터는 동일한 패턴을 따릅니다.
## 높은 수준의 변경 사항
웨이터 클래스는 서비스와 동일한 Maven 아티팩트에 있습니다.
| 변경 사항 | v1 | v2 |
| --- | --- | --- |
| Maven 종속성 |
com.amazonaws
aws-java-sdk-bom
1.12.6801
pom
import
com.amazonaws
dynamodb
|
software.amazon.awssdk
bom
2.27.102
pom
import
software.amazon.awssdk
dynamodb
|
| 패키지 이름 | com.amazonaws.services.dynamodbv2.waiters | software.amazon.awssdk.services.dynamodb.waiters |
| 클래스 이름 | `[AmazonDynamoDBWaiters](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/waiters/AmazonDynamoDBWaiters.html)` | [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/migration-waiters.html) |
1 [최신 버전](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [최신 버전](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API 변경 사항
| 변경 사항 | v1 | v2 |
| --- | --- | --- |
| 웨이터 만들기 | AmazonDynamoDB client = AmazonDynamoDBClientBuilder
.standard().build();
AmazonDynamoDBWaiters waiter = client.waiters();
| 동기식:DynamoDbClient client = DynamoDbClient.create();
DynamoDbWaiter waiter = client.waiter();
비동기식:DynamoDbAsyncClient asyncClient =
DynamoDbAsyncClient.create();
DynamoDbAsyncWaiter waiter = asyncClient.waiter();
|
| 테이블이 존재할 때까지 대기 | 동기식:waiter.tableExists()
.run(new WaiterParameters<>(
new DescribeTableRequest(tableName)));
비동기식:waiter.tableExists()
.runAsync(new WaiterParameters()
.withRequest(new DescribeTableRequest(tableName)),
new WaiterHandler() {
@Override
public void onWaitSuccess(
AmazonWebServiceRequest amazonWebServiceRequest) {
System.out.println("Table creation succeeded");
}
@Override
public void onWaitFailure(Exception e) {
e.printStackTrace();
}
}).get();
| 동기식: WaiterResponse waiterResponse =
waiter.waitUntilTableExists(
r -> r.tableName("myTable"));
waiterResponse.matched().response()
.ifPresent(System.out::println);
비동기식: waiter.waitUntilTableExists(r -> r.tableName(tableName))
.whenComplete((r, t) -> {
if (t != null) {
t.printStackTrace();
} else {
System.out.println(
"Table creation succeeded");
}
}).join();
|
## 구성 변경
| 변경 사항 | v1 | v2 |
| --- | --- | --- |
| 폴링 전략(최대 시도 횟수 및 고정 지연) | MaxAttemptsRetryStrategy maxAttemptsRetryStrategy =
new MaxAttemptsRetryStrategy(10);
FixedDelayStrategy fixedDelayStrategy =
new FixedDelayStrategy(3);
PollingStrategy pollingStrategy =
new PollingStrategy(maxAttemptsRetryStrategy,
fixedDelayStrategy);
waiter.tableExists().run(
new WaiterParameters<>(
new DescribeTableRequest(tableName)),
pollingStrategy);
|
FixedDelayBackoffStrategy fixedDelayBackoffStrategy =
FixedDelayBackoffStrategy
.create(Duration.ofSeconds(3));
waiter.waitUntilTableExists(r -> r.tableName(tableName),
c -> c.maxAttempts(10)
.backoffStrategy(fixedDelayBackoffStrategy));
|
# EC2 메타데이터 유틸리티가 버전 1에서 버전 2로 변경
이 항목에서는 버전 1(v1)에서 버전 2(v2)로 변경된 SDK for Java Amazon Elastic Compute Cloud(EC2) 메타데이터 유틸리티의 변경 사항에 대해 자세히 설명합니다.
## 높은 수준의 변경 사항
****
| 변경 | v1 | v2 |
| --- | --- | --- |
| Maven 종속성 |
com.amazonaws
aws-java-sdk-bom
1.12.5871
pom
import
com.amazonaws
aws-java-sdk-core
|
software.amazon.awssdk
bom
2.27.212
pom
import
software.amazon.awssdk
imds
software.amazon.awssdk
apache-client3
|
| 패키지 이름 | com.amazonaws.util | software.amazon.awssdk.imds |
| 인스턴스화 접근 방식 | 인스턴스화 없이 정적 유틸리티 메서드 사용: String localHostName =
EC2MetadataUtils.getLocalHostName();
| 정적 팩토리 메서드 사용: Ec2MetadataClient client = Ec2MetadataClient.create();
또는 빌더 접근 방식 사용: Ec2MetadataClient client = Ec2MetadataClient.builder()
.endpointMode(EndpointMode.IPV6)
.build();
|
| 클라이언트 유형 | 동기 전용 유틸리티 메서드: EC2MetadataUtils | 동기식: `Ec2MetadataClient` 비동기식: `Ec2MetadataAsyncClient` |
1 [최신 버전](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [최신 버전](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
3v2에 대한 `apache-client` 모듈 선언에 주목합니다. EC2 메타데이터 유틸리티 V2를 사용하려면 동기식 메타데이터 클라이언트의 경우 `SdkHttpClient` 인터페이스를 구현해야 하고, 비동기식 메타데이터 클라이언트의 경우 `SdkAsyncHttpClient` 인터페이스를 구현해야 합니다. [에서 HTTP 클라이언트 구성 AWS SDK for Java 2.x](http-configuration.md) 섹션에는 사용할 수 있는 HTTP 클라이언트 목록이 표시됩니다.
### 메타데이터 요청
v1에서는 파라미터를 허용하지 않는 정적 메서드를 사용하여 EC2 리소스에 대한 메타데이터를 요청합니다. 이와는 대조적으로 v2에서는 EC2 리소스의 경로를 파라미터로 지정해야 합니다. 다음 표는 서로 다른 접근 방식을 보여줍니다.
****
| v1 | v2 |
| --- | --- |
| String userMetaData = EC2MetadataUtils.getUserData();
| Ec2MetadataClient client = Ec2MetadataClient.create();
Ec2MetadataResponse response =
client.get("/latest/user-data");
String userMetaData =
response.asString();
|
[인스턴스 메타데이터 범주](https://docs.aws.amazon.com//AWSEC2/latest/UserGuide/instancedata-data-categories.html)를 참조하여 메타데이터를 요청하기 위해 제공해야 하는 경로를 찾으세요.
**참고**
v2에서 인스턴스 메타데이터 클라이언트를 사용하는 경우, 메타데이터를 검색하는 모든 요청에 동일한 클라이언트를 사용해야 합니다.
## 동작 변경 사항
### JSON 데이터
EC2에서 로컬로 실행되는 인스턴스 메타데이터 서비스(IMDS)는 일부 메타데이터를 JSON 형식의 문자열로 반환합니다. 그러한 예로 [인스턴스 ID 문서](https://docs.aws.amazon.com//AWSEC2/latest/UserGuide/instance-identity-documents.html)의 동적 메타데이터를 들 수 있습니다.
v1 API에는 인스턴스 ID 메타데이터의 각 부분에 대한 별도의 메서드가 포함되어 있는 반면, v2 API는 JSON 문자열을 직접 반환합니다. JSON 문자열로 작업하려면 [문서 API](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/core/document/package-summary.html)를 사용하여 응답을 구문 분석하고 JSON 구조를 탐색할 수 있습니다.
다음 표는 v1과 v2에서 인스턴스 ID 문서의 메타데이터를 검색하는 방법을 비교한 것입니다.
****
| 사용 사례: | v1 | v2 |
| --- | --- | --- |
| 리전 검색 | InstanceInfo instanceInfo =
EC2MetadataUtils.getInstanceInfo();
String region = instanceInfo.getRegion();
| Ec2MetadataResponse response =
client.get("/latest/dynamic/instance-identity/document");
Document instanceInfo = response.asDocument();
String region = instanceInfo.asMap().get("region").asString();
|
| 인스턴스 ID 검색 | InstanceInfo instanceInfo =
EC2MetadataUtils.getInstanceInfo();
String instanceId = instanceInfo.instanceId;
| Ec2MetadataResponse response =
client.get("/latest/dynamic/instance-identity/document");
Document instanceInfo = response.asDocument();
String instanceId = instanceInfo.asMap().get("instanceId").asString();
|
| 인스턴스 유형 검색 | InstanceInfo instanceInfo =
EC2MetadataUtils.getInstanceInfo();
String instanceType = instanceInfo.instanceType();
| Ec2MetadataResponse response =
client.get("/latest/dynamic/instance-identity/document");
Document instanceInfo = response.asDocument();
String instanceType = instanceInfo.asMap().get("instanceType").asString();
|
### 엔드포인트 해상도 차이
다음 표는 SDK가 엔드포인트를 IMDS로 확인하기 위해 확인하는 위치를 보여줍니다. 위치는 내림차순으로 나열됩니다.
****
| v1 | v2 |
| --- | --- |
| 시스템 속성: com.amazonaws.sdk.ec2MetadataServiceEndpointOverride | 클라이언트 빌더 구성 메서드: endpoint(...) |
| 환경 변수: AWS\$1EC2\$1METADATA\$1SERVICE\$1ENDPOINT | 시스템 속성: aws.ec2MetadataServiceEndpoint |
| 기본 값: http://169.254.169.254 | 구성 파일: ec2\$1metadata\$1service\$1endpoint 설정이 포함된 \$1.aws/config |
| | 확인된 endpoint-mode 관련된 값 |
| | 기본값: http://169.254.169.254 |
### v2의 엔드포인트 해상도
빌더를 사용하여 엔드포인트를 명시적으로 설정하면 해당 엔드포인트 값이 다른 모든 설정보다 우선합니다. 다음 코드가 실행될 때 `aws.ec2MetadataServiceEndpoint` 시스템 속성 및 구성 파일 `ec2_metadata_service_endpoint` 설정이 있는 경우 무시됩니다.
```
Ec2MetadataClient client = Ec2MetadataClient
.builder()
.endpoint(URI.create("endpoint.to.use"))
.build();
```
#### 엔드포인트 모드
v2에서는 엔드포인트 모드를 지정하여 IPv4 또는 IPv6의 기본 엔드포인트 값을 사용하도록 메타데이터 클라이언트를 구성할 수 있습니다. v1에는 엔드포인트 모드를 사용할 수 없습니다. IPv4에 사용되는 기본값은 `http://169.254.169.254`, IPv6의 경우 `http://[fd00:ec2::254]`입니다.
다음 표는 우선 순위가 내려가는 순서대로 엔드포인트 모드를 설정할 수 있는 다양한 방법을 보여줍니다.
****
| | | 가능한 값 |
| --- | --- | --- |
| 클라이언트 빌더 구성 메서드: endpointMode(...) | Ec2MetadataClient client = Ec2MetadataClient
.builder()
.endpointMode(EndpointMode.IPV4)
.build();
| EndpointMode.IPV4, EndpointMode.IPV6 |
| 시스템 속성 | aws.ec2MetadataServiceEndpointMode | IPv4, IPv6(대/소문자를 구분하지 않음) |
| Config 파일: \$1.aws/config | ec2\$1metadata\$1service\$1endpoint 설정 | IPv4, IPv6(대/소문자를 구분하지 않음) |
| 이전 방법으로는 지정되지 않음 | IPv4가 사용됨 | |
#### SDK가 v2에서 `endpoint` 또는 `endpoint-mode`를 확인하는 방법
1. SDK는 클라이언트 빌더의 코드에서 설정한 값을 사용하며 외부 설정은 무시합니다. 클라이언트 빌더에서 `endpoint`와 `endpointMode`가 모두 호출되면 SDK는 예외를 던지므로, 어떤 메서드를 사용하든 엔드포인트 값을 사용합니다.
1. 코드에서 값을 설정하지 않으면 SDK는 외부 구성에서 먼저 시스템 속성을 찾은 다음 구성 파일의 설정을 찾습니다.
1. SDK는 먼저 엔드포인트 값을 확인합니다. 값이 발견되면 해당 값이 사용됩니다.
1. 여전히 값을 찾지 못한 경우 SDK는 엔드포인트 모드 설정을 찾습니다.
1. 마지막으로, SDK가 외부 설정을 찾지 못하고 코드에서 메타데이터 클라이언트를 구성하지 않은 경우 SDK는 `http://169.254.169.254`의 IPv4 값을 사용합니다.
### IMDSv2
Amazon EC2는 인스턴스 메타데이터에 액세스하는 두 가지 접근 방식을 정의합니다.
+ 인스턴스 메타데이터 서비스 버전 1(IMDSv1) - 요청/응답 방식
+ 인스턴스 메타데이터 서비스 버전 2(IMDSv2) - 세션 지향 방식
다음 표는 Java SDK와 IMDS의 작동 방식을 비교한 것입니다.
****
| v1 | v2 |
| --- | --- |
| IMDSv2가 기본적으로 사용됨 | 항상 IMDSv2를 사용함 |
| 각 요청에 대해 세션 토큰을 가져오려고 시도하고 세션 토큰을 가져오지 못하면 IMDSv1으로 돌아갑니다. | 여러 요청에 재사용되는 세션 토큰을 내부 캐시에 보관합니다. |
SDK for Java 2.x는 IMDSv2만 지원하며 IMDSv1로 돌아가지 않습니다.
## 구성 차이점
다음 표에는 다양한 구성 옵션이 나와 있습니다.
****
| 구성 | v1 | v2 |
| --- | --- | --- |
| 재시도 | 구성을 사용할 수 없음 | 빌더 메서드 retryPolicy(...)를 통해 구성할 수 있습니다. |
| HTTP | 연결 시간 제한은 AWS\$1METADATA\$1SERVICE\$1TIMEOUT 환경 변수를 통해 구성할 수 있습니다. 기본값은 1초입니다. | 빌더 메서드인 httpClient(...)에 HTTP 클라이언트를 전달하여 구성할 수 있습니다. HTTP 클라이언트의 기본 연결 시간 제한은 2초입니다. |
### 예제 v2 HTTP 구성
다음 예제는 메타데이터 클라이언트를 구성하는 방법을 보여줍니다. 이 예제에서는 연결 시간 제한을 구성하고 Apache HTTP 클라이언트를 사용합니다.
```
SdkHttpClient httpClient = ApacheHttpClient.builder()
.connectionTimeout(Duration.ofSeconds(1))
.build();
Ec2MetadataClient imdsClient = Ec2MetadataClient.builder()
.httpClient(httpClient)
.build();
```
# 버전 1에서 버전 2로 Amazon CloudFront 사전 서명 변경
이 주제에서는 버전 1(v1)에서 버전 2(v2)로의 Amazon CloudFront 변경 사항에 대해 자세히 설명합니다.
## 높은 수준의 변경 사항
****
| 변경 | v1 | v2 |
| --- | --- | --- |
| Maven 종속성 |
com.amazonaws
aws-java-sdk-bom
1.12.5871
pom
import
com.amazonaws
cloudfront
|
software.amazon.awssdk
bom
2.27.212
pom
import
software.amazon.awssdk
cloudfront
|
| 패키지 이름 | com.amazonaws.services.cloudfront | software.amazon.awssdk.services.cloudfront |
| 클래스 이름 | [CloudFrontUrlSigner](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/cloudfront/CloudFrontUrlSigner.html) [CloudFrontCookieSigner](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/cloudfront/CloudFrontCookieSigner.html) | [CloudFrontUtilities](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/cloudfront/CloudFrontUtilities.html) [SignedUrl](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/cloudfront/url/SignedUrl.html) [CannedSignerRequest](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/cloudfront/model/CannedSignerRequest.html) [CustomSignerRequest](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/cloudfront/model/CustomSignerRequest.html) |
1 [최신 버전](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [최신 버전](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API 변경 사항
| 동작 | v1 | v2 |
| --- | --- | --- |
| 미리 준비된 요청 구축 | 인수는 API로 직접 전달됩니다. | CannedSignerRequest cannedRequest =
CannedSignerRequest.builder()
.resourceUrl(resourceUrl)
.privateKey(privateKey)
.keyPairId(keyPairId)
.expirationDate(expirationDate)
.build();
|
| 사용자 지정 요청 구축 | 인수는 API로 직접 전달됩니다. | CustomSignerRequest customRequest =
CustomSignerRequest.builder()
.resourceUrl(resourceUrl)
.resourceUrlPattern(resourceUrlPattern)
.privateKey(keyFile)
.keyPairId(keyPairId)
.expirationDate(expirationDate)
.activeDate(activeDate)
.ipRange(ipRange)
.build();
|
| 서명된 URL 생성(미리 준비됨) | String signedUrl =
CloudFrontUrlSigner.getSignedURLWithCannedPolicy(
resourceUrl, keyPairId, privateKey, expirationDate);
| CloudFrontUtilities cloudFrontUtilities =
CloudFrontUtilities.create();
SignedUrl signedUrl =
cloudFrontUtilities.getSignedUrlWithCannedPolicy(cannedRequest);
String url = signedUrl.url();
|
| 서명된 쿠키 생성(사용자 지정) | CookiesForCustomPolicy cookies =
CloudFrontCookieSigner.getCookiesForCustomPolicy(
resourceUrl, privateKey, keyPairId, expirationDate,
activeDate, ipRange);
| CloudFrontUtilities cloudFrontUtilities =
CloudFrontUtilities.create();
CookiesForCustomPolicy cookies =
cloudFrontUtilities.getCookiesForCustomPolicy(customRequest);
|
### v2의 리팩터링된 쿠키 헤더
Java v1에서 Java SDK는 쿠키 헤더를 `Map.Entry`으로 제공합니다.
```
Map.Entry signatureMap = cookies.getSignature();
String signatureKey = signatureMap.getKey(); // "CloudFront-Signature"
String signatureValue = signatureMap.getValue(); // "[SIGNATURE_VALUE]"
```
Java v2 SDK는 전체 헤더를 단일 `String`으로 제공합니다.
```
String signatureHeaderValue = cookies.signatureHeaderValue(); // "CloudFront-Signature=[SIGNATURE_VALUE]"
```
# IAM 정책 빌더 API를 버전 1에서 버전 2로 변경
이 주제에서는 버전 1(v1)에서 버전 2(v2)로의 IAM 정책 빌더 API의 변경 사항에 대해 자세히 설명합니다.
## 높은 수준의 변경 사항
****
| 변경 | v1 | v2 |
| --- | --- | --- |
| Maven 종속성 |
com.amazonaws
aws-java-sdk-bom
1.12.5871
pom
import
com.amazonaws
aws-java-sdk-core
|
software.amazon.awssdk
bom
2.27.212
pom
import
software.amazon.awssdk
iam-policy-builder
|
| 패키지 이름 | com.amazonaws.auth.policy | software.amazon.awssdk.policybuilder.iam |
| 클래스 이름 | [정책](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Policy.html) [Statement](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Statement.html) [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/migration-iam-policy-builder.html) | [IamPolicy](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamPolicy.html) [IamStatement](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamStatement.html) [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/migration-iam-policy-builder.html) |
1 [최신 버전](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [최신 버전](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API 변경 사항
****
| 설정 | v1 | v2 |
| --- | --- | --- |
| 정책 인스턴스화 | Policy policy = new Policy();
| IamPolicy.Builder policyBuilder = IamPolicy.builder();
...
IamPolicy policy = policyBuilder.build();
|
| 세트 ID | policy.withtId(...);
policy.setId(...);
| policyBuilder.id(...);
|
| 세트 버전 | 해당 사항 없음 - 2012-10-17의 기본 버전을 사용합니다. | policyBuilder.version(...);
|
| CREATE 문 | Statement statement =
new Statement(Effect.Allow)
.withActions(...)
.withConditions(...)
.withId(...)
.withPrincipals(...)
.withResources(...);
| IamStatement statement =
IamStatement.builder()
.effect(IamEffect.ALLOW)
.actions(...)
.notActions(...)
.conditions(...)
.sid(...)
.principals(...)
.notPrincipals(...)
.resources(...)
.notResources(...)
.build()
|
| SET 문 | policy.withStatements(statement);
policy.setStatements(statement);
| policyBuilder.addStatement(statement);
|
## 문 구축에서의 차이점
### 작업
#### v1
v1 SDK에는 정책 문의 `[https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_action.html](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_action.html)` 요소를 나타내는 서비스 작업에 대한 [`enum` 유형](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Action.html)이 포함됩니다. 다음 `enum` 유형은 몇 가지 예제입니다.
+ `[IdentityManagementActions](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/actions/IdentityManagementActions.html)`
+ `[DynamoDBv2Actions](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/actions/DynamoDBv2Actions.html)`
+ `[SQSActions](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/actions/SQSActions.html)`
다음 예제에서는 `SQSActions`에 대한 `SendMessage` 상수를 보여줍니다.
```
Action action = SQSActions.SendMessage;
```
v1의 문에 대해 `[https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notaction.html](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notaction.html)` 요소를 지정할 수 없습니다.
#### v2
v2에서 [IamAction](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamAction.html) 인터페이스는 모든 작업을 나타냅니다. [서비스별 작업](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_action.html) 요소를 지정하려면 다음 코드와 같이 문자열을 `create` 메서드에 전달합니다.
```
IamAction action = IamAction.create("sqs:SendMessage");
```
다음 코드와 같이 v2가 있는 문에 대해 `[https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notaction.html](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notaction.html)`을 지정할 수 있습니다.
```
IamAction action = IamAction.create("sqs:SendMessage");
IamStatement.builder().addNotAction(action);
```
### 조건
#### v1
문 조건을 나타내기 위해 v1 SDK는의 [https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Condition.html](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Condition.html)의 하위 클래스를 사용합니다.
+ [ArnCondition](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/conditions/ArnCondition.html)
+ [BooleanCondition](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/conditions/BooleanCondition.html)
+ [DateCondition](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/conditions/DateCondition.html)
+ [IpAddressCondition](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/conditions/IpAddressCondition.html)
+ [NumericCondition](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/conditions/NumericCondition.html)
+ [ StringCondition ](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/conditions/StringCondition.html)
각 `Condition` 하위 클래스는 조건을 정의하는 데 도움이 되는 비교 `enum` 유형을 정의합니다. 예를 들어 다음은 조건에 대한 *유사하지 않은*[ 문자열 비교](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_condition_operators.html#Conditions_String)를 보여줍니다.
```
Condition condition = new StringCondition(StringComparisonType.StringNotLike, "key", "value");
```
#### v2
v2에서는 `[IamCondition](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamCondition.html)`을 사용하여 정책 설명에 대한 조건을 구축하고 모든 유형에 대해 `enums`가 포함된`[IamConditionOperator](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamConditionOperator.html)`를 제공합니다.
```
IamCondition condition = IamCondition.create(IamConditionOperator.STRING_NOT_LIKE, "key", "value");
```
### 리소스
#### v1
정책 문의 `[https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_resource.html](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_resource.html)` 요소는 SDK의 `[Resource](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Resource.html)` 클래스로 표시됩니다. 생성자에서 ARN을 문자열로 제공합니다. 다음 하위 클래스는 편의 생성자를 제공합니다.
+ [S3BucketResource](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/resources/S3BucketResource.html)
+ [S3ObjectResource](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/resources/S3ObjectResource.html)
+ [SQSQueueResource](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/resources/SQSQueueResource.html)
v1에서는 다음 문과 같이 `withIsNotType` 메서드를 직접적으로 호출하여 `[Resource](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Resource.html)`에 대한 `[https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notresource.html](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notresource.html)` 요소를 지정할 수 있습니다.
```
Resource resource = new Resource("arn:aws:s3:::amzn-s3-demo-bucket").withIsNotType(true);
```
#### v2
v2에서는 ARN을 `IamResource.create` 메서드에 전달하여 `[https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_resource.html](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_resource.html)` 요소를 만듭니다.
```
IamResource resource = IamResource.create("arn:aws:s3:::amzn-s3-demo-bucket");
```
`[IamResource](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamResource.html)`는 다음 코드 조각과 같이 *[https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notresource.html](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notresource.html)* 요소로 설정할 수 있습니다.
```
IamResource resource = IamResource.create("arn:aws:s3:::amzn-s3-demo-bucket");
IamStatement.builder().addNotResource(resource);
```
`IamResource.ALL`은 모든 리소스를 나타냅니다.
### 보안 주체
#### v1
v1 SDK는 모든 멤버를 포함하는 보안 주체 유형을 나타내는 다음 `[Principal](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Principal.html)` 클래스를 제공합니다.
+ `AllUsers`
+ `AllServices`
+ `AllWebProviders`
+ `All`
문에 `[https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notprincipal.html](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notprincipal.html)` 요소를 추가할 수 없습니다.
#### v2
v2에서 `IamPrincipal.ALL`은 모든 보안 주체를 나타냅니다.
다른 유형의 보안 주체에 속한 모든 멤버를 나타내려면 `IamPrincipal`을 만들 때 `[IamPrincipalType](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamPrincipalType.html)` 클래스를 사용합니다.
+ 모든 사용자에 대한 `IamPrincipal.create(IamPrincipalType.AWS,"*")`입니다.
+ 모든 서비스에 대한 `IamPrincipal.create(IamPrincipalType.SERVICE,"*")`입니다.
+ 모든 웹 공급자에 대한 `IamPrincipal.create(IamPrincipalType.FEDERATED,"*")`입니다.
+ 모든 표준 사용자에 대한 `IamPrincipal.create(IamPrincipalType.CANONICAL_USER,"*")`입니다.
다음 문과 같이 정책 문을 만들 때 `addNotPrincipal` 메서드를 사용하여 `[https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notprincipal.html](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_notprincipal.html)` 요소를 나타낼 수 있습니다.
```
IamPrincipal principal = IamPrincipal.create(IamPrincipalType.AWS, "arn:aws:iam::444455556666:root");
IamStatement.builder().addNotPrincipal(principal);
```
# 의 버전 1에서 버전 2로 DynamoDB 작업 시 변경 사항 AWS SDK for Java
**Topics**
+ [의 버전 1과 버전 2 간의 DynamoDB 매핑 API 차이점 AWS SDK for Java](ddb-mapping.md)
+ [버전 1과 버전 2 간의 API 차이점 문서화 AWS SDK for Java](dynamodb-mapping-document-api.md)
+ [암호화 라이브러리 마이그레이션](ddb-encryption-lib-migrate.md)
# 의 버전 1과 버전 2 간의 DynamoDB 매핑 API 차이점 AWS SDK for Java
DynamoDB 매핑 API는 AWS SDK for Java의 버전 1과 버전 2 간에 크게 변경되었습니다. 버전 1에서는 `DynamoDBMapper`를 사용하여 Java POJO를 작업합니다. 버전 2에서는 업데이트된 메서드 이름, 향상된 스키마 정의 옵션 및 향상된 유형 안전과 함께 `DynamoDbEnhancedClient`를 사용합니다.
주요 차이점은 다음과 같습니다.
+ 새 메서드 이름(예: `load` 대신 `getItem`)
+ 명시적 테이블 스키마 만들기
+ 동기식 및 비동기식 작업 모두에 대한 기본 제공 지원
+ 비어 있는 문자열 및 구성 처리 방법 변경
이 섹션에서는 v1 `DynamoDBMapper`에서 v2 `DynamoDbEnhancedClient`로 전환하는 데 도움이 되는 매핑 API 변경 사항, 주석 차이, 구성 업데이트 및 마이그레이션 안내를 다룹니다.
**Contents**
+ [SDK for Java의 버전 1에서 버전 2로의 매핑 라이브러리에 대한 개괄적인 변경 사항](dynamodb-mapping-high-level.md)
+ [종속성 차이 가져오기](dynamodb-mapping-high-level.md#dynamodb-mapping-deps)
+ [SDK for Java 버전 1과 버전 2 간의 DynamoDB 매핑 API 변경 사항](dynamodb-mapping-api-changes.md)
+ [클라이언트 만들기](dynamodb-mapping-api-changes.md#dynamodb-mapping-api-changes-client)
+ [DynamoDB 테이블/인덱스에 대한 매핑 설정](dynamodb-mapping-api-changes.md#dynamodb-mapping-api-changes-mapping)
+ [테이블 작업](dynamodb-mapping-api-changes.md#dynamodb-mapping-api-changes-tobleops)
+ [클래스 및 속성 매핑](dynamodb-mapping-api-changes.md#dynamodb-mapping-schemas)
+ [bean 주석](dynamodb-mapping-api-changes.md#dynamodb-mapping-schemas-annos)
+ [V2 추가 주석](dynamodb-mapping-api-changes.md#dynamodb-mapping-schemas-annos-v2-addnl)
+ [구성](dynamodb-mapping-api-changes.md#dynamodb-mapping-configuration)
+ [작업별 구성](dynamodb-mapping-api-changes.md#dynamodb-mapping-configuration-per-op)
+ [조건](dynamodb-mapping-api-changes.md#dynamodb-mapping-conditionals)
+ [유형 변환](dynamodb-mapping-api-changes.md#dynamodb-mapping-type-conv)
+ [기본 변환기](dynamodb-mapping-api-changes.md#dynamodb-mapping-type-conv-defaults)
+ [속성에 대한 사용자 지정 변환기 설정](dynamodb-mapping-api-changes.md#dynamodb-mapping-type-conv-anno)
+ [유형 변환기 팩토리 또는 공급자 추가](dynamodb-mapping-api-changes.md#dynamodb-mapping-type-conv-factory)
+ [SDK for Java 버전 1과 버전 2 간의 문자열 처리 차이점](dynamodb-migration-string-handling.md)
+ [SDK for Java 버전 1과 버전 2의 낙관적 잠금 차이점](dynamodb-migrate-optimstic-locking.md)
+ [SDK for Java 버전 1과 버전 2 간의 유용한 setter 차이점](dynamodb-migrate-fluent-setters.md)
# SDK for Java의 버전 1에서 버전 2로의 매핑 라이브러리에 대한 개괄적인 변경 사항
각 라이브러리의 매핑 클라이언트 이름은 V1과 V2에서 다릅니다.
+ V1 - DynamoDBMapper
+ V2 - DynamoDB 향상된 클라이언트
두 라이브러리와 거의 동일한 방식으로 상호 작용합니다. 즉, 매퍼/클라이언트를 인스턴스화한 다음 이러한 항목을 읽고 DynamoDB 테이블에 쓰는 API에 Java POJO를 제공합니다. 또한 두 라이브러리 모두 POJO 클래스에 대한 주석을 제공하여 클라이언트가 POJO를 처리하는 방법을 지시합니다.
V2로 이전할 때 눈에 띄는 차이점은 다음과 같습니다.
+ V2와 V1은 하위 수준 DynamoDB 작업에 서로 다른 메서드 이름을 사용합니다. 예제:
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/dynamodb-mapping-high-level.html)
+ V2는 테이블 스키마를 정의하고 POJO 테이블에 매핑하는 다양한 방법을 제공합니다. 빌더를 사용하여 코드에서 생성된 스키마 또는 주석 사용 중에서 선택할 수 있습니다. 또한 V2는 변경 및 변경 불가능한 버전의 스키마를 제공합니다.
+ V2에서는 특히 첫 번째 단계 중 하나로 테이블 스키마를 만드는 반면, V1에서는 필요에 따라 주석이 달린 클래스에서 테이블 스키마를 추론합니다.
+ V2는 향상된 클라이언트 API에 [문서 API 클라이언트](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/document/EnhancedDocument.html)를 포함하는 반면, V1은 [별도의 API](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/DynamoDB.html)를 사용합니다.
+ 모든 API는 V2의 동기식 및 비동기식 버전에서 사용할 수 있습니다.
V2 향상된 클라이언트에 대한 자세한 내용은 이 가이드의 [DynamoDB 매핑 섹션](dynamodb-enhanced-client.md)을 참조하세요.
## 종속성 차이 가져오기
| V1 | V2 |
| --- | --- |
|
com.amazonaws
aws-java-sdk-bom
1.X.X
pom
import
com.amazonaws
aws-java-sdk-dynamodb
|
software.amazon.awssdk
bom
2.X.X*
pom
import
software.amazon.awssdk
dynamodb-enhanced
|
\$1 [최신 버전](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
V1에서는 단일 종속성에 하위 수준 DynamoDB API와 매핑/문서 API가 모두 포함되는 반면, V2에서는 `dynamodb-enhanced` 아티팩트 종속성을 사용하여 매핑/문서 API에 액세스합니다. `dynamodb-enhanced` 모듈에는 하위 수준 `dynamodb` 모듈에 대한 전이적 종속성이 포함되어 있습니다.
# SDK for Java 버전 1과 버전 2 간의 DynamoDB 매핑 API 변경 사항
## 클라이언트 만들기
****
| 사용 사례: | V1 | V2 |
| --- | --- | --- |
| 일반 인스턴스화 | AmazonDynamoDB standardClient = AmazonDynamoDBClientBuilder.standard()
.withCredentials(credentialsProvider)
.withRegion(Regions.US_EAST_1)
.build();
DynamoDBMapper mapper = new DynamoDBMapper(standardClient);
| DynamoDbClient standardClient = DynamoDbClient.builder()
.credentialsProvider(ProfileCredentialsProvider.create())
.region(Region.US_EAST_1)
.build();
DynamoDbEnhancedClient enhancedClient = DynamoDbEnhancedClient.builder()
.dynamoDbClient(standardClient)
.build();
|
| 최소 인스턴스화 | AmazonDynamoDB standardClient = AmazonDynamoDBClientBuilder.standard();
DynamoDBMapper mapper = new DynamoDBMapper(standardClient);
| DynamoDbEnhancedClient enhancedClient = DynamoDbEnhancedClient.create();
|
| 속성 변환기 사용\$1 | DynamoDBMapper mapper = new DynamoDBMapper(standardClient,
attributeTransformerInstance);
| DynamoDbEnhancedClient enhancedClient = DynamoDbEnhancedClient.builder()
.dynamoDbClient(standardClient)
.extensions(extensionAInstance, extensionBInstance)
.build();
|
\$1V2의 확장은 대략 V1의 속성 변환기에 해당합니다. 이 [확장 프로그램을 사용하여 DynamoDB 향상된 클라이언트 작업 사용자 지정](ddb-en-client-extensions.md) 섹션에는 V2의 확장에 대한 자세한 내용이 포함되어 있습니다.
## DynamoDB 테이블/인덱스에 대한 매핑 설정
V1에서는 bean 주석을 통해 DynamoDB 테이블 이름을 지정합니다. V2에서는 팩토리 메서드인 `table()`이 원격 DynamoDB 테이블을 나타내는 `DynamoDbTable`의 인스턴스를 생성합니다. `table()` 메서드의 첫 번째 파라미터는 DynamoDB 테이블 이름입니다.
****
| 사용 사례: | V1 | V2 |
| --- | --- | --- |
| Java POJO 클래스를 DynamoDB 테이블에 매핑 | @DynamoDBTable(tableName ="Customer")
public class Customer {
...
}
| DynamoDbTable customerTable = enhancedClient.table("Customer",
TableSchema.fromBean(Customer.class));
|
| DynamoDB 보조 인덱스에 매핑 | [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/dynamodb-mapping-api-changes.html) [ V1 `query` 메서드](https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/DynamoDBMapper.Methods.html#DynamoDBMapper.Methods.query)에 대해 설명하는 DynamoDB 개발자 안내서의 섹션에는 전체 예제가 나와 있습니다. | [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/dynamodb-mapping-api-changes.html) 이 안내서의 [보조 인덱스 사용](ddb-en-client-use-secindex.md) 섹션에서는 자세한 내용을 제공합니다. |
## 테이블 작업
이 섹션에서는 작업 API를 설명하며, 이는 대부분의 표준 사용 사례에 대한 V1과 V2 간의 차이점이 포함됩니다.
V2에서는 단일 테이블과 관련된 모든 작업이 향상된 클라이언트가 아닌 `DynamoDbTable` 인스턴스에서 직접적으로 호출됩니다. 향상된 클라이언트에는 여러 테이블을 대상으로 지정할 수 있는 메서드가 포함되어 있습니다.
아래 *테이블 작업*이라는 테이블에서 POJO 인스턴스를 `item` 또는 `customer1` 등의 특정 유형이라고 합니다. V2 예제의 경우 이름이 `table`인 인스턴스는 `DynamoDbTable` 인스턴스에 대한 참조를 반환하는 `enhancedClient.table()`을 이전에 직접적으로 호출한 결과입니다.
대부분의 V2 작업은 표시되지 않은 경우에도 유용한 소비자 패턴으로 직접 호출할 수 있습니다. 예:
```
Customer customer = table.getItem(r → r.key(key));
or
Customer customer = table.getItem(r → r.key(k -> k.partitionValue("id").sortValue("email")))
```
V1 작업의 경우 *테이블 작업*(아래)에는 모든 오버로드된 양식이 아닌 일반적으로 사용되는 양식 중 일부가 포함됩니다. 예를 들어 `load()` 메서드에는 다음과 같은 오버로드가 있습니다.
```
mapper.load(Customer.class, hashKey)
mapper.load(Customer.class, hashKey, rangeKey)
mapper.load(Customer.class, hashKey, config)
mapper.load(Customer.class, hashKey, rangeKey, config)
mapper.load(item)
mapper.load(item, config)
```
*테이블 작업*(아래)은 일반적으로 사용되는 양식을 보여줍니다.
```
mapper.load(item)
mapper.load(item, config)
```
**테이블 작업**
| 사용 사례: | V1 | V2 |
| --- | --- | --- |
| DynamoDB 테이블에 Java POJO 쓰기 **DynamoDB 작업:** `PutItem`, `UpdateItem` | mapper.save(item)
mapper.save(item, config)
mapper.save(item, saveExpression, config)
V1에서 `DynamoDBMapperConfig.SaveBehavior` 및 주석은 직접적으로 호출할 하위 수준 DynamoDB 메서드를 결정합니다. 일반적으로 `UpdateItem`은 `SaveBehavior.CLOBBER` 및 `SaveBehavior.PUT` 코드를 사용할 때를 제외하고 직접적으로 호출됩니다. 자동 생성된 키는 특별한 사용 사례이며 경우에 따라 `PutItem` 및 `UpdateItem`이 모두 사용됩니다. | table.putItem(putItemRequest)
table.putItem(item)
table.putItemWithResponse(item) //Returns metadata.
updateItem(updateItemRequest)
table.updateItem(item)
table.updateItemWithResponse(item) //Returns metadata.
|
| DynamoDB 테이블에서 Java POJO로의 항목 읽기 **DynamoDB 작업:** `GetItem` | mapper.load(item)
mapper.load(item, config)
| table.getItem(getItemRequest)
table.getItem(item)
table.getItem(key)
table.getItemWithResponse(key) //Returns POJO with metadata.
|
| DynamoDB 테이블에서 항목 삭제 **DynamoDB 작업:** `DeleteItem` | mapper.delete(item, deleteExpression, config)
| table.deleteItem(deleteItemRequest)
table.deleteItem(item)
table.deleteItem(key)
|
| DynamoDB 테이블 또는 보조 인덱스 쿼리 및 페이지 매김 목록 반환 **DynamoDB 작업:** `Query` | mapper.query(Customer.class, queryExpression)
mapper.query(Customer.class, queryExpression,
mapperConfig)
| table.query(queryRequest)
table.query(queryConditional)
동기식 응답에서 반환된 `PageIterable.stream()`(지연 로딩) 및 비동기식 응답에서 반환된 `PagePublisher.subscribe()` 사용 |
| DynamoDB 테이블 또는 보조 인덱스 쿼리 및 목록 반환 **DynamoDB 작업:** `Query` | mapper.queryPage(Customer.class, queryExpression)
mapper.queryPage(Customer.class, queryExpression,
mapperConfig)
| table.query(queryRequest)
table.query(queryConditional)
동기식 응답에서 반환된 `PageIterable.items()`(지연 로딩) 및 비동기식 응답에서 반환된 `PagePublisher.items.subscribe()` 사용 |
| DynamoDB 테이블 또는 보조 인덱스 스캔 및 페이지 매김 목록 반환 **DynamoDB 작업:** `Scan` | mapper.scan(Customer.class, scanExpression)
mapper.scan(Customer.class, scanExpression,
mapperConfig)
| table.scan()
table.scan(scanRequest)
동기식 응답에서 반환된 `PageIterable.stream()`(지연 로딩) 및 비동기식 응답에서 반환된 `PagePublisher.subscribe()` 사용 |
| DynamoDB 테이블 또는 보조 인덱스 스캔 및 목록 반환 **DynamoDB 작업:** `Scan` | mapper.scanPage(Customer.class, scanExpression)
mapper.scanPage(Customer.class, scanExpression,
mapperConfig)
| table.scan()
table.scan(scanRequest)
동기식 응답에서 반환된 `PageIterable.items()`(지연 로딩) 및 비동기식 응답에서 반환된 `PagePublisher.items.subscribe()` 사용 |
| 배치의 여러 테이블에서 여러 항목 읽기 **DynamoDB 작업:** `BatchGetItem` | mapper.batchLoad(Arrays.asList(customer1,
customer2,
book1))
mapper.batchLoad(itemsToGet)
// itemsToGet: Map, List>
| enhancedClient.batchGetItem(batchGetItemRequest)
enhancedClient.batchGetItem(r -> r.readBatches(
ReadBatch.builder(Record1.class)
.mappedTableResource(mappedTable1)
.addGetItem(i -> i.key(k -> k.partitionValue(0)))
.build(),
ReadBatch.builder(Record2.class)
.mappedTableResource(mappedTable2)
.addGetItem(i -> i.key(k -> k.partitionValue(0)))
.build()))
// Iterate over pages with lazy loading or over all items
from the same table.
|
| 배치의 여러 테이블에 여러 항목 쓰기 **DynamoDB 작업:** `BatchWriteItem` | mapper.batchSave(Arrays.asList(customer1,
customer2,
book1))
| enhancedClient.batchWriteItem(batchWriteItemRequest)
enhancedClient.batchWriteItem(r -> r.writeBatches(
WriteBatch.builder(Record1.class)
.mappedTableResource(mappedTable1)
.addPutItem(item1)
.build(),
WriteBatch.builder(Record2.class)
.mappedTableResource(mappedTable2)
.addPutItem(item2)
.build()))
|
| 배치의 여러 테이블에서 여러 항목 삭제 **DynamoDB 작업:** `BatchWriteItem` | mapper.batchDelete(Arrays.asList(customer1,
customer2,
book1))
| enhancedClient.batchWriteItem(r -> r.writeBatches(
WriteBatch.builder(Record1.class)
.mappedTableResource(mappedTable1)
.addDeleteItem(item1key)
.build(),
WriteBatch.builder(Record2.class)
.mappedTableResource(mappedTable2)
.addDeleteItem(item2key)
.build()))
|
| 배치에서 여러 항목 쓰기/삭제 **DynamoDB 작업:** `BatchWriteItem` | mapper.batchWrite(Arrays.asList(customer1, book1),
Arrays.asList(customer2))
| enhancedClient.batchWriteItem(r -> r.writeBatches(
WriteBatch.builder(Record1.class)
.mappedTableResource(mappedTable1)
.addPutItem(item1)
.build(),
WriteBatch.builder(Record2.class)
.mappedTableResource(mappedTable2)
.addDeleteItem(item2key)
.build()))
|
| 트랜잭션 쓰기 수행 **DynamoDB 작업:** `TransactWriteItems` | mapper.transactionWrite(transactionWriteRequest)
| enhancedClient.transactWriteItems(transasctWriteItemsRequest)
|
| 트랜잭션 읽기 수행 **DynamoDB 작업:** `TransactGetItems` | mapper.transactionLoad(transactionLoadRequest)
| enhancedClient.transactGetItems(transactGetItemsRequest)
|
| 쿼리의 일치하는 항목 수 가져오기 **DynamoDB 작업:** `Select.COUNT`로 `Query` | mapper.count(Customer.class, queryExpression)
| // Get the count from query results.
PageIterable pageIterable =
customerTable.query(QueryEnhancedRequest.builder()
.queryConditional(queryConditional)
.select(Select.COUNT)
.build());
Iterator> iterator = pageIterable.iterator();
Page page = iterator.next();
int count = page.count();
// For a more concise approach, you can chain the method calls:
int count = customerTable.query(QueryEnhancedRequest.builder()
.queryConditional(queryConditional)
.select(Select.COUNT)
.build())
.iterator().next().count();
|
| 스캔의 일치하는 항목 수 가져오기 **DynamoDB 작업:** `Select.COUNT`로 `Scan` | mapper.count(Customer.class, scanExpression)
| // Get the count from scan results.
PageIterable pageIterable =
customerTable.scan(ScanEnhancedRequest.builder()
.filterExpression(filterExpression)
.select(Select.COUNT)
.build());
Iterator> iterator = pageIterable.iterator();
Page page = iterator.next();
int count = page.count();
// For a more concise approach, you can chain the method calls:
int count = customerTable.scan(ScanEnhancedRequest.builder()
.filterExpression(filterExpression)
.select(Select.COUNT)
.build())
.iterator().next().count();
|
| DynamoDB에서 POJO 클래스에 해당하는 테이블 만들기 **DynamoDB 작업:** `CreateTable` | mapper.generateCreateTableRequest(Customer.class)
이전 문은 하위 수준 테이블 만들기 요청을 생성합니다. 사용자는 DynamoDB 클라이언트에서 `createTable`을 직접적으로 호출해야 합니다. | table.createTable(createTableRequest)
table.createTable(r -> r.provisionedThroughput(defaultThroughput())
.globalSecondaryIndices(
EnhancedGlobalSecondaryIndex.builder()
.indexName("gsi_1")
.projection(p -> p.projectionType(ProjectionType.ALL))
.provisionedThroughput(defaultThroughput())
.build()));
|
| DynamoDB에서 병렬 스캔 수행 **DynamoDB 작업:** `Segment` 및 `TotalSegments` 파라미터로 `Scan` | mapper.parallelScan(Customer.class,
scanExpression,
numTotalSegments)
| 사용자는 작업자 스레드를 처리하고 각 세그먼트에 대해 `scan`을 직접적으로 호출해야 합니다. table.scan(r -> r.segment(0).totalSegments(5))
|
| Amazon S3를 DynamoDB와 통합하여 지능형 S3 링크 저장 | mapper.createS3Link(bucket, key)
mapper.getS3ClientCache()
| Amazon S3와 DynamoDB를 통합하므로 지원되지 않습니다. |
## 클래스 및 속성 매핑
V1과 V2 모두에서 bean 스타일 주석을 사용하여 클래스를 테이블에 매핑합니다. V2는 변경 불가능한 클래스 작업 등 특정 사용 사례에 대한 [스키마를 정의하는 다른 방법](ddb-en-client-adv-features.md#ddb-en-client-adv-features-schm-overview)도 제공합니다.
### bean 주석
다음 테이블에는 V1 및 V2에 사용되는 특정 사용 사례별로 동등한 bean 주석이 나와 있습니다. `Customer` 클래스 시나리오는 파라미터를 설명하는 데 사용됩니다.
V2의 주석, 클래스, 열거는 Camel 대문자 규칙을 따르고 ‘DynamoDB’가 아닌 ‘DynamoDb’를 사용합니다.
| 사용 사례: | V1 | V2 |
| --- | --- | --- |
| 클래스를 테이블에 매핑 | @DynamoDBTable (tableName ="CustomerTable")
| @DynamoDbBean
@DynamoDbBean(converterProviders = {...})
테이블 이름은 DynamoDbEnhancedClient\$1table() 메서드를 직접적으로 호출할 때 정의됩니다. |
| 클래스 멤버를 테이블 속성으로 지정 | @DynamoDBAttribute(attributeName = "customerName")
| @DynamoDbAttribute("customerName") |
| 클래스 멤버를 해시/파티션 키로 지정 | @DynamoDBHashKey
| @DynamoDbPartitionKey
|
| 클래스 멤버를 범위/정렬 키로 지정 | @DynamoDBRangeKey
| @DynamoDbSortKey
|
| 클래스 멤버를 보조 인덱스 해시/파티션 키로 지정 | @DynamoDBIndexHashKey
| @DynamoDbSecondaryPartitionKey
|
| 클래스 멤버를 보조 인덱스 범위/정렬 키로 지정 | @DynamoDBIndexRangeKey
| @DynamoDbSecondarySortKey
|
| 테이블에 매핑할 때 이 클래스 멤버 무시 | @DynamoDBIgnore
| @DynamoDbIgnore
|
| 클래스 멤버를 자동 생성된 UUID 키 속성으로 지정 | @DynamoDBAutoGeneratedKey
| @DynamoDbAutoGeneratedUuid
이를 제공하는 확장 프로그램은 기본적으로 로드되지 않으므로 클라이언트 빌더에 확장 프로그램을 추가해야 합니다. |
| 클래스 멤버를 자동 생성된 타임스탬프 속성으로 지정 | @DynamoDBAutoGeneratedTimestamp
| @DynamoDbAutoGeneratedTimestampAttribute
이를 제공하는 확장 프로그램은 기본적으로 로드되지 않으므로 클라이언트 빌더에 확장 프로그램을 추가해야 합니다. |
| 클래스 멤버를 자동 증분 버전 속성으로 지정 | @DynamoDBVersionAttribute
| @DynamoDbVersionAttribute
이를 제공하는 확장 프로그램은 자동으로 로드됩니다. |
| 클래스 멤버를 사용자 지정 변환이 필요한 것으로 지정 | @DynamoDBTypeConverted
| @DynamoDbConvertedBy
|
| 다른 속성 유형으로 저장할 클래스 멤버 지정 | @DynamoDBTyped()
| `AttributeConverter` 구현을 사용합니다. V2는 일반적인 Java 유형을 위한 많은 기본 제공 변환기를 지원합니다. 자체 사용자 지정 `AttributeConverter` 또는 `AttributeConverterProvider`를 구현할 수도 있습니다. 이 설명서의 [제어 속성 변환](ddb-en-client-adv-features-conversion.md) 섹션을 참조하세요. |
| DynamoDB 문서(JSON 형식 문서) 또는 하위 문서로 직렬화할 수 있는 클래스 지정 | @DynamoDBDocument
| 향상된 문서 API 사용 다음 리소스를 참조하세요.[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/dynamodb-mapping-api-changes.html) |
### V2 추가 주석
| 사용 사례: | V1 | V2 |
| --- | --- | --- |
| Java 값이 null인 경우 클래스 멤버를 null 속성으로 저장하지 않도록 지정 | 해당 사항 없음 | @DynamoDbIgnoreNulls
|
| 모든 속성이 null인 경우 클래스 멤버를 비어 있는 객체로 지정 | 해당 사항 없음 | @DynamoDbPreserveEmptyObject
|
| 클래스 멤버에 대한 특별 업데이트 작업 지정 | 해당 사항 없음 | @DynamoDbUpdateBehavior
|
| 변경할 수 없는 클래스 지정 | 해당 사항 없음 | @DynamoDbImmutable
|
| 클래스 멤버를 자동 증분 카운터 속성으로 지정 | 해당 사항 없음 | @DynamoDbAtomicCounter
이 기능을 제공하는 확장 프로그램은 자동으로 로드됩니다. |
## 구성
V1에서는 일반적으로 `DynamoDBMapperConfig`의 인스턴스를 사용하여 특정 동작을 제어합니다. 매퍼를 만들거나 요청할 때 구성 객체를 제공할 수 있습니다. V2에서 구성은 작업에 대한 요청 객체에 따라 다릅니다.
| 사용 사례: | V1 | V1의 기본값 | V2 |
| --- | --- | --- | --- |
| | DynamoDBMapperConfig.builder()
| | |
| 배치 로드/쓰기 재시도 전략 | .withBatchLoadRetryStrategy(loadRetryStrategy)
.withBatchWriteRetryStrategy(writeRetryStrategy)
| 실패한 항목 재시도 | 기본 DynamoDBClient에서 재시도 전략을 구성합니다. 이 설명서의 [에서 재시도 동작 구성 AWS SDK for Java 2.x](retry-strategy.md) 섹션을 참조하세요. |
| 일관된 읽기 | .withConsistentReads(CONSISTENT)
| EVENTUAL | 기본적으로 일관된 읽기는 읽기 작업에 대해 false입니다. 요청 객체에서 .consistentRead(true)로 재정의합니다. |
| 마샬러/언마샬러 세트가 포함된 변환 스키마 | .withConversionSchema(conversionSchema)
정적 구현에서는 구버전과 이전 버전과의 호환성을 제공합니다. | V2\$1COMPATIBLE | 해당 사항 없음. 이는 DynamoDB(V1)의 최신 버전이 데이터 형식을 저장한 방식을 나타내는 레거시 기능이며, 이 동작은 향상된 클라이언트에서 유지되지 않습니다. DynamoDB V1의 동작 예제는 부울을 부울 대신 숫자로 저장합니다. |
| 테이블 이름 | .withObjectTableNameResolver()
.withTableNameOverride()
.withTableNameResolver()
정적 구현에서 구버전과 이전 버전과의 호환성 제공 | 클래스에서 주석 또는 추측 사용 | 테이블 이름은 `DynamoDbEnhancedClient#table()` 메서드를 직접적으로 호출할 때 정의됩니다. |
| 페이지 매김 로드 전략 | .withPaginationLoadingStrategy(strategy)
옵션은 LAZY\$1`LOADING`, `EAGER_LOADING` 또는 `ITERATION_ONLY`입니다. | LAZY\$1LOADING | [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/dynamodb-mapping-api-changes.html) |
| 지표 수집 요청 | .withRequestMetricCollector(collector)
| null | 표준 DynamoDB 클라이언트를 구축할 때 ClientOverrideConfiguration에서 metricPublisher()를 사용합니다. |
| 동작 저장 | .withSaveBehavior(SaveBehavior.CLOBBER)
옵션은 `UPDATE`, `CLOBBER`, `PUT`, `APPEND_SET`, `UPDATE_SKIP_NULL_ATTRIBUTES`입니다. | UPDATE | V2에서는 `putItem()` 또는 `updateItem()`을 명시적으로 직접 호출합니다. `CLOBBER or PUT`: v 2의 해당 작업은 `putItem()`을 직접적으로 호출합니다. 특정 `CLOBBER` 구성은 없습니다. `UPDATE`:에 해당 `updateItem()` `UPDATE_SKIP_NULL_ATTRIBUTES`:에 해당합니다`updateItem()`. 요청 설정 `ignoreNulls` 및 주석/태그 `DynamoDbUpdateBehavior`를 사용하여 업데이트 동작을 제어합니다. `APPEND_SET`: 지원되지 않음: |
| 유형 변환기 팩토리 | .withTypeConverterFactory(typeConverterFactory)
| 표준 유형 변환기 | bean에 설정하는 수단 @DynamoDbBean(converterProviders = {ConverterProvider.class,
DefaultAttributeConverterProvider.class}) |
### 작업별 구성
V1에서 `query()` 등의 일부 작업은 작업에 제출된 ‘표현식’ 객체를 통해 고도로 구성할 수 있습니다. 예제:
```
DynamoDBQueryExpression emailBwQueryExpr = new DynamoDBQueryExpression()
.withRangeKeyCondition("Email",
new Condition()
.withComparisonOperator(ComparisonOperator.BEGINS_WITH)
.withAttributeValueList(
new AttributeValue().withS("my")));
mapper.query(Customer.class, emailBwQueryExpr);
```
V2에서는 구성 객체를 사용하는 대신 빌더를 사용하여 요청 객체에 파라미터를 설정합니다. 예제:
```
QueryEnhancedRequest emailBw = QueryEnhancedRequest.builder()
.queryConditional(QueryConditional
.sortBeginsWith(kb -> kb
.sortValue("my"))).build();
customerTable.query(emailBw);
```
## 조건
V2에서 조건부 및 필터링 표현식은 조건과 이름 및 필터 매핑을 캡슐화하는 `Expression` 객체를 사용하여 표현됩니다.
| 사용 사례: | 운영 | V1 | V2 |
| --- | --- | --- | --- |
| 예상 속성 조건 | save(), delete(), query(), scan() | new DynamoDBSaveExpression()
.withExpected(Collections.singletonMap(
"otherAttribute", new ExpectedAttributeValue(false)))
.withConditionalOperator(ConditionalOperator.AND);
| 지원 종료되며 대신 ConditionExpression을 사용합니다. |
| 조건 표현식 | delete() | deleteExpression.setConditionExpression("zipcode = :zipcode")
deleteExpression.setExpressionAttributeValues(...)
| Expression conditionExpression =
Expression.builder()
.expression("#key = :value OR #key1 = :value1")
.putExpressionName("#key", "attribute")
.putExpressionName("#key1", "attribute3")
.putExpressionValue(":value", AttributeValues.stringValue("wrong"))
.putExpressionValue(":value1", AttributeValues.stringValue("three"))
.build();
DeleteItemEnhancedRequest request = DeleteItemEnhancedRequest.builder()
.conditionExpression(conditionExpression).build();
|
| 필터 표현식 | query(), scan() | scanExpression
.withFilterExpression("#statename = :state")
.withExpressionAttributeValues(attributeValueMapBuilder.build())
.withExpressionAttributeNames(attributeNameMapBuilder.build())
| Map values = singletonMap(":key", stringValue("value"));
Expression filterExpression =
Expression.builder()
.expression("name = :key")
.expressionValues(values)
.build();
QueryEnhancedRequest request = QueryEnhancedRequest.builder()
.filterExpression(filterExpression).build();
|
| 쿼리에 대한 키 조건 표현식 | query() | queryExpression.withKeyConditionExpression()
| QueryConditional keyEqual = QueryConditional.keyEqualTo(b -> b
.partitionValue("movie01"));
QueryEnhancedRequest tableQuery = QueryEnhancedRequest.builder()
.queryConditional(keyEqual)
.build();
|
## 유형 변환
### 기본 변환기
V2에서 SDK는 모든 일반 유형에 대한 기본 변환기 세트를 제공합니다. 전반적 공급자 수준과 단일 속성 모두에서 유형 변환기를 변경할 수 있습니다. [AttributeConverter](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/AttributeConverter.html) API 참조에서 사용 가능한 변환기 목록을 확인할 수 있습니다.
### 속성에 대한 사용자 지정 변환기 설정
V1에서는 `@DynamoDBTypeConverted`로 getter 메서드에 주석을 달아 Java 속성 유형과 DynamoDB 속성 유형 간에 변환되는 클래스를 지정할 수 있습니다. 예를 들어 Java `Currency` 유형과 DynamoDB 문자열 간에 변환되는 `CurrencyFormatConverter`는 다음 코드 조각과 같이 적용할 수 있습니다.
```
@DynamoDBTypeConverted(converter = CurrencyFormatConverter.class)
public Currency getCurrency() { return currency; }
```
이전 코드 조각과 동일한 V2가 아래에 나와 있습니다.
```
@DynamoDbConvertedBy(CurrencyFormatConverter.class)
public Currency getCurrency() { return currency; }
```
**참고**
V1에서는 속성 자체, 유형 또는 사용자 정의 주석에 주석을 적용할 수 있으며, V2는 주석을 getter에만 적용할 수 있도록 지원합니다.
### 유형 변환기 팩토리 또는 공급자 추가
V1에서는 고유한 유형 변환기 세트를 제공하거나 구성에 유형 변환기 팩토리를 추가하여 관심 있는 유형을 재정의할 수 있습니다. 유형 변환기 팩토리는 `DynamoDBTypeConverterFactory`를 확장하며, 기본 세트에 대한 참조를 가져와서 확장하면 재정의가 수행됩니다. 다음은 이 작업을 수행하는 방법을 보여주는 Java 코드 조각입니다.
```
DynamoDBTypeConverterFactory typeConverterFactory =
DynamoDBTypeConverterFactory.standard().override()
.with(String.class, CustomBoolean.class, new DynamoDBTypeConverter() {
@Override
public String convert(CustomBoolean bool) {
return String.valueOf(bool.getValue());
}
@Override
public CustomBoolean unconvert(String string) {
return new CustomBoolean(Boolean.valueOf(string));
}}).build();
DynamoDBMapperConfig config =
DynamoDBMapperConfig.builder()
.withTypeConverterFactory(typeConverterFactory)
.build();
DynamoDBMapper mapperWithTypeConverterFactory = new DynamoDBMapper(dynamo, config);
```
V2는 `@DynamoDbBean` 주석을 통해 유사한 기능을 제공합니다. 단일 `AttributeConverterProvider` 또는 순서대로 정리된 `AttributeConverterProvider`의 체인을 제공할 수 있습니다. 자체 속성 변환기 공급자 체인을 제공하는 경우 기본 변환기 공급자가 재정의되고 해당 속성 변환기를 사용하려면 체인에 포함되어야 함을 참고하시기 바랍니다.
```
@DynamoDbBean(converterProviders = {
ConverterProvider1.class,
ConverterProvider2.class,
DefaultAttributeConverterProvider.class})
public class Customer {
...
}
```
이 안내서의 [속성 변환](ddb-en-client-adv-features-conversion.md#ddb-en-client-adv-features-conversion-example) 섹션에는 V2에 대한 전체 예제가 포함되어 있습니다.
# SDK for Java 버전 1과 버전 2 간의 문자열 처리 차이점
V1과 V2는 DynamoDB로 데이터를 전송할 때 비어 있는 문자열을 다르게 처리합니다.
+ **V1**: DynamoDB로 전송하기 전에 비어 있는 문자열을 null 값으로 변환합니다(속성 없음).
+ **V2**: 비어 있는 문자열을 DynamoDB에 실제 비어 있는 문자열 값으로 전송합니다.
**중요**
V2로 마이그레이션한 후 DynamoDB에 비어 있는 문자열을 저장하지 않으려면 사용자 지정 변환기를 구현해야 합니다. 사용자 지정 변환기가 없으면 V2는 비어 있는 문자열을 DynamoDB 항목에 실제 비어 있는 문자열 속성으로 저장합니다. 이는 이러한 속성을 완전히 생략하는 V1의 동작과 다릅니다.
**Example 비어 있는 문자열 속성을 null로 변환하는 V2용 사용자 지정 변환기**
```
/**
* Custom converter that maintains V1 behavior by converting empty strings to null values
* when writing to DynamoDB, ensuring compatibility with existing data. No attribute will be saved to DynamoDB.
*/
public class NullifyEmptyStringConverter implements AttributeConverter {
@Override
public AttributeValue transformFrom(String value) {
if (value == null || value.isEmpty()) {
return AttributeValue.builder().nul(true).build();
}
return AttributeValue.builder().s(value).build();
}
@Override
public String transformTo(AttributeValue attributeValue) {
if (attributeValue.nul()) {
return null;
}
return attributeValue.s();
}
@Override
public EnhancedType type() {
return EnhancedType.of(String.class);
}
@Override
public AttributeValueType attributeValueType() {
return AttributeValueType.S;
}
}
// V2 usage:
@DynamoDbBean
public class Customer {
private String name;
@DynamoDbConvertedBy(NullifyEmptyStringConverter.class)
public String getName() {
return name;
}
}
```
# SDK for Java 버전 1과 버전 2의 낙관적 잠금 차이점
V1과 V2 모두 bean 클래스에 하나의 속성을 표시하여 버전 번호를 저장하는 속성 주석으로 낙관적 잠금을 구현합니다.
**낙관적 잠금 동작의 차이점**
| | V1 | V2 |
| --- | --- | --- |
| bean 클래스 주석 | @DynamoDBVersionAttribute | @DynamoDbVersionAttribute(V2는 소문자 ‘b’ 사용) |
| 초기 저장 | 버전 번호 속성은 1로 설정됩니다. | `@DynamoDbVersionAttribute(startAt = X)`로 설정된 버전 속성의 시작 값입니다. 기본값은 0입니다. |
| 업데이트 | 조건부 확인에서 업데이트 중인 객체의 버전 번호가 데이터베이스의 번호와 일치하는지 확인하면 버전 번호 속성이 1씩 증가합니다. | 조건부 확인에서 업데이트 중인 객체의 버전 번호가 데이터베이스의 번호와 일치하는지 확인하면 버전 번호 속성이 증분합니다. `@DynamoDbVersionAttribute(incrementBy = X)`로 설정된 `incrementBy` 옵션에 따라 증분하는 버전 번호 속성입니다. 기본값은 1입니다. |
| Delete | DynamoDBMapper는 삭제 중인 객체의 버전 번호가 데이터베이스의 버전 번호와 일치하는지 조건부 확인을 추가합니다. | V2는 삭제 작업에 대한 조건을 자동으로 추가하지 않습니다. 삭제 동작을 제어하려면 조건 표현식을 수동으로 추가해야 합니다. 다음 예제에서 `recordVersion`은 bean의 버전 속성입니다. // 1. Read the item and get its current version.
Customer item = customerTable.getItem(Key.builder().partitionValue("someId").build());
AttributeValue currentVersion = item.getRecordVersion();
// 2. Create conditional delete with the `currentVersion` value.
DeleteItemEnhancedRequest deleteItemRequest =
DeleteItemEnhancedRequest.builder()
.key(KEY)
.conditionExpression(Expression.builder()
.expression("recordVersion = :current_version_value")
.putExpressionValue(":current_version_value", currentVersion)
.build()).build();
customerTable.deleteItem(deleteItemRequest);
|
| 조건 확인을 사용한 트랜잭션 쓰기 | addConditionCheck 메서드에서 @DynamoDBVersionAttribute로 주석이 달린 bean 클래스는 사용할 수 없습니다. | transactWriteItems 요청에 대해 addConditionCheck 빌더 메서드의 @DynamoDbVersionAttribute 주석과 함께 bean 클래스를 사용할 수 있습니다. |
| 비활성화 | 낙관적 잠금은 DynamoDBMapperConfig.SaveBehavior 열거 값을 UPDATE에서 CLOBBER로 변경하면 사용 해제할 수 있습니다. | `@DynamoDbVersionAttribute` 주석을 사용하지 마세요. |
# SDK for Java 버전 1과 버전 2 간의 유용한 setter 차이점
V1용 DynamoDB 매핑 API에서 유용한 setter와 버전 2.30.29 이후 V2에서 POJO를 사용할 수 있습니다.
예를 들어 다음 POJO는 `setName` 메서드에서 `Customer` 인스턴스를 반환합니다.
```
// V1
@DynamoDBTable(tableName ="Customer")
public class Customer{
private String name;
// Other attributes and methods not shown.
public Customer setName(String name){
this.name = name;
return this;
}
}
```
그러나 2.30.29 이전의 V2 버전을 사용하는 경우 `setName`은 `name` 값이 `null`인 `Customer` 인스턴스를 반환합니다.
```
// V2 prior to version 2.30.29.
@DynamoDbBean
public class Customer{
private String name;
// Other attributes and methods not shown.
public Customer setName(String name){
this.name = name;
return this; // Bug: returns this instance with a `name` value of `null`.
}
}
```
```
// Available in V2 since version 2.30.29.
@DynamoDbBean
public class Customer{
private String name;
// Other attributes and methods not shown.
public Customer setName(String name){
this.name = name;
return this; // Returns this instance for method chaining with the `name` value set.
}
}
```
# 버전 1과 버전 2 간의 API 차이점 문서화 AWS SDK for Java
문서 API는 DynamoDB 테이블에서 JSON 형식 문서를 단일 항목으로 사용할 수 있도록 지원합니다. V1 문서 API는 V2에 해당 API가 있지만, V1처럼 문서 API에 별도의 클라이언트를 사용하는 대신, V2에서는 DynamoDB 향상된 클라이언트에 문서 API 기능을 통합했습니다.
V1에서 [https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/Item.html](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/Item.html) 클래스는 DynamoDB 테이블의 비정형 레코드를 나타냅니다. V2에서 비정형 레코드는 [https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/document/EnhancedDocument.html](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/document/EnhancedDocument.html) 클래스의 인스턴스로 표시됩니다. 프라이머리 키는 V2의 테이블 스키마와 V1의 항목 자체에 정의되어 있습니다.
아래 테이블에서는 V1과 V2의 문서 API를 비교합니다.
| 사용 사례: | V1 | V2 |
| --- |--- |--- |
| Create a document client | AmazonDynamoDB client = ... //Create a client.
DynamoDB documentClient = new DynamoDB(client);
| // The V2 Document API uses the same DynamoDbEnhancedClient
// that is used for mapping POJOs.
DynamoDbClient standardClient = ... //Create a standard client.
DynamoDbEnhancedClient enhancedClient = ... // Create an enhanced client.
|
| Reference a table | Table documentTable = docClient.documentClient("Person"); | DynamoDbTable documentTable = enhancedClient.table("Person",
TableSchema.documentSchemaBuilder()
.addIndexPartitionKey(TableMetadata.primaryIndexName(),"id", AttributeValueType.S)
.attributeConverterProviders(AttributeConverterProvider.defaultProvider())
.build());
|
| **Work with semi-structured data** |
| --- |
| Put item | Item item = new Item()
.withPrimaryKey("id", 50)
.withString("firstName", "Shirley");
PutItemOutcome outcome = documentTable.putItem(item);
| EnhancedDocument personDocument = EnhancedDocument.builder()
.putNumber("id", 50)
.putString("firstName", "Shirley")
.build();
documentTable.putItem(personDocument);
|
| Get item | GetItemOutcome outcome = documentTable.getItemOutcome( "id", 50);
Item personDocFromDb = outcome.getItem();
String firstName = personDocFromDb.getString("firstName");
| EnhancedDocument personDocFromDb = documentTable
.getItem(Key.builder()
.partitionValue(50)
.build());
String firstName = personDocFromDb.getString("firstName");
|
| **Work with JSON items** |
| --- |
| Convert a JSON structure to use it with the Document API | // The 'jsonPerson' identifier is a JSON string.
Item item = new Item().fromJSON(jsonPerson);
| // The 'jsonPerson' identifier is a JSON string.
EnhancedDocument document = EnhancedDocument.builder()
.json(jsonPerson).build());
|
| Put JSON | documentTable.putItem(item)
| documentTable.putItem(document);
|
| Read JSON | GetItemOutcome outcome = //Get item.
String jsonPerson = outcome.getItem().toJSON();
| String jsonPerson = documentTable.getItem(Key.builder()
.partitionValue(50).build())
.fromJson();
|
## 문서 API에 대한 API 참조 및 안내서
| | V1 | V2 |
| --- | --- | --- |
| API 참조 | [API 참조](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/package-summary.html) | [API 참조](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/document/package-summary.html) |
| 문서 안내서 | [Amazon DynamoDB 개발자 안내서](https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/JavaDocumentAPIItemCRUD.html) | [향상된 문서 API](ddb-en-client-doc-api.md)(이 안내서) |
# V1 Xpec API에서 V2 표현식 API
문서 중심 데이터로 작업할 표현식을 만드는 데 도움이 되는 V1에서 사용할 수 있는 표현식 사양(Xspec) API는 V2에서 사용할 수 없습니다. V2는 문서 중심 데이터와 object-to-item 매핑 데이터 모두에서 작동하는 표현식 API를 사용합니다.
****
| | V1 | V2 |
| --- | --- | --- |
| API 이름 | 표현식 사양(Xspec) API | 표현식 API |
| 함께 작동 | [updateItem](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/Table.html#updateItem-java.lang.String-java.lang.Object-com.amazonaws.services.dynamodbv2.xspec.UpdateItemExpressionSpec-) 및 [scan](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/Table.html#scan-com.amazonaws.services.dynamodbv2.xspec.ScanExpressionSpec-) 등 문서 API [테이블](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/Table.html) 클래스의 메서드 | DynamoDB 향상된 클라이언트의 두 API: [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/ddb-v1-xspec-migrate.html) [https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/DynamoDbTable.html](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/DynamoDbTable.html) 인스턴스를 획득한 후 두 유형의 API에 대해 다음을 수행합니다. [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/ddb-v1-xspec-migrate.html) 요청 객체를 만들 때 `DynamoDbTable` 메서드에서 표현식을 사용합니다. [https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/model/QueryEnhancedRequest.Builder.html](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/model/QueryEnhancedRequest.Builder.html)의 `filterExpression` 메서드에서의 예제 |
| 리소스 | [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/ko_kr/sdk-for-java/latest/developer-guide/ddb-v1-xspec-migrate.html) | 이 Java 개발자 안내서의 [표현식 정보](ddb-en-client-expressions.md) |
# 암호화 라이브러리 마이그레이션
DynamoDB가 Java SDK의 V2로 작동하도록 암호화 라이브러리를 마이그레이션하는 방법에 대한 자세한 내용은 [Amazon DynamoDB Encryption Client 개발자 안내서](https://docs.aws.amazon.com/database-encryption-sdk/latest/devguide/ddb-java-migrate.html)를 참조하세요.
# 버전 1에서 버전 2로 자동 Amazon SQS 요청 배치 처리 변경 사항
이 주제에서는 AWS SDK for Java의 버전 1과 버전 2 간에 Amazon SQS에 대한 자동 요청 배치 처리의 변경 사항을 자세히 설명합니다.
## 높은 수준의 변경 사항
AWS SDK for Java 1.x는 요청 일괄 처리를 위해 명시적으로 초기화해야 하는 별도의 `[AmazonSQSBufferedAsyncClient](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/sqs/buffered/AmazonSQSBufferedAsyncClient.html)` 클래스를 사용하여 클라이언트 측 버퍼링을 수행합니다.
는를 사용하여 버퍼링 기능을 AWS SDK for Java 2.x 간소화하고 개선합니다`[SqsAsyncBatchManager](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html)`. 이 인터페이스의 구현은 표준 `[SqsAsyncClient](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/SqsAsyncClient.html)`와 직접 통합된 자동 요청 배치 처리 기능을 제공합니다. v2의 `SqsAsyncBatchManager`에 대해 알아보려면 이 안내서의 [에서 Amazon SQS에 자동 요청 일괄 처리 사용 AWS SDK for Java 2.x](sqs-auto-batch.md) 주제를 참조하세요.
| 변경 | v1 | v2 |
| --- | --- | --- |
| Maven 종속성 |
com.amazonaws
aws-java-sdk-bom
1.12.7821
pom
import
com.amazonaws
aws-java-sdk-sqs
|
software.amazon.awssdk
bom
2.31.152
pom
import
software.amazon.awssdk
sqs
|
| 패키지 이름 | com.amazonaws.services.sqs.buffered | software.amazon.awssdk.services.sqs.batchmanager |
| 클래스 이름 | `[AmazonSQSBufferedAsyncClient](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/sqs/buffered/AmazonSQSBufferedAsyncClient.html)` | [SqsAsyncBatchManager](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html) |
1 [최신 버전](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [최신 버전](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## 자동 SQS 요청 배치 처리 사용
| 변경 | v1 | v2 |
| --- | --- | --- |
| 배치 관리자 만들기 | AmazonSQSAsync sqsAsync = new AmazonSQSAsyncClient();
AmazonSQSAsync bufferedSqs = new
AmazonSQSBufferedAsyncClient(sqsAsync);
| SqsAsyncClient asyncClient = SqsAsyncClient.create();
SqsAsyncBatchManager sqsAsyncBatchManager =
asyncClient.batchManager();
|
| 사용자 지정 구성을 사용하여 배치 관리자 만들기 | AmazonSQSAsync sqsAsync = new AmazonSQSAsyncClient();
QueueBufferConfig queueBufferConfig = new QueueBufferConfig()
.withMaxBatchOpenMs(200)
.withMaxBatchSize(10)
.withMinReceiveWaitTimeMs(1000)
.withVisibilityTimeoutSeconds(20)
.withReceiveMessageAttributeNames(messageAttributeValues);
AmazonSQSAsync bufferedSqs =
new AmazonSQSBufferedAsyncClient(sqsAsync, queueBufferConfig);
| BatchOverrideConfiguration batchOverrideConfiguration =
BatchOverrideConfiguration.builder()
.sendRequestFrequency(Duration.ofMillis(200))
.maxBatchSize(10)
.receiveMessageMinWaitDuration(Duration.ofMillis(1000))
.receiveMessageVisibilityTimeout(Duration.ofSeconds(20))
.receiveMessageSystemAttributeNames(messageSystemAttributeNames)
.receiveMessageAttributeNames(messageAttributeValues)
.build();
SqsAsyncBatchManager sqsAsyncBatchManager = SqsAsyncBatchManager.builder()
.overrideConfiguration(batchOverrideConfiguration)
.client(SqsAsyncClient.create())
.scheduledExecutor(Executors.newScheduledThreadPool(8))
.build();
|
| 메시지 전송 | Future sendResultFuture =
bufferedSqs.sendMessageAsync(new SendMessageRequest()
.withQueueUrl(queueUrl)
.withMessageBody(body));
| CompletableFuture sendCompletableFuture =
sqsAsyncBatchManager.sendMessage(
SendMessageRequest.builder()
.queueUrl(queueUrl)
.messageBody(body)
.build());
|
| 메시지 삭제 | Future deletResultFuture =
bufferedSqs.deleteMessageAsync(new DeleteMessageRequest()
.withQueueUrl(queueUrl));
| CompletableFuture deleteResultCompletableFuture
= sqsAsyncBatchManager.deleteMessage(
DeleteMessageRequest.builder()
.queueUrl(queueUrl)
.build());
|
| 메시지의 표시 여부 변경 | Future changeVisibilityResultFuture =
bufferedSqs.changeMessageVisibilityAsync
(new ChangeMessageVisibilityRequest()
.withQueueUrl(queueUrl)
.withVisibilityTimeout(20));
| CompletableFuture changeResponseCompletableFuture
= sqsAsyncBatchManager.changeMessageVisibility(
ChangeMessageVisibilityRequest.builder()
.queueUrl(queueUrl)
.visibilityTimeout(20)
.build());
|
| 메시지 수신 | ReceiveMessageResult receiveResult =
bufferedSqs.receiveMessage(
new ReceiveMessageRequest()
.withQueueUrl(queueUrl));
| CompletableFuture
responseCompletableFuture = sqsAsyncBatchManager.receiveMessage(
ReceiveMessageRequest.builder()
.queueUrl(queueUrl)
.build());
|
## 비동기식 반환 유형 차이점
| 변경 | v1 | v2 |
| --- | --- | --- |
| 반환 타입 | Future | CompletableFuture |
| 콜백 메커니즘 | 별도의 onSuccess 및 onError 메서드가 있는 AsyncHandler 필요 | whenComplete(), thenCompose(), thenApply() 등 JDK에서 제공하는 CompletableFuture API 사용 |
| 예외 처리 | AsyncHandler\$1onError() 메서드 사용 | exceptionally(), handle(), whenComplete() 등 JDK에서 제공하는 CompletableFuture API 사용 |
| 취소 | Future.cancel()을 통한 기본 지원 | 상위 CompletableFuture를 취소하면 체인의 모든 종속 future 자동 취소 |
## 비동기식 완료 처리 차이점
| 변경 | v1 | v2 |
| --- | --- | --- |
| 응답 핸들러 구현 | Future future = bufferedSqs.receiveMessageAsync(
receiveRequest,
new AsyncHandler() {
@Override
public void onSuccess(ReceiveMessageRequest request,
ReceiveMessageResult result) {
List messages = result.getMessages();
System.out.println("Received " + messages.size() + " messages");
for (Message message : messages) {
System.out.println("Message ID: " + message.getMessageId());
System.out.println("Body: " + message.getBody());
}
}
@Override
public void onError(Exception e) {
System.err.println("Error receiving messages: " + e.getMessage());
e.printStackTrace();
}
}
);
| CompletableFuture completableFuture = sqsAsyncBatchManager
.receiveMessage(ReceiveMessageRequest.builder()
.queueUrl(queueUrl).build())
.whenComplete((receiveMessageResponse, throwable) -> {
if (throwable != null) {
System.err.println("Error receiving messages: " + throwable.getMessage());
throwable.printStackTrace();
} else {
List messages = receiveMessageResponse.messages();
System.out.println("Received " + messages.size() + " messages");
for (Message message : messages) {
System.out.println("Message ID: " + message.messageId());
System.out.println("Body: " + message.body());
}
}
});
|
## 주요 구성 파라미터
****
| 파라미터 | v1 | v2 |
| --- | --- | --- |
| 최대 배치 크기 | maxBatchSize(배치당 기본 요청 10개) | maxBatchSize(배치당 기본 요청 10개) |
| 배치 대기 시간 | maxBatchOpenMs(기본값 200ms) | sendRequestFrequency(기본값 200ms) |
| 표시 제한 시간 | visibilityTimeoutSeconds(대기열 기본값의 경우 -1) | receiveMessageVisibilityTimeout(기본 대기열) |
| 최소 대기 시간 | longPollWaitTimeoutSeconds(longPoll이 true인 경우 20초) | receiveMessageMinWaitDuration(기본값 50ms) |
| 메시지 속성 | ReceiveMessageRequest를 사용하여 설정 | receiveMessageAttributeNames(기본적으로 없음) |
| 시스템 속성 | ReceiveMessageRequest를 사용하여 설정 | receiveMessageSystemAttributeNames(기본적으로 없음) |
| 긴 폴링 | longPoll(기본값 true) | 서버가 메시지를 보낼 때까지 대기 중인 열린 연결을 방지하기 위해 지원되지 않음 |
| 긴 폴링의 최대 대기 시간 | longPollWaitTimeoutSeconds(기본값 20초) | 서버가 메시지를 보낼 때까지 대기 중인 열린 연결을 방지하기 위해 지원되지 않음 |
| 클라이언트 측에서 미리 가져와서 저장하는 수신 배치의 최대 개수 | maxDoneReceiveBatches(배치 10개) | 내부적으로 처리되므로 지원되지 않음 |
| 동시에 처리되는 최대 활성 아웃바운드 배치 수 | maxInflightOutboundBatches(기본값 배치 5개) | 내부적으로 처리되므로 지원되지 않음 |
| 동시에 처리되는 최대 활성 수신 배치 수 | maxInflightReceiveBatches(기본값 배치 10개) | 내부적으로 처리되므로 지원되지 않음 |