| Direkt wiederaufnehmbares Objekt | Nicht unterstützt |
### Ergebnisobjekte
| Klasse V1 | Klasse V2 | Migrationsstatus |
| --- | --- | --- |
| CopyResult | CompletedCopy | Unterstützt |
| UploadResult | CompletedUpload | Unterstützt |
### Konfigurationsobjekte
| Klasse V1 | Klasse V2 | Migrationsstatus |
| --- | --- | --- |
| TransferManagerConfiguration | MultipartConfiguration(auf dem Amazon S3 S3-Client) | Unterstützt |
| TransferProgress | TransferProgress \$1 TransferProgressSnapshot | Unterstützt |
| KeyFilter | DownloadFilter | Unterstützt |
### Nicht unterstützte Objekte
| Klasse V1 | Alternative V2 | Migrationsstatus |
| --- | --- | --- |
| PauseStatus | Nicht unterstützt | Nicht unterstützt |
| UploadContext | Nicht unterstützt | Nicht unterstützt |
| ObjectCannedAclProvider | PutObjectRequest.builder().acl() | Nicht unterstützt |
| ObjectMetadataProvider | PutObjectRequest.builder().metadata() | Nicht unterstützt |
| ObjectTaggingProvider | PutObjectRequest.builder().tagging() | Nicht unterstützt |
| PresignedUrlDownload | Nicht unterstützt | Nicht unterstützt |
## TransferManagerBuilder Migration der Konfiguration
### Konfigurationsänderungen
Die Konfigurationsänderungen, die Sie für den v2-Transfermanager vornehmen müssen, hängen davon ab, welchen S3-Client Sie verwenden. Sie haben die Wahl zwischen dem AWS CRT-basierten S3-Client oder dem standardmäßigen, auf Java basierenden asynchronen S3-Client. Informationen zu den Unterschieden finden Sie im Thema. [S3-Clients in der AWS SDK for Java 2.x](examples-s3.md#s3-clients)
------
#### [ Use the AWS CRT-based S3 client ]
****
| Einstellung | v1 | v2 — Transfer Manager mit AWS CRT-basiertem S3-Client |
| --- | --- | --- |
| (hol dir einen Builder) | TransferManagerBuilder tmBuilder =
TransferManagerBuilder.standard();
| S3TransferManager.Builder tmBuilder =
S3TransferManager.builder();
|
| S3-Klient | tmBuilder.withS3Client(...);
tmBuilder.setS3Client(...);
| tmBuilder.s3Client(...);
|
| Testamentsvollstrecker | tmBuilder.withExecutorFactory(...);
tmBuilder.setExecutorFactory(...);
| tmBuilder.executor(...);
|
| Threadpools herunterfahren | tmBuilder.withShutDownThreadPools(...);
tmBuilder.setShutdownThreadPools(...);
| Nicht unterstützt Der bereitgestellte Executor wird nicht heruntergefahren, wenn der S3TransferManager geschlossen wird |
| Minimale Größe des Upload-Teils | tmBuilder.withMinimumUploadPartSize(...);
tmBuilder.setMinimumUploadPartSize(...);
| S3AsyncClient s3 = S3AsyncClient.crtBuilder().
minimumPartSizeInBytes(...).build();
tmBuilder.s3Client(s3);
|
| Schwellenwert für mehrteiliges Hochladen | tmBuilder.withMultipartUploadThreshold(...);
tmBuilder.setMultipartUploadThreshold(...);
| S3AsyncClient s3 = S3AsyncClient.crtBuilder().
thresholdInBytes(...).build();
tmBuilder.s3Client(s3);
|
| Minimale Größe des Kopierteils | tmBuilder.withMultipartCopyPartSize(...);
tmBuilder.setMultipartCopyPartSize(...);
| S3AsyncClient s3 = S3AsyncClient.crtBuilder().
minimumPartSizeInBytes(...).build();
tmBuilder.s3Client(s3);
|
| Schwellenwert für mehrteiliges Kopieren | tmBuilder.withMultipartCopyThreshold(...);
tmBuilder.setMultipartCopyThreshold(...);
| S3AsyncClient s3 = S3AsyncClient.crtBuilder().
thresholdInBytes(...).build();
tmBuilder.s3Client(s3);
|
| parallel Downloads deaktivieren | tmBuilder.withDisableParallelDownloads(...);
tmBuilder.setDisableParallelDownloads(...);
| Deaktivieren Sie parallel Downloads, indem Sie einen standardmäßigen Java-basierten S3-Client mit deaktiviertem Multipart (Standard) an den Transfermanager übergeben.S3AsyncClient s3 =
S3AsyncClient.builder().build();
tmBuilder.s3Client(s3);
|
| Berechne immer mehrteiliges MD5 | tmBuilder.withAlwaysCalculateMultipartMd5(...);
tmBuilder.setAlwaysCalculateMultipartMd5(...);
| Nicht unterstützt |
------
#### [ Use Java-based S3 async client ]
****
| Einstellung | v1 | v2 — Transfer Manager mit einem Java-basierten asynchronen S3-Client |
| --- | --- | --- |
| (hol dir einen Builder) | TransferManagerBuilder tmBuilder =
TransferManagerBuilder.standard();
| S3TransferManager.Builder tmBuilder =
S3TransferManager.builder();
|
| S3-Klient | tmBuilder.withS3Client(...);
tmBuilder.setS3Client(...);
| tmBuilder.s3Client(...);
|
| Testamentsvollstrecker | tmBuilder.withExecutorFactory(...);
tmBuilder.setExecutorFactory(...);
| tmBuilder.executor(...);
|
| Threadpools herunterfahren | tmBuilder.withShutDownThreadPools(...);
tmBuilder.setShutdownThreadPools(...);
| Nicht unterstützt Der bereitgestellte Executor wird nicht heruntergefahren, wenn der S3TransferManager geschlossen wird |
| Minimale Größe des Upload-Teils | tmBuilder.withMinimumUploadPartSize(...);
tmBuilder.setMinimumUploadPartSize(...);
| S3AsyncClient s3 = S3AsyncClient.builder()
.multipartConfiguration(cfg ->
cfg.minimumPartSizeInBytes(...)).build();
tmBuilder.s3Client(s3);
|
| Schwellenwert für mehrteiliges Hochladen | tmBuilder.withMultipartUploadThreshold(...);
tmBuilder.setMultipartUploadThreshold(...);
| S3AsyncClient s3 = S3AsyncClient.builder()
.multipartConfiguration(cfg ->
cfg.thresholdInBytes(...)).build();
tmBuilder.s3Client(s3);
|
| Minimale Größe des Kopierteils | tmBuilder.withMultipartCopyPartSize(...);
tmBuilder.setMultipartCopyPartSize(...);
| S3AsyncClient s3 = S3AsyncClient.builder()
.multipartConfiguration(cfg ->
cfg.minimumPartSizeInBytes(...)).build();
tmBuilder.s3Client(s3);
|
| Schwellenwert für mehrteiliges Kopieren | tmBuilder.withMultipartCopyThreshold(...);
tmBuilder.setMultipartCopyThreshold(...);
| S3AsyncClient s3 = S3AsyncClient.builder()
.multipartConfiguration(cfg ->
cfg.thresholdInBytes(...)).build();
tmBuilder.s3Client(s3);
|
| parallel Downloads deaktivieren | tmBuilder.withDisableParallelDownloads(...);
tmBuilder.setDisableParallelDownloads(...);
| Deaktivieren Sie parallel Downloads, indem Sie einen standardmäßigen Java-basierten S3-Client mit deaktiviertem Multipart (Standard) an den Transfermanager übergeben.S3AsyncClient s3 =
S3AsyncClient.builder().build();
tmBuilder.s3Client(s3);
|
| Berechne immer mehrteiliges MD5 | tmBuilder.withAlwaysCalculateMultipartMd5(...);
tmBuilder.setAlwaysCalculateMultipartMd5(...);
| Nicht unterstützt |
------
## Verhaltensänderungen
### Asynchrone Operationen
**V1 (blockierend):**
```
Upload upload = transferManager.upload("amzn-s3-demo-bucket", "key", file);
upload.waitForCompletion(); // Blocks until complete
```
**V2 (asynchron):**
```
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());
});
```
### Fehlerbehandlung
**V1:** Verzeichnisübertragungen schlagen vollständig fehl, wenn eine Unteranforderung fehlschlägt.
**V2:** Verzeichnisübertragungen werden erfolgreich abgeschlossen, auch wenn einige Unteranfragen fehlschlagen. Explizit nach Fehlern suchen:
```
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()));
}
```
### Paralleler Download über Bytebereichs-Abrufe
Wenn die automatische parallele Übertragung im v2-SDK aktiviert ist, verwendet der S3 Transfer Manager [Bytebereichs-Abrufe, um bestimmte](https://docs.aws.amazon.com/AmazonS3/latest/userguide/optimizing-performance-guidelines.html#optimizing-performance-guidelines-get-range) Teile des Objekts parallel abzurufen (mehrteiliger Download). Die Art und Weise, wie ein Objekt mit Version 2 heruntergeladen wird, hängt nicht davon ab, wie das Objekt ursprünglich hochgeladen wurde. Alle Downloads können von hohem Durchsatz und Parallelität profitieren.
Im Gegensatz dazu spielt es beim Transfer Manager von Version 1 eine Rolle, wie das Objekt ursprünglich hochgeladen wurde. Der v1-Transfermanager ruft die Teile des Objekts auf die gleiche Weise ab, wie die Teile hochgeladen wurden. Wenn ein Objekt ursprünglich als einzelnes Objekt hochgeladen wurde, ist der v1 Transfer Manager nicht in der Lage, den Download-Vorgang mithilfe von Unteranforderungen zu beschleunigen.
# Änderungen beim Parsen von Amazon S3 URIs von Version 1 zu Version 2
In diesem Thema werden die Änderungen beim Parsen von Amazon S3 URIs von Version 1 (v1) auf Version 2 (v2.) beschrieben.
## Änderungen auf hoher Ebene
Um mit dem Parsen eines S3-URI in Version 1 zu beginnen, instanziieren Sie einen `AmazonS3URI` mithilfe eines Konstruktors. In v2 rufen Sie eine Instanz von `parseUri()` auf`S3Utilities`, um eine zurückzugeben. `S3URI`
****
| Änderungen | v1 | v2 |
| --- | --- | --- |
| Maven-Abhängigkeiten |
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
|
| Package name | com.amazonaws.services.s3 | software.amazon.awssdk.services.s3 |
| Klassennamen | [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 [Letzte Version](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [Letzte Version](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API-Änderungen
| Behavior | v1 | v2 |
| --- | --- | --- |
| Analysieren Sie eine 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);
|
| Ruft den Bucket-Namen aus einer S3-URI ab. | String bucket = s3Uri.getBucket();
| Optional bucket = s3Uri.bucket();
|
| Rufen Sie den Schlüssel ab. | String key = s3Uri.getKey();
| Optional key = s3Uri.key();
|
| Rufen Sie die Region ab. | String region = s3Uri.getRegion();
| Optional region = s3Uri.region();
String region;
if (s3Uri.region().isPresent()) {
region = s3Uri.region().get().id();
}
|
| Ruft ab, ob die S3-URI im Pfadstil ist. | boolean isPathStyle = s3Uri.isPathStyle();
| boolean isPathStyle = s3Uri.isPathStyle();
|
| Rufen Sie die Versions-ID ab. | String versionId = s3Uri.getVersionId();
| Optional versionId =
s3Uri.firstMatchingRawQueryParameter("versionId");
|
| Rufen Sie die Abfrageparameter ab. | – | Map> queryParams =
s3Uri.rawQueryParameters();
|
### Verhaltensänderungen
#### URL-Kodierung
v1 bietet die Möglichkeit, ein Flag zu übergeben, um anzugeben, ob der URI URL-codiert werden soll. Der Standardwert ist `true`.
In Version 2 wird die URL-Kodierung nicht unterstützt. Wenn Sie mit Objektschlüsseln oder Abfrageparametern arbeiten, die reservierte oder unsichere Zeichen enthalten, müssen Sie diese URL-kodieren. Beispielsweise müssen Sie ein Leerzeichen `" "` durch ersetzen. `%20`
# Änderungen in der S3-API für Ereignisbenachrichtigungen von Version 1 zu Version 2
In diesem Thema werden die Änderungen an der API für S3-Ereignisbenachrichtigungen von Version 1.x (v1) auf Version 2 .x (v2) von beschrieben. AWS SDK für Java
## Änderungen auf hoher Ebene
### Strukturelle Veränderungen
V1 verwendet statische innere Klassen für `EventNotificationRecord` Typen und ihre Attribute, wohingegen v2 separate öffentliche Klassen für `EventNotificationRecord` Typen verwendet.
### Die Namenskonvention ändert sich
In Version 1 enthalten Attributklassennamen das Suffix *Entity*, wohingegen in Version 2 dieses Suffix aus Gründen der einfacheren Benennung weggelassen wird: zum Beispiel *EventData* statt. *eventDataEntity*
## Änderungen an Abhängigkeiten, Paketen und Klassennamen
In Version 1 werden S3 Event Notification API-Klassen zusammen mit dem S3-Modul (`aws-java-sdk-s3`artifactId) transitiv importiert. In Version 2 müssen Sie jedoch eine Abhängigkeit vom Artefakt hinzufügen. `s3-event-notifications`
****
| Änderungen | v1 | v2 |
| --- | --- | --- |
| Maven-Abhängigkeiten |
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
|
| Package name | com.amazonaws.services.s3.event | software.amazon.awssdk.eventnotifications.s3.model |
| Klassennamen | [S3EventNotification](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.html) [S3 EventNotification S.3 EventNotificationRecord](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. BucketEntity](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.S3BucketEntity.html) [S3 S.3-Entität EventNotification](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/s3/event/S3EventNotification.S3Entity.html) [EventNotificationS3. S3 ObjectEntity](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) [S3 Bucket](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) [S3-Objekt](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 [Letzte Version](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API-Änderungen
### JSON zu `S3EventNotification` und umgekehrt
| Anwendungsfall | v1 | v2 |
| --- | --- | --- |
| S3EventNotificationAus einer JSON-Zeichenfolge erstellen | S3EventNotification notification =
S3EventNotification.parseJson(message.body());
| S3EventNotification notification =
S3EventNotification.fromJson(message.body());
|
| In S3EventNotification eine JSON-Zeichenfolge konvertieren | String json = notification.toJson();
| String json = notification.toJson();
|
### Greifen Sie auf Attribute von zu `S3EventNotification`
| Anwendungsfall | v1 | v2 |
| --- | --- | --- |
| Datensätze aus einer Benachrichtigung abrufen | List records =
notifcation.getRecords();
| List records =
notification.getRecords();
|
| Rufen Sie einen Datensatz aus einer Liste von Datensätzen ab | S3EventNotification.S3EventNotificationRecord record =
records.stream().findAny().get();
| S3EventNotificationRecord record =
records.stream().findAny().get();
|
| Rufen Sie Glacier-Ereignisdaten ab | S3EventNotification.GlacierEventDataEntity glacierEventData =
record.getGlacierEventData();
| GlacierEventData glacierEventData =
record.getGlacierEventData();
|
| Rufen Sie Wiederherstellungsdaten von einem Glacier-Ereignis ab | S3EventNotification.RestoreEventDataEntity restoreEventData =
glacierEventData.getRestoreEventDataEntity();
| RestoreEventData restoreEventData =
glacierEventData.getRestoreEventData();
|
| Abrufen der Anforderungsparameter | S3EventNotification.RequestParametersEntity requestParameters =
record.getRequestParameters();
| RequestParameters requestParameters =
record.getRequestParameters();
|
| Rufen Sie Intelligent Tiering-Ereignisdaten ab | S3EventNotification.IntelligentTieringEventDataEntity tieringEventData =
record.getIntelligentTieringEventData();
| IntelligentTieringEventData intelligentTieringEventData =
record.getIntelligentTieringEventData();
|
| Lebenszyklus-Ereignisdaten abrufen | S3EventNotification.LifecycleEventDataEntity lifecycleEventData =
record.getLifecycleEventData();
| LifecycleEventData lifecycleEventData =
record.getLifecycleEventData();
|
| Rufen Sie den Ereignisnamen als Enum ab | S3Event eventNameAsEnum = record.getEventNameAsEnum();
| //getEventNameAsEnum does not exist; use 'getEventName()'
String eventName = record.getEventName();
|
| Daten zu Replikationsereignissen abrufen | S3EventNotification.ReplicationEventDataEntity replicationEntity =
record.getReplicationEventDataEntity();
| ReplicationEventData replicationEventData =
record.getReplicationEventData();
|
| Rufen Sie S3-Bucket- und Objektinformationen ab | S3EventNotification.S3Entity s3 = record.getS3();
| S3 s3 = record.getS3();
|
| Rufen Sie Informationen zur Benutzeridentität ab | S3EventNotification.UserIdentityEntity userIdentity =
record.getUserIdentity();
| UserIdentity userIdentity =
record.getUserIdentity();
|
| Antwortelemente abrufen | S3EventNotification.ResponseElementsEntity responseElements =
record.getResponseElements();
| ResponseElements responseElements =
record.getResponseElements();
|
## Migrieren Sie die `aws-lambda-java-events` Bibliotheksversion
Wenn Sie [aws-lambda-java-events](https://github.com/aws/aws-lambda-java-libs/tree/main/aws-lambda-java-events)früher mit S3-Benachrichtigungsereignissen innerhalb einer Lambda-Funktion arbeiten, empfehlen wir Ihnen, auf die neueste 3.x.x-Version zu aktualisieren. Neuere Versionen beseitigen alle Abhängigkeiten von AWS SDK für Java 1.x von der S3-API für Ereignisbenachrichtigungen.
Weitere Informationen zu den Unterschieden bei der Behandlung von S3-Ereignisbenachrichtigungen zwischen der `aws-lambda-java-events` Bibliothek und dem SDK for Java 2.x finden Sie unter[S3-Ereignisse in Lambda mit Java-Bibliotheken verarbeiten: AWS SDK for Java 2.x und `aws-lambda-java-events`](examples-s3-event-notifications.md#s3-event-notif-processing-options).
# Änderungen an der Profildatei
Der AWS SDK for Java 2.x analysiert die Profildefinitionen in `~/.aws/config` und emuliert `~/.aws/credentials` die Art und Weise, wie die AWS CLI die Dateien analysiert, genauer.
Das SDK for Java 2.x:
+ Löst ein `~/` oder, `~` gefolgt vom standardmäßigen Pfadtrennzeichen des Dateisystems am Anfang des Pfads auf, indem der Reihe nach,`$HOME`, `$USERPROFILE` (nur Windows),`$HOMEDRIVE`, `$HOMEPATH` (nur Windows) und dann die `user.home` Systemeigenschaft überprüft wird.
+ Sucht nach der `AWS_SHARED_CREDENTIALS_FILE` Umgebungsvariablen statt nach. `AWS_CREDENTIAL_PROFILES_FILE`
+ Löscht automatisch Profildefinitionen in Konfigurationsdateien ohne das Wort `profile` am Anfang des Profilnamens.
+ Löscht automatisch Profildefinitionen, die nicht aus alphanumerischen Zeichen, Unterstrichen oder Bindestrichen bestehen (nachdem das führende `profile` Wort aus Konfigurationsdateien entfernt wurde).
+ Führt Einstellungen von Profildefinitionen zusammen, die in derselben Datei dupliziert wurden.
+ Führt Einstellungen von Profildefinitionen zusammen, die sowohl in der Konfiguration als auch in der Anmeldeinformationsdatei dupliziert wurden.
+ Führt die Einstellungen NICHT zusammen, wenn `[profile foo]` sich beide in derselben Datei `[foo]` befinden.
+ Verwendet Einstellungen in`[profile foo]`, wenn `[profile foo]` sowohl als auch in der Konfigurationsdatei enthalten `[foo]` sind.
+ Verwendet den Wert der letzten duplizierten Einstellung in derselben Datei und demselben Profil.
+ Erkennt beide `;` und dient `#` zur Definition eines Kommentars.
+ Erkennt `;` und `#` in Profildefinitionen zur Definition eines Kommentars, auch wenn die Zeichen neben der schließenden Klammer stehen.
+ Erkennt `;` und `#` definiert einen Kommentar nur in der Einstellung von Werten, denen Leerzeichen vorangestellt sind.
+ Erkennt `;` und `#` und alle nachfolgenden Inhalte beim Setzen von Werten, wenn ihnen keine Leerzeichen vorangestellt sind.
+ Betrachtet rollenbasierte Anmeldeinformationen als Anmeldeinformationen mit der höchsten Priorität. Das 2.x SDK verwendet immer rollenbasierte Anmeldeinformationen, wenn der Benutzer die Eigenschaft angibt. `role_arn`
+ Betrachtet sitzungsbasierte Anmeldeinformationen als Anmeldeinformationen. second-highest-priority Das 2.x SDK verwendet immer sitzungsbasierte Anmeldeinformationen, wenn keine rollenbasierten Anmeldeinformationen verwendet wurden und der Benutzer die Eigenschaften und angibt. `aws_access_key_id` `aws_session_token`
+ Verwendet grundlegende Anmeldeinformationen, wenn keine rollen- und sitzungsbasierten Anmeldeinformationen verwendet werden und der Benutzer die Eigenschaft angegeben hat. `aws_access_key_id`
# Änderungen an Umgebungsvariablen und Systemeigenschaften
| 1.x-Umgebungsvariable | 1.x-Systemeigenschaft | 2.x Umgebungsvariable | 2.x-Systemeigenschaft |
| --- | --- | --- | --- |
| 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 | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
| | com.amazonaws.sdk.enableDefaultMetrics | [Wird nicht unterstützt](https://github.com/aws/aws-sdk-java-v2/issues/23) | [Wird nicht unterstützt](https://github.com/aws/aws-sdk-java-v2/issues/23) |
| | com.amazonaws.sdk.enableThrottledRetry | [Wird nicht unterstützt](https://github.com/aws/aws-sdk-java-v2/issues/645) | [Wird nicht unterstützt](https://github.com/aws/aws-sdk-java-v2/issues/645) |
| | com.amazonaws.regions.RegionUtils.fileOverride | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
| | com.amazonaws.regions.RegionUtils.disableRemote | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
| | com.amazonaws.services.s3.disableImplicitGlobalClients | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
| | com.amazonaws.sdk.enableInRegionOptimizedMode | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) | Nicht unterstützt ([Anforderungsfunktion](https://github.com/aws/aws-sdk-java-v2/issues/new)) |
# Änderungen in Waiters von Version 1 zu Version 2
In diesem Thema werden die Änderungen der Funktionalität von Waiters von Version 1 (v1) auf Version 2 (v2) beschrieben.
In den folgenden Tabellen wird der Unterschied speziell für DynamoDB-Kellner veranschaulicht. Kellner für andere Dienste folgen demselben Muster.
## Änderungen auf hoher Ebene
Die Kurse für Kellner finden im selben Maven-Artefakt statt wie der Service.
| Änderung | v1 | v2 |
| --- | --- | --- |
| Abhängigkeiten von 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
|
| Package name | com.amazonaws.services.dynamodbv2.waiters | software.amazon.awssdk.services.dynamodb.waiters |
| Klassennamen | `[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/de_de/sdk-for-java/latest/developer-guide/migration-waiters.html) |
1 [Letzte Version](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [Letzte Version](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API-Änderungen
| Änderung | v1 | v2 |
| --- | --- | --- |
| Erstelle einen Kellner | AmazonDynamoDB client = AmazonDynamoDBClientBuilder
.standard().build();
AmazonDynamoDBWaiters waiter = client.waiters();
| Synchron:DynamoDbClient client = DynamoDbClient.create();
DynamoDbWaiter waiter = client.waiter();
Asynchron:DynamoDbAsyncClient asyncClient =
DynamoDbAsyncClient.create();
DynamoDbAsyncWaiter waiter = asyncClient.waiter();
|
| Warte, bis eine Tabelle existiert | Synchron:waiter.tableExists()
.run(new WaiterParameters<>(
new DescribeTableRequest(tableName)));
Asynchron: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();
| Synchron: WaiterResponse waiterResponse =
waiter.waitUntilTableExists(
r -> r.tableName("myTable"));
waiterResponse.matched().response()
.ifPresent(System.out::println);
Asynchron: waiter.waitUntilTableExists(r -> r.tableName(tableName))
.whenComplete((r, t) -> {
if (t != null) {
t.printStackTrace();
} else {
System.out.println(
"Table creation succeeded");
}
}).join();
|
## Konfigurationsänderungen
| Änderung | v1 | v2 |
| --- | --- | --- |
| Abfragestrategie (maximale Anzahl Versuche und feste Verzögerung) | 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));
|
# Änderungen im EC2-Metadaten-Hilfsprogramm von Version 1 zu Version 2
In diesem Thema werden die Änderungen im Metadaten-Hilfsprogramm SDK for Java Amazon Elastic Compute Cloud (EC2) von Version 1 (v1) auf Version 2 (v2) beschrieben.
## Änderungen auf hoher Ebene
****
| Änderungen | v1 | v2 |
| --- | --- | --- |
| Maven-Abhängigkeiten |
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
|
| Package name | com.amazonaws.util | software.amazon.awssdk.imds |
| Instanziierungsansatz | Verwenden Sie statische Hilfsmethoden; keine Instanziierung: String localHostName =
EC2MetadataUtils.getLocalHostName();
| Verwenden Sie eine statische Factory-Methode: Ec2MetadataClient client = Ec2MetadataClient.create();
Oder verwenden Sie einen Builder-Ansatz: Ec2MetadataClient client = Ec2MetadataClient.builder()
.endpointMode(EndpointMode.IPV6)
.build();
|
| Arten von Kunden | Nur synchrone Hilfsmethoden: EC2MetadataUtils | Synchron: `Ec2MetadataClient` Asynchron: `Ec2MetadataAsyncClient` |
1 [Letzte Version](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [Letzte Version](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
3 Beachten Sie die Deklaration des `apache-client` Moduls für v2. V2 des EC2-Metadaten-Dienstprogramms erfordert eine Implementierung der `SdkHttpClient` Schnittstelle für den synchronen Metadaten-Client oder der `SdkAsyncHttpClient` Schnittstelle für den asynchronen Metadaten-Client. Der [Konfigurieren Sie HTTP-Clients in der AWS SDK for Java 2.x](http-configuration.md) Abschnitt zeigt die Liste der HTTP-Clients, die Sie verwenden können.
### Metadaten anfordern
In Version 1 verwenden Sie statische Methoden, die keine Parameter akzeptieren, um Metadaten für eine EC2-Ressource anzufordern. Im Gegensatz dazu müssen Sie in v2 den Pfad zur EC2-Ressource als Parameter angeben. Die folgende Tabelle zeigt die verschiedenen Ansätze.
****
| v1 | v2 |
| --- | --- |
| String userMetaData = EC2MetadataUtils.getUserData();
| Ec2MetadataClient client = Ec2MetadataClient.create();
Ec2MetadataResponse response =
client.get("/latest/user-data");
String userMetaData =
response.asString();
|
Den Pfad, den Sie angeben müssen, um [Metadaten anzufordern, finden Sie in den Kategorien der Instanz-Metadaten](https://docs.aws.amazon.com//AWSEC2/latest/UserGuide/instancedata-data-categories.html).
**Anmerkung**
Wenn Sie in Version 2 einen Instanz-Metadaten-Client verwenden, sollten Sie versuchen, für alle Anfragen zum Abrufen von Metadaten denselben Client zu verwenden.
## Verhaltensänderungen
### JSON-Daten
Auf EC2 gibt der lokal ausgeführte Instance Metadata Service (IMDS) einige Metadaten als Zeichenketten im JSON-Format zurück. Ein solches Beispiel sind die dynamischen Metadaten eines [Instanz-Identdokuments](https://docs.aws.amazon.com//AWSEC2/latest/UserGuide/instance-identity-documents.html).
Die v1-API enthält separate Methoden für jeden Teil der Instanzidentitätsmetadaten, wohingegen die v2-API die JSON-Zeichenfolge direkt zurückgibt. Um mit der JSON-Zeichenfolge zu arbeiten, können Sie die [Dokument-API](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/core/document/package-summary.html) verwenden, um die Antwort zu analysieren und in der JSON-Struktur zu navigieren.
In der folgenden Tabelle wird verglichen, wie Sie Metadaten eines Instanzidentitätsdokuments in Version 1 und Version 2 abrufen.
****
| Anwendungsfall | v1 | v2 |
| --- | --- | --- |
| Rufen Sie die Region ab | 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();
|
| Rufen Sie die Instanz-ID ab | 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();
|
| Rufen Sie den Instanztyp ab | 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();
|
### Unterschiede bei der Auflösung von Endpunkten
Die folgende Tabelle zeigt die Speicherorte, nach denen das SDK sucht, um den Endpunkt nach IMDS aufzulösen. Die Standorte sind mit absteigender Priorität aufgeführt.
****
| v1 | v2 |
| --- | --- |
| Systemeigenschaft: com.amazonaws.sdk.ec2MetadataServiceEndpointOverride | Konfigurationsmethode für den Client Builder: endpoint(...) |
| Umgebungsvariable: AWS\$1EC2\$1METADATA\$1SERVICE\$1ENDPOINT | Systemeigenschaft: aws.ec2MetadataServiceEndpoint |
| Standardwert: http://169.254.169.254 | Konfigurationsdatei: \$1.aws/config mit der ec2\$1metadata\$1service\$1endpoint Einstellung |
| | Wert, der mit „gelöst“ verknüpft ist endpoint-mode |
| | Standardwert: http://169.254.169.254 |
### Endpunktauflösung in Version 2
Wenn Sie mithilfe des Builders explizit einen Endpunkt festlegen, hat dieser Endpunktwert Vorrang vor allen anderen Einstellungen. Wenn der folgende Code ausgeführt wird, werden die `aws.ec2MetadataServiceEndpoint` Systemeigenschaft und die `ec2_metadata_service_endpoint` Einstellung der Konfigurationsdatei ignoriert, sofern sie existieren.
```
Ec2MetadataClient client = Ec2MetadataClient
.builder()
.endpoint(URI.create("endpoint.to.use"))
.build();
```
#### Endpoint-Modus
Mit v2 können Sie einen Endpunktmodus angeben, um den Metadaten-Client so zu konfigurieren, dass er die Standard-Endpunktwerte für oder verwendet. IPv4 IPv6 Der Endpunktmodus ist für Version 1 nicht verfügbar. Der für verwendete Standardwert IPv4 ist `http://169.254.169.254` und `http://[fd00:ec2::254]` für. IPv6
Die folgende Tabelle zeigt die verschiedenen Möglichkeiten, wie Sie den Endpunktmodus nach absteigender Priorität einstellen können.
****
| | | Mögliche Werte |
| --- | --- | --- |
| Client-Builder-Konfigurationsmethode: endpointMode(...) | Ec2MetadataClient client = Ec2MetadataClient
.builder()
.endpointMode(EndpointMode.IPV4)
.build();
| EndpointMode.IPV4, EndpointMode.IPV6 |
| Systemeigenschaft | aws.ec2MetadataServiceEndpointMode | IPv4, IPv6 (Groß- und Kleinschreibung spielt keine Rolle) |
| Konfigurationsdatei: \$1.aws/config | ec2\$1metadata\$1service\$1endpoint-Einstellung | IPv4, IPv6 (Groß- und Kleinschreibung spielt keine Rolle) |
| Auf die vorherigen Arten nicht angegeben | IPv4 wird verwendet | |
#### Wie das SDK auflöst `endpoint` oder `endpoint-mode` in v2
1. Das SDK verwendet den Wert, den Sie im Code auf dem Client Builder festgelegt haben, und ignoriert alle externen Einstellungen. Da das SDK bei beiden eine Ausnahme auslöst `endpoint` und `endpointMode` im Client Builder aufgerufen wird, verwendet das SDK den Endpunktwert der von Ihnen verwendeten Methode.
1. Wenn Sie keinen Wert im Code festlegen, sucht das SDK nach einer externen Konfiguration — zuerst nach Systemeigenschaften und dann nach einer Einstellung in der Konfigurationsdatei.
1. Das SDK sucht zunächst nach einem Endpunktwert. Wenn ein Wert gefunden wird, wird er verwendet.
1. Wenn das SDK immer noch keinen Wert gefunden hat, sucht das SDK nach Einstellungen für den Endpunktmodus.
1. Wenn das SDK schließlich keine externen Einstellungen findet und Sie den Metadaten-Client nicht im Code konfiguriert haben, verwendet das SDK den IPv4 Wert von`http://169.254.169.254`.
### IMDSv2
Amazon EC2 definiert zwei Ansätze für den Zugriff auf Instance-Metadaten:
+ Instance-Metadaten-Service Version 1 (IMDSv1) — Anforderungs-/Antwort-Ansatz
+ Instanz-Metadatendienst Version 2 (IMDSv2) — Sitzungsorientierter Ansatz
In der folgenden Tabelle wird verglichen, wie Java mit SDKs IMDS funktioniert.
****
| v1 | v2 |
| --- | --- |
| IMDSv2 wird standardmäßig verwendet | Benutzt immer IMDSv2 |
| Versucht, für jede Anfrage ein Sitzungstoken abzurufen, und greift darauf zurück, IMDSv1 wenn ein Sitzungstoken nicht abgerufen werden kann | Speichert ein Sitzungstoken in einem internen Cache, der für mehrere Anfragen wiederverwendet wird |
Das SDK for Java 2.x unterstützt nur IMDSv2 und greift nicht darauf IMDSv1 zurück.
## Unterschiede in der Konfiguration
In der folgenden Tabelle sind die unterschiedlichen Konfigurationsoptionen aufgeführt.
****
| Konfiguration | v1 | v2 |
| --- | --- | --- |
| Erneute Versuche | Konfiguration nicht verfügbar | Konfigurierbar über die Builder-Methode retryPolicy(...) |
| HTTP | Verbindungs-Timeout, konfigurierbar über die AWS\$1METADATA\$1SERVICE\$1TIMEOUT Umgebungsvariable. Die Standardeinstellung ist 1 Sekunde. | Die Konfiguration ist verfügbar, indem ein HTTP-Client an die Builder-Methode übergeben wirdhttpClient(...). Das Standard-Verbindungstimeout für HTTP-Clients beträgt 2 Sekunden. |
### Beispiel für eine v2-HTTP-Konfiguration
Das folgende Beispiel zeigt, wie Sie den Metadaten-Client konfigurieren können. In diesem Beispiel wird das Verbindungstimeout konfiguriert und der Apache HTTP-Client verwendet.
```
SdkHttpClient httpClient = ApacheHttpClient.builder()
.connectionTimeout(Duration.ofSeconds(1))
.build();
Ec2MetadataClient imdsClient = Ec2MetadataClient.builder()
.httpClient(httpClient)
.build();
```
# Änderungen bei CloudFront Amazon-Presignierung von Version 1 zu Version 2
In diesem Thema werden die Änderungen in Amazon CloudFront von Version 1 (v1) zu Version 2 (v2) beschrieben.
## Änderungen auf hoher Ebene
****
| Änderungen | v1 | v2 |
| --- | --- | --- |
| Maven-Abhängigkeiten |
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
|
| Package name | com.amazonaws.services.cloudfront | software.amazon.awssdk.services.cloudfront |
| Klassennamen | [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 [Letzte Version](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [Letzte Version](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API-Änderungen
| Behavior | v1 | v2 |
| --- | --- | --- |
| Erstellen Sie eine vorgefertigte Anfrage | Argumente werden direkt an die API übergeben. | CannedSignerRequest cannedRequest =
CannedSignerRequest.builder()
.resourceUrl(resourceUrl)
.privateKey(privateKey)
.keyPairId(keyPairId)
.expirationDate(expirationDate)
.build();
|
| Erstellen Sie eine benutzerdefinierte Anfrage | Argumente werden direkt an die API übergeben. | CustomSignerRequest customRequest =
CustomSignerRequest.builder()
.resourceUrl(resourceUrl)
.resourceUrlPattern(resourceUrlPattern)
.privateKey(keyFile)
.keyPairId(keyPairId)
.expirationDate(expirationDate)
.activeDate(activeDate)
.ipRange(ipRange)
.build();
|
| Generieren Sie eine signierte URL (gesperrt) | String signedUrl =
CloudFrontUrlSigner.getSignedURLWithCannedPolicy(
resourceUrl, keyPairId, privateKey, expirationDate);
| CloudFrontUtilities cloudFrontUtilities =
CloudFrontUtilities.create();
SignedUrl signedUrl =
cloudFrontUtilities.getSignedUrlWithCannedPolicy(cannedRequest);
String url = signedUrl.url();
|
| Generieren Sie ein signiertes Cookie (benutzerdefiniert) | CookiesForCustomPolicy cookies =
CloudFrontCookieSigner.getCookiesForCustomPolicy(
resourceUrl, privateKey, keyPairId, expirationDate,
activeDate, ipRange);
| CloudFrontUtilities cloudFrontUtilities =
CloudFrontUtilities.create();
CookiesForCustomPolicy cookies =
cloudFrontUtilities.getCookiesForCustomPolicy(customRequest);
|
### Überarbeitete Cookie-Header in Version 2
In Java v1 liefert das Java-SDK Cookie-Header als. `Map.Entry`
```
Map.Entry signatureMap = cookies.getSignature();
String signatureKey = signatureMap.getKey(); // "CloudFront-Signature"
String signatureValue = signatureMap.getValue(); // "[SIGNATURE_VALUE]"
```
Das Java v2 SDK liefert den gesamten Header als einen einzigen`String`.
```
String signatureHeaderValue = cookies.signatureHeaderValue(); // "CloudFront-Signature=[SIGNATURE_VALUE]"
```
# Änderungen an der IAM Policy Builder-API von Version 1 zu Version 2
In diesem Thema werden die Änderungen an der IAM Policy Builder-API von Version 1 (v1) auf Version 2 (v2) beschrieben.
## Änderungen auf hoher Ebene
****
| Änderungen | v1 | v2 |
| --- | --- | --- |
| Maven-Abhängigkeiten |
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
|
| Package name | com.amazonaws.auth.policy | software.amazon.awssdk.policybuilder.iam |
| Klassennamen | [Richtlinie](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/de_de/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/de_de/sdk-for-java/latest/developer-guide/migration-iam-policy-builder.html) |
1 Letzte Version[.](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom) 2 [Letzte Version](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## API-Änderungen
****
| Einstellung | v1 | v2 |
| --- | --- | --- |
| Instanziieren Sie eine Richtlinie | Policy policy = new Policy();
| IamPolicy.Builder policyBuilder = IamPolicy.builder();
...
IamPolicy policy = policyBuilder.build();
|
| ID festlegen | policy.withtId(...);
policy.setId(...);
| policyBuilder.id(...);
|
| Version festlegen | N/A — verwendet die Standardversion von 2012-10-17 | policyBuilder.version(...);
|
| Aussage erstellen | 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()
|
| Aussage festlegen | policy.withStatements(statement);
policy.setStatements(statement);
| policyBuilder.addStatement(statement);
|
## Unterschiede beim Aufbau einer Aussage
### Aktionen
#### v1
Das v1-SDK verfügt über [`enum`Typen](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Action.html) für Serviceaktionen, die `[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)` Elemente einer Richtlinienerklärung darstellen. Die folgenden `enum` Typen sind einige Beispiele.
+ `[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)`
Das folgende Beispiel zeigt die `SendMessage` Konstante für`SQSActions`.
```
Action action = SQSActions.SendMessage;
```
In Version 1 können Sie kein `[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)` Element für eine Anweisung angeben.
#### v2
In Version 2 repräsentiert die [IamAction](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamAction.html)Schnittstelle alle Aktionen. Um ein [dienstspezifisches Aktionselement](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_action.html) anzugeben, übergeben Sie eine Zeichenfolge an die `create` Methode, wie im folgenden Code gezeigt.
```
IamAction action = IamAction.create("sqs:SendMessage");
```
Sie können a `[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)` für eine Anweisung mit v2 angeben, wie im folgenden Code gezeigt.
```
IamAction action = IamAction.create("sqs:SendMessage");
IamStatement.builder().addNotAction(action);
```
### Bedingungen
#### v1
Zur Darstellung von Anweisungsbedingungen verwendet das v1-SDK Unterklassen von [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)
Jede `Condition` Unterklasse definiert einen `enum` Vergleichstyp, der bei der Definition der Bedingung hilft. Im Folgenden wird beispielsweise ein [Vergleich einer Zeichenfolge](https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_elements_condition_operators.html#Conditions_String), die *nicht ähnlich ist*, für eine Bedingung dargestellt.
```
Condition condition = new StringCondition(StringComparisonType.StringNotLike, "key", "value");
```
#### v2
In Version 2 erstellen Sie eine Bedingung für eine Richtlinienanweisung, indem Sie eine`[IamConditionOperator](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamConditionOperator.html)`, die `enums` für alle Typen enthält, verwenden `[IamCondition](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamCondition.html)` und bereitstellen.
```
IamCondition condition = IamCondition.create(IamConditionOperator.STRING_NOT_LIKE, "key", "value");
```
### Ressourcen
#### v1
Das `[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)` Element einer Richtlinienerklärung wird durch die `[Resource](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Resource.html)` Klasse des SDK repräsentiert. Sie geben den ARN als Zeichenfolge im Konstruktor an. Die folgenden Unterklassen bieten praktische Konstruktoren.
+ [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)
+ [SQSQueueRessource](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/resources/SQSQueueResource.html)
In Version 1 können Sie ein `[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)` Element für a angeben, `[Resource](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Resource.html)` indem Sie die `withIsNotType` Methode aufrufen, wie in der folgenden Anweisung gezeigt.
```
Resource resource = new Resource("arn:aws:s3:::amzn-s3-demo-bucket").withIsNotType(true);
```
#### v2
In v2 erstellen Sie ein `[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)` Element, indem Sie der `IamResource.create` Methode einen ARN übergeben.
```
IamResource resource = IamResource.create("arn:aws:s3:::amzn-s3-demo-bucket");
```
An `[IamResource](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamResource.html)` kann als *[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)*Element festgelegt werden, wie im folgenden Snippet gezeigt.
```
IamResource resource = IamResource.create("arn:aws:s3:::amzn-s3-demo-bucket");
IamStatement.builder().addNotResource(resource);
```
`IamResource.ALL`steht für alle Ressourcen.
### Prinzipale
#### v1
Das v1-SDK bietet die folgenden `[Principal](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/policy/Principal.html)` Klassen, um Typen von Prinzipalen darzustellen, die alle Mitglieder umfassen:
+ `AllUsers`
+ `AllServices`
+ `AllWebProviders`
+ `All`
Sie können einer Anweisung kein `[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)` Element hinzufügen.
#### v2
Steht in v2 `IamPrincipal.ALL` für alle Prinzipale:
Um alle Mitglieder in anderen Typen von Prinzipalen darzustellen, verwenden Sie die `[IamPrincipalType](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/policybuilder/iam/IamPrincipalType.html)` Klassen, wenn Sie eine erstellen. `IamPrincipal`
+ `IamPrincipal.create(IamPrincipalType.AWS,"*")`für alle Benutzer.
+ `IamPrincipal.create(IamPrincipalType.SERVICE,"*")`für alle Dienste.
+ `IamPrincipal.create(IamPrincipalType.FEDERATED,"*")`für alle Webprovider.
+ `IamPrincipal.create(IamPrincipalType.CANONICAL_USER,"*")`für alle kanonischen Benutzer.
Sie können die `addNotPrincipal` Methode verwenden, um ein `[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)` Element darzustellen, wenn Sie eine Richtlinienerklärung erstellen, wie in der folgenden Anweisung gezeigt.
```
IamPrincipal principal = IamPrincipal.create(IamPrincipalType.AWS, "arn:aws:iam::444455556666:root");
IamStatement.builder().addNotPrincipal(principal);
```
# Änderungen bei der Arbeit mit DynamoDB von Version 1 zu Version 2 von AWS SDK für Java
**Topics**
+ [Unterschiede der DynamoDB-Mapping-API zwischen Version 1 und Version 2 von AWS SDK für Java](ddb-mapping.md)
+ [Dokumentieren Sie die API-Unterschiede zwischen Version 1 und Version 2 von AWS SDK für Java](dynamodb-mapping-document-api.md)
+ [Migration der Verschlüsselungsbibliothek](ddb-encryption-lib-migrate.md)
# Unterschiede der DynamoDB-Mapping-API zwischen Version 1 und Version 2 von AWS SDK für Java
Die DynamoDB-Zuordnung APIs hat sich zwischen Version 1 und Version 2 von erheblich geändert. AWS SDK für Java In Version 1 verwenden Sie den, um mit `DynamoDBMapper` Java zu arbeiten. POJOs In Version 2 verwenden Sie die `DynamoDbEnhancedClient` mit aktualisierten Methodennamen, erweiterten Schemadefinitionsoptionen und verbesserter Typsicherheit.
Zu den wichtigsten Unterschieden gehören:
+ Neue Methodennamen (z. B. `getItem` statt von`load`)
+ Explizite Erstellung eines Tabellenschemas
+ Integrierte Unterstützung für synchrone und asynchrone Operationen
+ Änderungen in der Art und Weise, wie leere Zeichenketten und Konfigurationen behandelt werden
In diesem Abschnitt werden die Änderungen der Mapping-API, Unterschiede in den Anmerkungen, Konfigurationsupdates und Migrationsanleitungen behandelt, die Ihnen beim Übergang von Version 1 `DynamoDBMapper` zu Version 2 helfen sollen`DynamoDbEnhancedClient`.
**Contents**
+ [Änderungen auf hoher Ebene in den Mapping-Bibliotheken von Version 1 zu Version 2 des SDK for Java](dynamodb-mapping-high-level.md)
+ [Unterschiede zwischen Importabhängigkeiten](dynamodb-mapping-high-level.md#dynamodb-mapping-deps)
+ [Änderungen in der DynamoDB-Zuordnung APIs zwischen Version 1 und Version 2 des SDK for Java](dynamodb-mapping-api-changes.md)
+ [Erstellen Sie einen Client](dynamodb-mapping-api-changes.md#dynamodb-mapping-api-changes-client)
+ [Zuordnung zur DynamoDB-Tabelle/zum DynamoDB-Index einrichten](dynamodb-mapping-api-changes.md#dynamodb-mapping-api-changes-mapping)
+ [Tabellenoperationen](dynamodb-mapping-api-changes.md#dynamodb-mapping-api-changes-tobleops)
+ [Ordnen Sie Klassen und Eigenschaften zu](dynamodb-mapping-api-changes.md#dynamodb-mapping-schemas)
+ [Bean-Anmerkungen](dynamodb-mapping-api-changes.md#dynamodb-mapping-schemas-annos)
+ [V2 zusätzliche Anmerkungen](dynamodb-mapping-api-changes.md#dynamodb-mapping-schemas-annos-v2-addnl)
+ [Konfiguration](dynamodb-mapping-api-changes.md#dynamodb-mapping-configuration)
+ [Konfiguration pro Vorgang](dynamodb-mapping-api-changes.md#dynamodb-mapping-configuration-per-op)
+ [Bedingungen](dynamodb-mapping-api-changes.md#dynamodb-mapping-conditionals)
+ [Typkonvertierung](dynamodb-mapping-api-changes.md#dynamodb-mapping-type-conv)
+ [Standardkonverter](dynamodb-mapping-api-changes.md#dynamodb-mapping-type-conv-defaults)
+ [Legen Sie einen benutzerdefinierten Konverter für ein Attribut fest](dynamodb-mapping-api-changes.md#dynamodb-mapping-type-conv-anno)
+ [Fügen Sie einen Typkonverter, eine Fabrik oder einen Anbieter hinzu](dynamodb-mapping-api-changes.md#dynamodb-mapping-type-conv-factory)
+ [Unterschiede im Umgang mit Zeichenketten zwischen Version 1 und Version 2 des SDK for Java](dynamodb-migration-string-handling.md)
+ [Optimistische Sperrunterschiede zwischen Version 1 und Version 2 des SDK for Java](dynamodb-migrate-optimstic-locking.md)
+ [Fluent Setter: Unterschiede zwischen Version 1 und Version 2 des SDK for Java](dynamodb-migrate-fluent-setters.md)
# Änderungen auf hoher Ebene in den Mapping-Bibliotheken von Version 1 zu Version 2 des SDK for Java
Die Namen der Mapping-Clients in den einzelnen Bibliotheken unterscheiden sich in V1 und V2:
+ V1 — Dynamo DBMapper
+ V2 — Erweiterter DynamoDB-Client
Sie interagieren mit den beiden Bibliotheken auf die gleiche Weise: Sie instanziieren ein mapper/client und stellen dann ein Java-POJO bereit APIs , das diese Elemente liest und in DynamoDB-Tabellen schreibt. Beide Bibliotheken bieten auch Anmerkungen für die Klasse des POJO, um zu steuern, wie der Client mit dem POJO umgeht.
Zu den bemerkenswerten Unterschieden beim Umstieg auf V2 gehören:
+ V2 und V1 verwenden unterschiedliche Methodennamen für die DynamoDB-Operationen auf niedriger Ebene. Beispiel:
[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/de_de/sdk-for-java/latest/developer-guide/dynamodb-mapping-high-level.html)
+ V2 bietet mehrere Möglichkeiten, Tabellenschemas zu definieren und Tabellen POJOs zuzuordnen. Sie können zwischen der Verwendung von Anmerkungen oder einem Schema wählen, das mithilfe eines Builders aus Code generiert wurde. V2 bietet auch veränderbare und unveränderliche Versionen von Schemas.
+ Bei V2 erstellen Sie als einen der ersten Schritte speziell das Tabellenschema, wohingegen in V1 das Tabellenschema nach Bedarf aus der annotierten Klasse abgeleitet wird.
+ V2 beinhaltet den [Document API-Client](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/document/EnhancedDocument.html) in der erweiterten Client-API, wohingegen V1 eine [separate](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/DynamoDB.html) API verwendet.
+ Alle APIs sind in Version V2 in synchronen und asynchronen Versionen verfügbar.
Ausführlichere Informationen zum erweiterten V2-Client finden Sie im [Abschnitt DynamoDB-Mapping](dynamodb-enhanced-client.md) in diesem Handbuch.
## Unterschiede zwischen Importabhängigkeiten
| 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 [Letzte Version](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
In Version 1 umfasst eine einzelne Abhängigkeit sowohl die DynamoDB-API auf niedriger Ebene als auch die mapping/document API, wohingegen Sie in V2 die `dynamodb-enhanced` Artefaktabhängigkeit verwenden, um auf die API zuzugreifen. mapping/document Das `dynamodb-enhanced` Modul enthält eine transitive Abhängigkeit vom Low-Level-Modul. `dynamodb`
# Änderungen in der DynamoDB-Zuordnung APIs zwischen Version 1 und Version 2 des SDK for Java
## Erstellen Sie einen Client
****
| Anwendungsfall | V1 | V2 |
| --- | --- | --- |
| Normale Instanziierung | 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();
|
| Minimale Instanziierung | AmazonDynamoDB standardClient = AmazonDynamoDBClientBuilder.standard();
DynamoDBMapper mapper = new DynamoDBMapper(standardClient);
| DynamoDbEnhancedClient enhancedClient = DynamoDbEnhancedClient.create();
|
| Mit dem Attribut Transformator \$1 | DynamoDBMapper mapper = new DynamoDBMapper(standardClient,
attributeTransformerInstance);
| DynamoDbEnhancedClient enhancedClient = DynamoDbEnhancedClient.builder()
.dynamoDbClient(standardClient)
.extensions(extensionAInstance, extensionBInstance)
.build();
|
\$1 Erweiterungen in V2 entsprechen in etwa den Attributtransformatoren in V1. Der [Verwenden Sie Erweiterungen, um DynamoDB Enhanced Client-Operationen anzupassen](ddb-en-client-extensions.md) Abschnitt enthält weitere Informationen zu Erweiterungen in V2.
## Zuordnung zur DynamoDB-Tabelle/zum DynamoDB-Index einrichten
In V1 geben Sie einen DynamoDB-Tabellennamen über eine Bean-Annotation an. In V2 erzeugt eine Factory-Methode,`table()`, eine Instanz von, `DynamoDbTable` die die Remote-DynamoDB-Tabelle darstellt. Der erste Parameter der `table()` Methode ist der DynamoDB-Tabellenname.
****
| Anwendungsfall | V1 | V2 |
| --- | --- | --- |
| Ordnen Sie die Java-POJO-Klasse der DynamoDB-Tabelle zu | @DynamoDBTable(tableName ="Customer")
public class Customer {
...
}
| DynamoDbTable customerTable = enhancedClient.table("Customer",
TableSchema.fromBean(Customer.class));
|
| Einem DynamoDB-Sekundärindex zuordnen | [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/de_de/sdk-for-java/latest/developer-guide/dynamodb-mapping-api-changes.html) Der Abschnitt im DynamoDB Developer Guide, in [dem die `query` V1-Methode](https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/DynamoDBMapper.Methods.html#DynamoDBMapper.Methods.query) beschrieben wird, enthält ein vollständiges Beispiel. | [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/de_de/sdk-for-java/latest/developer-guide/dynamodb-mapping-api-changes.html) Der [Verwenden Sie sekundäre Indizes](ddb-en-client-use-secindex.md) Abschnitt in diesem Handbuch enthält weitere Informationen. |
## Tabellenoperationen
In diesem Abschnitt werden Operationen beschrieben APIs , die sich in den meisten Standardanwendungsfällen zwischen V1 und V2 unterscheiden.
In V2 werden alle Operationen, die eine einzelne Tabelle betreffen, auf der `DynamoDbTable` Instanz aufgerufen, nicht auf dem erweiterten Client. Der erweiterte Client enthält Methoden, die auf mehrere Tabellen abzielen können.
In der folgenden *Tabelle mit dem Namen Tabellenoperationen* wird eine POJO-Instanz als `item` oder als ein bestimmter Typ bezeichnet, z. B. `customer1` In den V2-Beispielen sind die genannten Instanzen `table` das Ergebnis eines vorherigen Aufrufs`enhancedClient.table()`, der einen Verweis auf die `DynamoDbTable` Instanz zurückgibt.
Beachten Sie, dass die meisten V2-Operationen mit einem fließenden Benutzermuster aufgerufen werden können, auch wenn sie nicht angezeigt werden. Zum Beispiel
```
Customer customer = table.getItem(r → r.key(key));
or
Customer customer = table.getItem(r → r.key(k -> k.partitionValue("id").sortValue("email")))
```
Für V1-Operationen enthalten *Tabellenoperationen* (unten) einige der häufig verwendeten Formulare und nicht alle überladenen Formulare. Die `load()` Methode weist beispielsweise die folgenden Überladungen auf:
```
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)
```
Die *Tabellenoperationen* (unten) zeigen die am häufigsten verwendeten Formen:
```
mapper.load(item)
mapper.load(item, config)
```
**Tabellenoperationen**
| Anwendungsfall | V1 | V2 |
| --- | --- | --- |
| Schreiben Sie ein Java-POJO in eine DynamoDB-Tabelle **DynamoDB-Betrieb**:, `PutItem` `UpdateItem` | mapper.save(item)
mapper.save(item, config)
mapper.save(item, saveExpression, config)
In V1 bestimmen `DynamoDBMapperConfig.SaveBehavior` Annotationen, welche Low-Level-DynamoDB-Methode aufgerufen wird. Wird im Allgemeinen aufgerufen, außer wenn und verwendet `UpdateItem` wird. `SaveBehavior.CLOBBER` `SaveBehavior.PUT` Automatisch generierte Schlüssel sind ein besonderer Anwendungsfall, und gelegentlich `UpdateItem` werden beide `PutItem` verwendet. | table.putItem(putItemRequest)
table.putItem(item)
table.putItemWithResponse(item) //Returns metadata.
updateItem(updateItemRequest)
table.updateItem(item)
table.updateItemWithResponse(item) //Returns metadata.
|
| Ein Element aus einer DynamoDB-Tabelle in ein Java-POJO lesen **DynamoDB-Betrieb:** `GetItem` | mapper.load(item)
mapper.load(item, config)
| table.getItem(getItemRequest)
table.getItem(item)
table.getItem(key)
table.getItemWithResponse(key) //Returns POJO with metadata.
|
| Löschen Sie ein Element aus einer DynamoDB-Tabelle **DynamoDB-Betrieb:** `DeleteItem` | mapper.delete(item, deleteExpression, config)
| table.deleteItem(deleteItemRequest)
table.deleteItem(item)
table.deleteItem(key)
|
| Fragen Sie eine DynamoDB-Tabelle oder einen sekundären Index ab und geben Sie eine paginierte Liste zurück **DynamoDB-Betrieb:** `Query` | mapper.query(Customer.class, queryExpression)
mapper.query(Customer.class, queryExpression,
mapperConfig)
| table.query(queryRequest)
table.query(queryConditional)
Verwenden Sie die zurückgegebenen Daten `PageIterable.stream()` (verzögertes Laden) für Synchronisationsantworten und `PagePublisher.subscribe()` für asynchrone Antworten |
| Eine DynamoDB-Tabelle oder einen sekundären Index abfragen und eine Liste zurückgeben **DynamoDB-Betrieb:** `Query` | mapper.queryPage(Customer.class, queryExpression)
mapper.queryPage(Customer.class, queryExpression,
mapperConfig)
| table.query(queryRequest)
table.query(queryConditional)
Verwenden Sie die zurückgegebenen Daten `PageIterable.items()` (verzögertes Laden) für Synchronisationsantworten und `PagePublisher.items.subscribe()` für asynchrone Antworten |
| Scannen Sie eine DynamoDB-Tabelle oder einen sekundären Index und geben Sie eine paginierte Liste zurück **DynamoDB-Betrieb:** `Scan` | mapper.scan(Customer.class, scanExpression)
mapper.scan(Customer.class, scanExpression,
mapperConfig)
| table.scan()
table.scan(scanRequest)
Verwenden Sie die zurückgegebenen Daten `PageIterable.stream()` (verzögertes Laden) für Synchronisationsantworten und `PagePublisher.subscribe()` für asynchrone Antworten |
| Eine DynamoDB-Tabelle oder einen sekundären Index scannen und eine Liste zurückgeben **DynamoDB-Betrieb:** `Scan` | mapper.scanPage(Customer.class, scanExpression)
mapper.scanPage(Customer.class, scanExpression,
mapperConfig)
| table.scan()
table.scan(scanRequest)
Verwenden Sie die zurückgegebenen Daten `PageIterable.items()` (verzögertes Laden) für Synchronisationsantworten und `PagePublisher.items.subscribe()` für asynchrone Antworten |
| Lesen Sie mehrere Elemente aus mehreren Tabellen in einem Stapel **DynamoDB-Betrieb:** `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.
|
| Schreiben Sie mehrere Elemente in einem Stapel in mehrere Tabellen **DynamoDB-Betrieb:** `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()))
|
| Löschen Sie mehrere Elemente aus mehreren Tabellen in einem Stapel **DynamoDB-Betrieb:** `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()))
|
| Schreiben/löschen Sie mehrere Elemente in einem Stapel **DynamoDB-Betrieb:** `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()))
|
| Führen Sie einen transaktionalen Schreibvorgang durch **DynamoDB-Betrieb:** `TransactWriteItems` | mapper.transactionWrite(transactionWriteRequest)
| enhancedClient.transactWriteItems(transasctWriteItemsRequest)
|
| Führen Sie einen transaktionalen Lesevorgang durch **DynamoDB-Betrieb:** `TransactGetItems` | mapper.transactionLoad(transactionLoadRequest)
| enhancedClient.transactGetItems(transactGetItemsRequest)
|
| Ruft die Anzahl der übereinstimmenden Elemente einer Abfrage ab **DynamoDB-Betrieb**: mit `Query` `Select.COUNT` | 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();
|
| Ermittelt die Anzahl der übereinstimmenden Elemente eines Scans **DynamoDB-Betrieb**: mit `Scan` `Select.COUNT` | 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();
|
| Erstellen Sie eine Tabelle in DynamoDB, die der POJO-Klasse entspricht **DynamoDB-Betrieb:** `CreateTable` | mapper.generateCreateTableRequest(Customer.class)
Die vorherige Anweisung generiert eine Low-Level-Anforderung zur Tabellenerstellung; Benutzer müssen den DynamoDB-Client aufrufen`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()));
|
| Führen Sie einen parallel Scan in DynamoDB durch **DynamoDB-Operation:** `Scan` mit `Segment` und Parametern `TotalSegments` | mapper.parallelScan(Customer.class,
scanExpression,
numTotalSegments)
| Benutzer müssen die Worker-Threads verwalten und jedes Segment aufrufen`scan`: table.scan(r -> r.segment(0).totalSegments(5))
|
| Integrieren Sie Amazon S3 mit DynamoDB, um intelligente S3-Links zu speichern | mapper.createS3Link(bucket, key)
mapper.getS3ClientCache()
| Wird nicht unterstützt, da es Amazon S3 und DynamoDB verbindet. |
## Ordnen Sie Klassen und Eigenschaften zu
Sowohl in V1 als auch in V2 ordnen Sie Klassen Tabellen mithilfe von Anmerkungen im Bean-Stil zu. V2 bietet auch [andere Möglichkeiten, Schemas für bestimmte Anwendungsfälle zu definieren](ddb-en-client-adv-features.md#ddb-en-client-adv-features-schm-overview), z. B. die Arbeit mit unveränderlichen Klassen.
### Bean-Anmerkungen
Die folgende Tabelle zeigt die entsprechenden Bean-Annotationen für einen bestimmten Anwendungsfall, die in V1 und V2 verwendet werden. Ein `Customer` Klassenszenario wird verwendet, um Parameter zu veranschaulichen.
Anmerkungen — ebenso wie Klassen und Aufzählungen — in V2 folgen der Camel-Case-Konvention und verwenden '', nicht 'DynamoDB'. DynamoDb
| Anwendungsfall | V1 | V2 |
| --- | --- | --- |
| Klasse der Tabelle zuordnen | @DynamoDBTable (tableName ="CustomerTable")
| @DynamoDbBean
@DynamoDbBean(converterProviders = {...})
Der Tabellenname wird beim Aufrufen der DynamoDbEnhancedClient\$1table() Methode definiert. |
| Benennen Sie ein Klassenmitglied als Tabellenattribut | @DynamoDBAttribute(attributeName = "customerName")
| @DynamoDbAttribute("customerName") |
| Die Benennung eines Klassenmitglieds ist ein Schlüssel hash/partition | @DynamoDBHashKey
| @DynamoDbPartitionKey
|
| Die Benennung eines Klassenmitglieds ist ein Schlüssel range/sort | @DynamoDBRangeKey
| @DynamoDbSortKey
|
| Ein Klassenmitglied als sekundären Index-Hash-/Partitionsschlüssel bezeichnen | @DynamoDBIndexHashKey
| @DynamoDbSecondaryPartitionKey
|
| Ein Klassenmitglied als sekundären Indexbereich/Sortierschlüssel bezeichnen | @DynamoDBIndexRangeKey
| @DynamoDbSecondarySortKey
|
| Ignorieren Sie dieses Klassenmitglied bei der Zuordnung zu einer Tabelle | @DynamoDBIgnore
| @DynamoDbIgnore
|
| Benennen Sie ein Klassenmitglied als automatisch generiertes UUID-Schlüsselattribut | @DynamoDBAutoGeneratedKey
| @DynamoDbAutoGeneratedUuid
Die Erweiterung, die dies bereitstellt, wird standardmäßig nicht geladen. Sie müssen die Erweiterung zu Client Builder hinzufügen. |
| Kennzeichnen Sie ein Klassenmitglied als automatisch generiertes Zeitstempelattribut | @DynamoDBAutoGeneratedTimestamp
| @DynamoDbAutoGeneratedTimestampAttribute
Die Erweiterung, die dies bereitstellt, wird standardmäßig nicht geladen. Sie müssen die Erweiterung zu Client Builder hinzufügen. |
| Kennzeichnen Sie ein Klassenmitglied als automatisch inkrementiertes Versionsattribut | @DynamoDBVersionAttribute
| @DynamoDbVersionAttribute
Die Erweiterung, die dies bereitstellt, wird automatisch geladen. |
| Weisen Sie einem Klassenmitglied zu, für das eine benutzerdefinierte Konvertierung erforderlich ist | @DynamoDBTypeConverted
| @DynamoDbConvertedBy
|
| Legen Sie ein Klassenmitglied fest, das mit einem anderen Attributtyp gespeichert werden soll | @DynamoDBTyped()
| Verwenden Sie eine `AttributeConverter` Implementierung. V2 bietet viele integrierte Konverter für gängige Java-Typen. Sie können auch Ihr eigenes benutzerdefiniertes `AttributeConverter` oder implementieren`AttributeConverterProvider`. Siehe [Steuern Sie die Attributkonvertierung](ddb-en-client-adv-features-conversion.md) in diesem Handbuch. |
| Bestimmen Sie eine Klasse, die in ein DynamoDB-Dokument (Dokument im JSON-Stil) oder Unterdokument serialisiert werden kann | @DynamoDBDocument
| Verwenden Sie die erweiterte Dokument-API. Weitere Informationen finden Sie in den folgenden Ressourcen:[\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/de_de/sdk-for-java/latest/developer-guide/dynamodb-mapping-api-changes.html) |
### V2 zusätzliche Anmerkungen
| Anwendungsfall | V1 | V2 |
| --- | --- | --- |
| Bestimmen Sie ein Klassenmitglied, das nicht als NULL-Attribut gespeichert werden soll, wenn der Java-Wert Null ist | – | @DynamoDbIgnoreNulls
|
| Bestimmen Sie ein Klassenmitglied als leeres Objekt, wenn alle Attribute Null sind | – | @DynamoDbPreserveEmptyObject
|
| Legen Sie eine spezielle Aktualisierungsaktion für ein Klassenmitglied fest | – | @DynamoDbUpdateBehavior
|
| Bestimmen Sie eine unveränderliche Klasse | – | @DynamoDbImmutable
|
| Kennzeichnen Sie ein Klassenmitglied als automatisch inkrementiertes Zählerattribut | – | @DynamoDbAtomicCounter
Die Erweiterung, die diese Funktionalität bereitstellt, wird automatisch geladen. |
## Konfiguration
In V1 steuern Sie im Allgemeinen bestimmte Verhaltensweisen, indem Sie eine Instanz von `DynamoDBMapperConfig` verwenden. Sie können das Konfigurationsobjekt entweder angeben, wenn Sie den Mapper erstellen oder wenn Sie eine Anfrage stellen. In V2 ist die Konfiguration spezifisch für das Anforderungsobjekt für den Vorgang.
| Anwendungsfall | V1 | Standard in V1 | V2 |
| --- | --- | --- | --- |
| | DynamoDBMapperConfig.builder()
| | |
| Strategie zur load/write Wiederholung von Batch | .withBatchLoadRetryStrategy(loadRetryStrategy)
.withBatchWriteRetryStrategy(writeRetryStrategy)
| Fehlgeschlagene Artikel erneut versuchen | Konfigurieren Sie die Wiederholungsstrategie für das Basisprodukt. DynamoDBClient Weitere Informationen finden Sie [Konfigurieren Sie das Wiederholungsverhalten in der AWS SDK for Java 2.x](retry-strategy.md) in diesem Handbuch. |
| Konsistente Lesevorgänge | .withConsistentReads(CONSISTENT)
| EVENTUAL | Standardmäßig ist der Wert für konsistente Lesevorgänge für Lesevorgänge falsch. Überschreiben .consistentRead(true) Sie mit im Anforderungsobjekt. |
| Konvertierungsschema mit Gruppen von Marshallern/Unmarshallern | .withConversionSchema(conversionSchema)
Statische Implementierungen bieten Abwärtskompatibilität mit älteren Versionen. | V2\$1COMPATIBLE | Nicht zutreffend. Dies ist ein veraltetes Feature, das sich darauf bezieht, wie die frühesten Versionen von DynamoDB (V1) Datentypen gespeichert haben. Dieses Verhalten wird im erweiterten Client nicht beibehalten. Ein Beispiel für ein Verhalten in DynamoDB V1 ist das Speichern von Booleschen Werten als Zahl statt als Boolean. |
| Tabellennamen | .withObjectTableNameResolver()
.withTableNameOverride()
.withTableNameResolver()
Statische Implementierungen bieten Abwärtskompatibilität mit älteren Versionen | verwende Anmerkungen oder Vermutungen aus der Klasse | Der Tabellenname wird beim Aufrufen der `DynamoDbEnhancedClient#table()` Methode definiert. |
| Strategie beim Laden der Seitennummerierung | .withPaginationLoadingStrategy(strategy)
Die Optionen sind: LAZY\$1`LOADING`, oder `EAGER_LOADING` `ITERATION_ONLY` | LAZY\$1LOADING | [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/de_de/sdk-for-java/latest/developer-guide/dynamodb-mapping-api-changes.html) |
| Erfassung von Metriken anfordern | .withRequestMetricCollector(collector)
| null | Verwenden Sie metricPublisher() inClientOverrideConfiguration, wenn Sie den standardmäßigen DynamoDB-Client erstellen. |
| Verhalten speichern | .withSaveBehavior(SaveBehavior.CLOBBER)
Die Optionen sind `UPDATE``CLOBBER`,`PUT`,`APPEND_SET`, oder`UPDATE_SKIP_NULL_ATTRIBUTES`. | UPDATE | In V2 rufen Sie `putItem()` oder `updateItem()` explizit auf. `CLOBBER or PUT`: Die entsprechende Aktion in Version 2 ist das Aufrufen`putItem()`. Es gibt keine spezifische `CLOBBER` Konfiguration. `UPDATE`: Entspricht `updateItem()` `UPDATE_SKIP_NULL_ATTRIBUTES`: Entspricht`updateItem()`. Steuern Sie das Aktualisierungsverhalten mit der Anforderungseinstellung `ignoreNulls` und der Annotation/dem Tag`DynamoDbUpdateBehavior`. `APPEND_SET`: Nicht unterstützt |
| Geben Sie Converter Factory ein | .withTypeConverterFactory(typeConverterFactory)
| Wandler vom Typ Standard | Auf die Bohne legen, indem Sie @DynamoDbBean(converterProviders = {ConverterProvider.class,
DefaultAttributeConverterProvider.class}) |
### Konfiguration pro Vorgang
In Version 1 sind einige Operationen, wie z. B.`query()`, über ein Ausdrucksobjekt, das der Operation übergeben wird, in hohem Maße konfigurierbar. Beispiel:
```
DynamoDBQueryExpression emailBwQueryExpr = new DynamoDBQueryExpression()
.withRangeKeyCondition("Email",
new Condition()
.withComparisonOperator(ComparisonOperator.BEGINS_WITH)
.withAttributeValueList(
new AttributeValue().withS("my")));
mapper.query(Customer.class, emailBwQueryExpr);
```
In V2 verwenden Sie kein Konfigurationsobjekt, sondern legen Parameter für das Anforderungsobjekt mithilfe eines Builders fest. Beispiel:
```
QueryEnhancedRequest emailBw = QueryEnhancedRequest.builder()
.queryConditional(QueryConditional
.sortBeginsWith(kb -> kb
.sortValue("my"))).build();
customerTable.query(emailBw);
```
## Bedingungen
In V2 werden Bedingungs- und Filterausdrücke mithilfe eines `Expression` Objekts ausgedrückt, das die Bedingung und die Zuordnung von Namen und Filtern kapselt.
| Anwendungsfall | Operationen | V1 | V2 |
| --- | --- | --- | --- |
| Erwartete Attributbedingungen | speichern (), löschen (), abfragen (), scannen () | new DynamoDBSaveExpression()
.withExpected(Collections.singletonMap(
"otherAttribute", new ExpectedAttributeValue(false)))
.withConditionalOperator(ConditionalOperator.AND);
| Veraltet; stattdessen verwendenConditionExpression. |
| Bedingungsausdruck | löschen () | 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();
|
| Filterausdruck | abfragen (), scannen () | 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();
|
| Bedingungsausdruck für die Abfrage | abfrage () | queryExpression.withKeyConditionExpression()
| QueryConditional keyEqual = QueryConditional.keyEqualTo(b -> b
.partitionValue("movie01"));
QueryEnhancedRequest tableQuery = QueryEnhancedRequest.builder()
.queryConditional(keyEqual)
.build();
|
## Typkonvertierung
### Standardkonverter
In V2 bietet das SDK eine Reihe von Standardkonvertern für alle gängigen Typen. Sie können Typkonverter sowohl auf der Gesamtanbieterebene als auch für ein einzelnes Attribut ändern. Eine Liste der verfügbaren Konverter finden Sie in der [AttributeConverter](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/AttributeConverter.html)API-Referenz.
### Legen Sie einen benutzerdefinierten Konverter für ein Attribut fest
In V1 können Sie eine Getter-Methode mit annotieren, `@DynamoDBTypeConverted` um die Klasse anzugeben, die zwischen dem Java-Attributtyp und einem DynamoDB-Attributtyp konvertiert. Beispielsweise kann eine, `CurrencyFormatConverter` die zwischen einem `Currency` Java-Typ und einem DynamoDB-String konvertiert, angewendet werden, wie im folgenden Codeausschnitt gezeigt.
```
@DynamoDBTypeConverted(converter = CurrencyFormatConverter.class)
public Currency getCurrency() { return currency; }
```
Das V2-Äquivalent des vorherigen Snippets ist unten dargestellt.
```
@DynamoDbConvertedBy(CurrencyFormatConverter.class)
public Currency getCurrency() { return currency; }
```
**Anmerkung**
In V1 können Sie die Anmerkung auf das Attribut selbst, einen Typ oder eine benutzerdefinierte Anmerkung anwenden. V2 unterstützt das Anwenden der Anmerkung nur auf den Getter.
### Fügen Sie einen Typkonverter, eine Fabrik oder einen Anbieter hinzu
In V1 können Sie Ihren eigenen Satz von Typkonvertern bereitstellen oder die Typen, die Ihnen wichtig sind, überschreiben, indem Sie der Konfiguration eine Typkonverter-Factory hinzufügen. Die Typkonverter-Factory wird erweitert`DynamoDBTypeConverterFactory`, und Überschreibungen werden vorgenommen, indem ein Verweis auf den Standardsatz abgerufen und dieser erweitert wird. Der folgende Ausschnitt zeigt, wie das geht.
```
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 bietet durch die Anmerkung ähnliche Funktionen. `@DynamoDbBean` Sie können ein einzelnes `AttributeConverterProvider` oder eine Kette von bestellten `AttributeConverterProvider` s angeben. Beachten Sie, dass Sie, wenn Sie Ihre eigene Kette von Anbietern für Attributkonverter angeben, den Standardkonverter-Anbieter überschreiben und ihn in die Kette aufnehmen müssen, um die zugehörigen Attributkonverter verwenden zu können.
```
@DynamoDbBean(converterProviders = {
ConverterProvider1.class,
ConverterProvider2.class,
DefaultAttributeConverterProvider.class})
public class Customer {
...
}
```
Der Abschnitt zur [Attributkonvertierung](ddb-en-client-adv-features-conversion.md#ddb-en-client-adv-features-conversion-example) in diesem Handbuch enthält ein vollständiges Beispiel für V2.
# Unterschiede im Umgang mit Zeichenketten zwischen Version 1 und Version 2 des SDK for Java
V1 und V2 behandeln leere Zeichenketten unterschiedlich, wenn Daten an DynamoDB gesendet werden:
+ **V1**: Konvertiert leere Zeichenketten vor dem Senden an DynamoDB in Nullwerte (was zu keinem Attribut führt)
+ **V2**: Sendet leere Zeichenketten als tatsächliche leere Zeichenkettenwerte an DynamoDB
**Wichtig**
Wenn Sie nach der Migration zu V2 keine leeren Zeichenketten in DynamoDB speichern möchten, müssen Sie benutzerdefinierte Konverter implementieren. Ohne benutzerdefinierte Konverter speichert V2 leere Zeichenfolgen als tatsächliche leere Zeichenkettenattribute in Ihren DynamoDB-Elementen, was sich von dem Verhalten von V1 unterscheidet, diese Attribute vollständig wegzulassen.
**Example benutzerdefinierter Konverter für V2, der ein leeres Zeichenkettenattribut in Null umwandelt**
```
/**
* 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;
}
}
```
# Optimistische Sperrunterschiede zwischen Version 1 und Version 2 des SDK for Java
Sowohl V1 als auch V2 implementieren optimistisches Sperren mit einer Attributanmerkung, die eine Eigenschaft in Ihrer Bean-Klasse markiert, um die Versionsnummer zu speichern.
**Unterschiede im optimistischen Sperrverhalten**
| | V1 | V2 |
| --- | --- | --- |
| Anmerkung zur Bean-Klasse | @DynamoDBVersionAttribute | @DynamoDbVersionAttribute(Beachten Sie, dass V2 ein kleingeschriebenes „b“ verwendet) |
| Erstes Speichern | Das Versionsnummer-Attribut ist auf 1 gesetzt. | Der Startwert für das auf festgelegte Versionsattribut`@DynamoDbVersionAttribute(startAt = X)`. Der Standardwert ist 0. |
| Aktualisierung | Das Versionsnummernattribut wird um 1 erhöht, wenn die bedingte Prüfung sicherstellt, dass die Versionsnummer des zu aktualisierenden Objekts mit der Nummer in der Datenbank übereinstimmt. | Das Versionsnummernattribut wird erhöht, wenn bei der bedingten Überprüfung überprüft wird, ob die Versionsnummer des zu aktualisierenden Objekts mit der Nummer in der Datenbank übereinstimmt. Das Versionsnummernattribut wird um die mit festgelegte `incrementBy` Option erhöht. `@DynamoDbVersionAttribute(incrementBy = X)` Der Standardwert ist 1. |
| Delete | DynamoDBMapperfügt eine bedingte Überprüfung hinzu, ob die Versionsnummer des gelöschten Objekts mit der Versionsnummer in der Datenbank übereinstimmt. | V2 fügt nicht automatisch Bedingungen für die Löschvorgänge hinzu. Sie müssen Bedingungsausdrücke manuell hinzufügen, wenn Sie das Löschverhalten steuern möchten. Im folgenden Beispiel `recordVersion` ist das Versionsattribut der Bean dargestellt. // 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);
|
| Transaktionales Schreiben mit einer Zustandsprüfung | Sie können eine Bean-Klasse, die mit einer Anmerkung versehen ist, nicht @DynamoDBVersionAttribute in einer Methode verwenden. addConditionCheck | Sie können eine Bean-Klasse mit der @DynamoDbVersionAttribute Anmerkung in einer addConditionCheck Builder-Methode für eine transactWriteItems Anfrage verwenden. |
| Deaktivieren | Deaktivieren Sie optimistisches Sperren, indem Sie den DynamoDBMapperConfig.SaveBehavior Aufzählungswert von UPDATE bis CLOBBER ändern. | Verwenden Sie die `@DynamoDbVersionAttribute` Anmerkung nicht. |
# Fluent Setter: Unterschiede zwischen Version 1 und Version 2 des SDK for Java
Sie können es POJOs mit Fluent-Settern in der DynamoDB-Mapping-API für V1 und mit V2 seit Version 2.30.29 verwenden.
Das folgende POJO gibt beispielsweise eine Instanz aus der Methode zurück: `Customer` `setName`
```
// 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;
}
}
```
Wenn Sie jedoch eine Version von V2 vor 2.30.29 verwenden, wird eine `Customer` Instanz mit dem Wert von `setName` zurückgegeben. `name` `null`
```
// 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.
}
}
```
# Dokumentieren Sie die API-Unterschiede zwischen Version 1 und Version 2 von AWS SDK für Java
Die Dokument-API unterstützt die Arbeit mit Dokumenten im JSON-Stil als einzelne Elemente in einer DynamoDB-Tabelle. Die V1-Dokument-API hat eine entsprechende API in V2, aber anstatt wie in V1 einen separaten Client für die Dokument-API zu verwenden, integriert V2 Dokument-API-Funktionen in den erweiterten DynamoDB-Client.
In V1 stellt die [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)Klasse einen unstrukturierten Datensatz aus einer DynamoDB-Tabelle dar. In V2 wird ein unstrukturierter Datensatz durch eine Instanz der Klasse dargestellt. [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) Beachten Sie, dass Primärschlüssel im Tabellenschema für V2 und im Element selbst in V1 definiert sind.
In der folgenden Tabelle werden die Unterschiede zwischen den Dokumenten APIs in V1 und V2 verglichen.
| Anwendungsfall | V1 | V2 |
| --- |--- |--- |
| Erstellen Sie einen Dokumentenclient | 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.
|
| Verweisen Sie auf eine Tabelle | 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** |
| --- |
| Element einfügen | 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);
|
| Element abrufen | 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** |
| --- |
| Konvertiert eine JSON-Struktur, um sie mit der Document API zu verwenden | // 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());
|
| Geben Sie JSON ein | documentTable.putItem(item)
| documentTable.putItem(document);
|
| Lesen Sie JSON | GetItemOutcome outcome = //Get item.
String jsonPerson = outcome.getItem().toJSON();
| String jsonPerson = documentTable.getItem(Key.builder()
.partitionValue(50).build())
.fromJson();
|
## API-Referenz und Anleitungen für das Dokument APIs
| | V1 | V2 |
| --- | --- | --- |
| API-Referenz | [API-Referenz](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/package-summary.html) | [API-Referenz](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/enhanced/dynamodb/document/package-summary.html) |
| Leitfaden zur Dokumentation | [Entwicklerhandbuch für Amazon DynamoDB](https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/JavaDocumentAPIItemCRUD.html) | [Verbesserte Dokument-API](ddb-en-client-doc-api.md) (dieser Leitfaden) |
# V1 Xpec API zur V2 Expressions API
Die in Version 1 verfügbare Expression Specification (Xspec) -API, mit der Ausdrücke für dokumentorientierte Daten erstellt werden können, ist in Version 2 nicht verfügbar. V2 verwendet die Expression API, die sowohl mit dokumentenorientierten Daten als auch mit zugewiesenen Daten funktioniert. object-to-item
****
| | V1 | V2 |
| --- | --- | --- |
| API-Name | API für Ausdrucksspezifikationen (Xspec) | Ausdrucks-API |
| Funktioniert mit | [Methoden der [Document-API-Tabellenklasse](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/Table.html) wie [updateItem und scan](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-)](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/dynamodbv2/document/Table.html#scan-com.amazonaws.services.dynamodbv2.xspec.ScanExpressionSpec-) | Beide Versionen APIs von DynamoDB Enhanced Client: [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/de_de/sdk-for-java/latest/developer-guide/ddb-v1-xspec-migrate.html) Für beide Typen von APIs, nachdem Sie eine [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)Instanz erworben haben: [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/de_de/sdk-for-java/latest/developer-guide/ddb-v1-xspec-migrate.html) Sie verwenden Ausdrücke in `DynamoDbTable` Methoden, wenn Sie Anforderungsobjekte erstellen. Zum Beispiel in der `filterExpression` Methode der [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) |
| Ressourcen | [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/de_de/sdk-for-java/latest/developer-guide/ddb-v1-xspec-migrate.html) | [Informationen zu Ausdrücken](ddb-en-client-expressions.md) in diesem Java-Entwicklerhandbuch |
# Migration der Verschlüsselungsbibliothek
Informationen zur Migration der Verschlüsselungsbibliothek für DynamoDB, damit sie mit Version 2 des Java SDK funktioniert, finden Sie im [Amazon DynamoDB](https://docs.aws.amazon.com/database-encryption-sdk/latest/devguide/ddb-java-migrate.html) Encryption Client Developer Guide.
# Änderungen beim automatischen Batching von Amazon SQS SQS-Anfragen von Version 1 zu Version 2
In diesem Thema werden die Änderungen beim automatischen Batching von Anfragen für Amazon SQS zwischen Version 1 und Version 2 von beschrieben. AWS SDK für Java
## Änderungen auf hoher Ebene
AWS SDK für Java 1.x führt die clientseitige Pufferung mithilfe einer separaten `[AmazonSQSBufferedAsyncClient](https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/sqs/buffered/AmazonSQSBufferedAsyncClient.html)` Klasse durch, die eine explizite Initialisierung für das Batching von Anfragen erfordert.
Das AWS SDK for Java 2.x vereinfacht und erweitert die Pufferfunktionalität mit dem. `[SqsAsyncBatchManager](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/batchmanager/SqsAsyncBatchManager.html)` Die Implementierung dieser Schnittstelle bietet automatische Batchfunktionen für Anfragen, die direkt in den Standard integriert sind. `[SqsAsyncClient](https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sqs/SqsAsyncClient.html)` Weitere Informationen zu Version 2 finden Sie unter dem [Verwenden Sie die automatische Batchverarbeitung von Anfragen für Amazon SQS mit dem AWS SDK for Java 2.x](sqs-auto-batch.md) Thema in diesem Handbuch. `SqsAsyncBatchManager`
| Änderungen | v1 | v2 |
| --- | --- | --- |
| Maven-Abhängigkeiten |
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
|
| Namen von Paketen | com.amazonaws.services.sqs.buffered | software.amazon.awssdk.services.sqs.batchmanager |
| Klassennamen | `[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 [Letzte Version](https://central.sonatype.com/artifact/com.amazonaws/aws-java-sdk-bom). 2 [Letzte Version](https://central.sonatype.com/artifact/software.amazon.awssdk/bom).
## Automatisches Batching von SQS-Anfragen verwenden
| Änderungen | v1 | v2 |
| --- | --- | --- |
| Erstellen Sie einen Batch-Manager | AmazonSQSAsync sqsAsync = new AmazonSQSAsyncClient();
AmazonSQSAsync bufferedSqs = new
AmazonSQSBufferedAsyncClient(sqsAsync);
| SqsAsyncClient asyncClient = SqsAsyncClient.create();
SqsAsyncBatchManager sqsAsyncBatchManager =
asyncClient.batchManager();
|
| Erstellen Sie einen Batch-Manager mit benutzerdefinierter Konfiguration | 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();
|
| Senden Sie Nachrichten | Future sendResultFuture =
bufferedSqs.sendMessageAsync(new SendMessageRequest()
.withQueueUrl(queueUrl)
.withMessageBody(body));
| CompletableFuture sendCompletableFuture =
sqsAsyncBatchManager.sendMessage(
SendMessageRequest.builder()
.queueUrl(queueUrl)
.messageBody(body)
.build());
|
| Nachrichten löschen | Future deletResultFuture =
bufferedSqs.deleteMessageAsync(new DeleteMessageRequest()
.withQueueUrl(queueUrl));
| CompletableFuture deleteResultCompletableFuture
= sqsAsyncBatchManager.deleteMessage(
DeleteMessageRequest.builder()
.queueUrl(queueUrl)
.build());
|
| Sichtbarkeit von Nachrichten ändern | Future changeVisibilityResultFuture =
bufferedSqs.changeMessageVisibilityAsync
(new ChangeMessageVisibilityRequest()
.withQueueUrl(queueUrl)
.withVisibilityTimeout(20));
| CompletableFuture changeResponseCompletableFuture
= sqsAsyncBatchManager.changeMessageVisibility(
ChangeMessageVisibilityRequest.builder()
.queueUrl(queueUrl)
.visibilityTimeout(20)
.build());
|
| Empfangen Sie Nachrichten | ReceiveMessageResult receiveResult =
bufferedSqs.receiveMessage(
new ReceiveMessageRequest()
.withQueueUrl(queueUrl));
| CompletableFuture
responseCompletableFuture = sqsAsyncBatchManager.receiveMessage(
ReceiveMessageRequest.builder()
.queueUrl(queueUrl)
.build());
|
## Unterschiede beim asynchronen Rückgabetyp
| Änderungen | v1 | v2 |
| --- | --- | --- |
| Rückgabetyp | Future | CompletableFuture |
| Rückruf-Mechanismus | Erfordert eine AsyncHandler mit separaten onSuccess Methoden onError | Vom JDK CompletableFuture APIs bereitgestellte Verwendungen, wiewhenComplete(), thenCompose() thenApply() |
| Ausnahmeverarbeitung | Verwendet Methode AsyncHandler\$1onError() | Verwendungen, die vom JDK CompletableFuture APIs bereitgestellt werden, wieexceptionally(),handle(), oder whenComplete() |
| Abbruch | Grundlegende Unterstützung durch Future.cancel() | Durch die Kündigung eines übergeordneten Unternehmens CompletableFuture werden automatisch alle abhängigen Futures in der Kette storniert |
## Asynchrone Fertigstellung, Behandlung von Unterschieden
| Änderungen | v1 | v2 |
| --- | --- | --- |
| Implementierung des Response-Handlers | 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());
}
}
});
|
## Wichtige Konfigurationsparameter
****
| Parameter | v1 | v2 |
| --- | --- | --- |
| Maximale Stapelgröße | maxBatchSize(standardmäßig 10 Anfragen pro Stapel) | maxBatchSize(standardmäßig 10 Anfragen pro Stapel) |
| Wartezeit für Batch | maxBatchOpenMs(Standard 200 ms) | sendRequestFrequency(Standard 200 ms) |
| Timeout für Sichtbarkeit | visibilityTimeoutSeconds(-1 für die Standardeinstellung in der Warteschlange) | receiveMessageVisibilityTimeout(Standardeinstellung für die Warteschlange) |
| Minimale Wartezeit | longPollWaitTimeoutSeconds(20s wann longPoll ist wahr) | receiveMessageMinWaitDuration(Standard 50 ms) |
| Nachrichtenattribute | Stellen Sie ein mit ReceiveMessageRequest | receiveMessageAttributeNames(standardmäßig keine) |
| Systemattribute | Stellen Sie ein mit ReceiveMessageRequest | receiveMessageSystemAttributeNames(standardmäßig keine) |
| Lange Umfragen | longPoll(Die Standardeinstellung ist „true“) | Wird nicht unterstützt, um zu verhindern, dass offene Verbindungen warten, bis der Server die Nachrichten sendet |
| Maximale Wartezeit für lange Abfragen | longPollWaitTimeoutSeconds(Standard 20s) | Wird nicht unterstützt, um zu verhindern, dass offene Verbindungen warten, bis der Server die Nachrichten sendet |
| Maximale Anzahl von vorab abgerufenen Empfangsstapeln, die clientseitig gespeichert werden | maxDoneReceiveBatches(10 Stapel) | Wird nicht unterstützt, da es intern verwaltet wird |
| Maximale Anzahl aktiver ausgehender Batches, die gleichzeitig verarbeitet werden | maxInflightOutboundBatches(standardmäßig 5 Batches) | Wird nicht unterstützt, da es intern verarbeitet wird |
| Maximale Anzahl aktiver Empfangsstapel, die gleichzeitig verarbeitet werden | maxInflightReceiveBatches(standardmäßig 10 Batches) | Wird nicht unterstützt, da es intern verarbeitet wird |