PutDynamoDBRecord 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-aws-nar
Beschreibung¶
Fügt Elemente auf der Grundlage von datensatzorientierten Daten in DynamoDB ein. Die Datensatzfelder werden den DynamoDB-Artikelfeldern zugeordnet, einschließlich der Partitions- und Sortierschlüssel, falls festgelegt. Je nach Anzahl der Datensätze kann der Prozessor die Einfügung in mehreren Blöcken ausführen, um die Beschränkung der DynamoDBfür das Schreiben von Blöcken zu umgehen. Dies kann zu teilweise verarbeiteten FlowFiles führen. In diesem Fall wird das FlowFile mit den erforderlichen Attributen in die „unverarbeitet“ Beziehung verschoben, um später erneut versucht zu werden, ohne die bereits ausgeführten Einfügungen zu duplizieren.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
AWS-Anmeldeinformationen-Anbieterdienst |
Der Controller Service, der verwendet wird, um AWS-Anmeldeinformationsanbieter zu erhalten |
Communications Timeout |
|
Endpoint Override URL |
Endpunkt-URL, die anstelle des AWS Standardwerts verwendet werden soll, einschließlich Schema, Host, Port und Pfad. Die AWS-Bibliotheken wählen eine Endpunkt-URL auf der Grundlage der AWS-Region aus, aber diese Eigenschaft überschreibt die ausgewählten Endpunkt-URL und ermöglicht die Verwendung mit anderen S3-kompatiblen Endpunkten. |
Region |
|
SSL Context Service |
Gibt einen optionalen SSL Context Service an, der, falls vorhanden, zum Erstellen von Verbindungen verwendet wird |
Tabellenname |
Der DynamoDB-Tabellenname. |
partition-key-attribut |
Gibt das FlowFile-Attribut an, das als Wert des Partitionsschlüssels verwendet wird, wenn Sie die Partitionsschlüsselstrategie „Partition by attribute“ verwenden. |
partition-key-field |
Legt den Namen des Partitionsschlüsselfeldes in der Tabelle DynamoDB fest. Der Partitionsschlüssel wird auch als Hash-Schlüssel bezeichnet. Abhängig von der „Partition Key Strategy“ kann der Feldwert aus dem eingehenden Datensatz oder einem generierten Datensatz stammen. |
partition-key-strategy |
Definiert die Strategie, die der Prozessor verwendet, um den eingefügten Objekten einen Partitionsschlüsselwert zuzuweisen. |
proxy-configuration-service |
Gibt den Proxy-Konfigurations-Controller Service an für die Weiterleitung von Netzwerkanforderungen festl. |
record-reader |
Gibt den Controller Service an, der für das Parsen eingehender Daten und die Bestimmung des Datenschemas verwendet werden soll. |
sort-key-field |
Legt den Namen des Sortierschlüsselfeldes in der DynamoDB-Tabelle fest. Der Sortierschlüssel wird auch als Bereichsschlüssel bezeichnet. |
sort-key-strategy |
Definiert die Strategie, die der Prozessor verwendet, um den eingefügten Objekten Sortierschlüssel zuzuweisen. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
FlowFiles werden an die Beziehung „failure“ weitergeleitet. |
success |
FlowFiles werden an die Beziehung „success“ weitergeleitet |
unprocessed |
FlowFiles werden an die Beziehung „unprocessed“ weitergeleitet, wenn DynamoDB nicht in der Lage ist, alle Elemente der Anfrage zu verarbeiten. Typische Gründe sind eine unzureichende Kapazität des Tabellendurchsatzes und die Überschreitung der maximalen Bytes pro Anfrage. Unverarbeitete FlowFiles können mit einer neuen Anfrage erneut versucht werden. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
dynamodb.chunks.processed |
Anzahl der erfolgreich in DynamoDB eingefügten Blöcke. Wenn nicht festgelegt, wird er als 0 betrachtet |
dynamodb.key.error.unprocessed |
Nicht verarbeitete Schlüssel in DynamoDB |
dynmodb.range.key.value.error |
Bereichsschlüsselfehler in DynamoDB |
dynamodb.key.error.not.found |
DynamoDB-Schlüssel nicht gefunden |
dynamodb.error.exception.message |
DynamoDB-Ausnahmemeldung |
dynamodb.error.code |
DynamoDB-Fehlercode |
dynamodb.error.message |
DynamoDB-Fehlermeldung |
dynamodb.error.service |
DynamoDB-Fehlerdienst |
dynamodb.error.retryable |
DynamoDB-Fehler ist wiederholbar |
dynamodb.error.request.id |
DynamoDB-Fehleranfrage-ID |
dynamodb.error.status.code |
DynamoDB-Fehlerstatuscode |
dynamodb.item.io.error |
IO-Ausnahmemeldung beim Erstellen eines Artikels |