PutKinesisStream 2025.5.31.15

Bundle

org.apache.nifi | nifi-aws-nar

Description

Envoie le contenu à un Amazon Kinesis spécifié. Pour envoyer des données à Kinesis, le nom du flux doit être spécifié.

Balises

amazon, aws, kinesis, put, stream

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

amazon-kinesis-stream-partition-key

L’attribut clé de la partition. Si cela n’est pas paramétrée, une valeur aléatoire est utilisée

kinesis-stream-name

Le nom du flux Kinesis

max-message-buffer-size

Taille maximale de la mémoire tampon du message en méga-octets

message-batch-size

Taille du lot pour les messages (1-500).

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 »

Écrit les attributs

Nom

Description

aws.kinesis.error.message

Message d’erreur lors de l’envoi d’un message à AWS Kinesis

aws.kinesis.error.code

Code d’erreur pour le message lors de l’envoi à AWS Kinesis

aws.kinesis.sequence.number

Numéro de séquence du message lors de l’envoi à AWS Kinesis

aws.kinesis.shard.id

Identifiant du message envoyé à AWS Kinesis

Voir aussi :