PutDynamoDBRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-aws-nar

Description¶

Insère des éléments dans DynamoDB sur la base de données orientées enregistrement. Les champs d’enregistrement sont mappés vers les champs d’élément du DynamoDB, y compris les clés de partition et de tri si elles sont définies. En fonction du nombre d’enregistrements, le processeur peut exécuter l’insertion en plusieurs lots afin de contourner la limitation du DynamoDB concernant l’écriture par lots. Cela peut produire des FlowFiles partiellement traités, auquel cas le FlowFile sera transféré vers la relation « unprocessed » avec l’attribut nécessaire pour réessayer ultérieurement sans dupliquer les insertions déjà effectuées.

Balises¶

AWS amazon, DynamoDB, insérer, mettre, enregistrer

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
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.
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
partition-key-attribute	Spécifie l’attribut FlowFile qui sera utilisé comme valeur de clé de partition lors de l’utilisation de la stratégie de clé de partition « Partition by attribute ».
partition-key-field	Définit le nom du champ de clé de partition dans la table DynamoDB. La clé de partition est également appelée clé de hachage. Selon la « Partition Key Strategy », la valeur du champ peut provenir de l’enregistrement entrant ou être générée.
partition-key-strategy	Définit la stratégie utilisée par le processeur pour attribuer la valeur de la clé de partition aux éléments insérés.
service proxy-configuration	Spécifie le Controller Service de configuration proxy pour les requêtes réseau proxy.
record-reader	Spécifie le Controller Service à utiliser pour analyser les données entrantes et déterminer le schéma des données.
sort-key-field	Définit le nom du champ de la clé de tri dans la table DynamoDB. La clé de tri est également connue sous le nom de clé de gamme.
sort-key-strategy	Définit la stratégie utilisée par le processeur pour attribuer une clé de tri aux éléments insérés.

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.chunks.processed	Nombre de morceaux insérés avec succès dans DynamoDB. Si non défini, il est considéré comme étant 0.
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