PutKinesisStream 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-aws-nar
Beschreibung¶
Sendet den Inhalt an ein angegebenes Amazon Kinesis. Um Daten an Kinesis zu senden, muss der Streamname angegeben werden.
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 |
|
amazon-kinesis-stream-partition-key |
Das Schlüsselattribut der Partition. Wenn nicht festgelegt, wird ein Zufallswert verwendet |
kinesis-stream-name |
Der Name des Kinesis-Streams |
max-message-buffer-size |
Maximale Größe des Meldungspuffers in Megabytes |
message-batch-size |
Batchgröße für Meldungen (1-500). |
proxy-configuration-service |
Gibt den Proxy-Konfigurations-Controller Service an für die Weiterleitung von Netzwerkanforderungen festl. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
FlowFiles werden an die Beziehung „failure“ weitergeleitet. |
success |
FlowFiles werden an die Beziehung „success“ weitergeleitet |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
aws.kinesis.error.message |
Fehlermeldung beim Senden einer Meldung an AWS Kinesis |
aws.kinesis.error.code |
Fehlercode für die Meldung beim Senden an AWS Kinesis |
aws.kinesis.sequence.number |
Laufende Nummer für die Meldung beim Senden an AWS Kinesis |
aws.kinesis.shard.id |
Shard-ID der Meldung, die an AWS Kinesis gesendet wurde |