PutDynamoDB 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-aws-nar
Description¶
Place un document à partir de DynamoDB sur la base d’un hachage et d’une clé d’intervalle. La table peut comporter soit un hachage et une plage, soit une clé de hachage seule. Actuellement, les clés prises en charge sont les chaînes et les nombres et la valeur peut être un document json. Dans le cas des clés de hachage et de plage, les deux clés sont nécessaires pour l’opération. Le contenu du FlowFile doit être JSON. Un FlowFile est mappé à l’attribut JSON Document spécifié dans l’élément DynamoDB.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Service des fournisseurs d’identifiants de connexion AWS |
Le Controller Service qui est utilisé pour obtenir le fournisseur d’identifiants de connexion AWS |
Éléments de lot de chaque requête (entre 1 et 50) |
Éléments à récupérer en un seul lot |
Character set of document |
Jeu de caractères des données contenues dans le document |
Délai d’expiration de la communication |
|
Endpoint Override URL |
URL du point de terminaison à utiliser à la place du point de terminaison AWS par défaut, y compris le schéma, l’hôte, le port et le chemin. Les bibliothèques AWS sélectionnent une URL de point de terminaison en fonction de la région AWS, mais cette propriété remplace l’URL de point de terminaison sélectionnée, ce qui permet une utilisation avec d’autres points de terminaison compatibles S3. |
Hash Key Name |
Nom de clé de hachage de l’élément |
Hash Key Value |
Valeur de clé de hachage de l’élément |
Hash Key Value Type |
Type de valeur de la clé de hachage de l’élément |
Attribut du document JSON |
Le document JSON à récupérer dans l’élément dynamodb (type “s” dans le schéma) |
Range Key Name |
Nom de clé d’intervalle de l’élément |
Range Key Value |
|
Range Key Value Type |
Type de valeur de clé d’intervalle de l’élément |
Region |
|
Service contextuel SSL |
Spécifie un service contextuel SSL facultatif qui, s’il est fourni, sera utilisé pour créer des connexions |
Nom de la table |
Nom de table DynamoDB |
service proxy-configuration |
Spécifie le Controller Service de configuration proxy pour les requêtes réseau proxy. |
Relations¶
Nom |
Description |
|---|---|
failure |
Les FlowFiles sont routés vers la relation d’échec |
success |
Les FlowFiles sont routés vers la relation « success » |
unprocessed |
Les FlowFiles sont routés vers la relation non traité lorsque DynamoDB n’est pas en mesure de traiter tous les éléments de la requête. Les raisons types sont une capacité de débit insuffisante de la table et un dépassement du nombre maximal d’octets par requête. Les FlowFiles non traités peuvent faire l’objet d’une nouvelle requête. |
Écrit les attributs¶
Nom |
Description |
|---|---|
dynamodb.key.error.unprocessed |
Clés DynamoDB non traitées |
dynmodb.range.key.value.error |
Erreur de clé d’intervalle DynamoDB |
dynamodb.key.error.not.found |
Clé DynamoDB introuvable |
dynamodb.error.exception.message |
Message d’exception DynamoDB |
dynamodb.error.code |
Code d’erreur DynamoDB |
dynamodb.error.message |
Message d’erreur DynamoDB |
dynamodb.error.service |
Service d’erreur DynamoDB |
dynamodb.error.retryable |
L’erreur DynamoDB peut être retentée |
dynamodb.error.request.id |
ID de requête en état d’erreur DynamoDB |
dynamodb.error.status.code |
DynamoDB error status code |
dynamodb.item.io.error |
Message d’exception IO lors de la création d’un article |