PutKinesisStream 2025.10.2.19¶
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é.
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. |
Taille maximale de la mémoire tampon des messages |
Taille maximale de la mémoire tampon des messages définie avec les unités de taille de données standard |
Taille du lot de messages |
Taille du lot pour les messages (1-500). |
Region |
|
Nom du flux |
Le nom du flux Kinesis |
Clé de partition de flux |
L’attribut de la clé de partition. Si elle n’est pas définie, une valeur aléatoire est utilisée. |
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 |