Kinesis-Beispiele mit AWS CLI - AWS Command Line Interface

Diese Dokumentation bezieht sich AWS CLI nur auf Version 1 von. Dokumentation zu Version 2 von finden Sie im Benutzerhandbuch für Version 2. AWS CLI

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Kinesis-Beispiele mit AWS CLI

Die folgenden Codebeispiele zeigen Ihnen, wie Sie AWS Command Line Interface mit Kinesis Aktionen ausführen und allgemeine Szenarien implementieren.

Aktionen sind Codeauszüge aus größeren Programmen und müssen im Kontext ausgeführt werden. Während Aktionen Ihnen zeigen, wie Sie einzelne Servicefunktionen aufrufen, können Sie Aktionen im Kontext der zugehörigen Szenarien und serviceübergreifenden Beispiele sehen.

Szenarien sind Codebeispiele, die Ihnen zeigen, wie Sie eine bestimmte Aufgabe ausführen können, indem Sie mehrere Funktionen innerhalb desselben Services aufrufen.

Jedes Beispiel enthält einen Link zu GitHub, wo Sie Anweisungen zum Einrichten und Ausführen des Codes im Kontext finden.

Themen

Aktionen

Das folgende Codebeispiel zeigt die Verwendungadd-tags-to-stream.

AWS CLI

Um Tags zu einem Datenstrom hinzuzufügen

Im folgenden add-tags-to-stream Beispiel wird dem angegebenen Stream ein Tag mit dem Schlüssel samplekey und example dem Wert zugewiesen.

aws kinesis add-tags-to-stream \ --stream-name samplestream \ --tags samplekey=example

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Tagging Your Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungcreate-stream.

AWS CLI

Um einen Datenstrom zu erstellen

Im folgenden create-stream Beispiel wird ein Datenstream namens samplestream mit 3 Shards erstellt.

aws kinesis create-stream \ --stream-name samplestream \ --shard-count 3

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Creating a Stream im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungdecrease-stream-retention-period.

AWS CLI

Um die Aufbewahrungsdauer von Datenströmen zu verkürzen

Im folgenden decrease-stream-retention-period Beispiel wird die Aufbewahrungsdauer (die Dauer, für die Datensätze zugänglich sind, nachdem sie dem Stream hinzugefügt wurden) eines Streams mit dem Namen samplestream auf 48 Stunden verringert.

aws kinesis decrease-stream-retention-period \ --stream-name samplestream \ --retention-period-hours 48

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Ändern der Datenaufbewahrungsfrist im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungdelete-stream.

AWS CLI

Um einen Datenstrom zu löschen

Im folgenden delete-stream Beispiel wird der angegebene Datenstrom gelöscht.

aws kinesis delete-stream \ --stream-name samplestream

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Löschen eines Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungderegister-stream-consumer.

AWS CLI

Um einen Datenstream-Consumer abzumelden

Im folgenden deregister-stream-consumer Beispiel wird der angegebene Verbraucher vom angegebenen Datenstrom abgemeldet.

aws kinesis deregister-stream-consumer \ --stream-arn arn:aws:kinesis:us-west-2:123456789012:stream/samplestream \ --consumer-name KinesisConsumerApplication

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Entwickeln von Verbrauchern mit erweitertem Fan-Out mithilfe der Kinesis Data Streams-API im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungdescribe-limits.

AWS CLI

Um Shard-Limits zu beschreiben

Im folgenden describe-limits Beispiel werden die Shard-Limits und die Nutzung für das aktuelle AWS Konto angezeigt.

aws kinesis describe-limits

Ausgabe:

{ "ShardLimit": 500, "OpenShardCount": 29 }

Weitere Informationen finden Sie unter Resharding a Stream im Amazon Kinesis Data Streams Developer Guide.

  • Einzelheiten zur API finden Sie unter Befehlsreferenz DescribeLimits.AWS CLI

Das folgende Codebeispiel zeigt die Verwendungdescribe-stream-consumer.

AWS CLI

Um einen Datenstromverbraucher zu beschreiben

Das folgende describe-stream-consumer Beispiel gibt die Beschreibung des angegebenen Verbrauchers zurück, der für den angegebenen Datenstrom registriert ist.

aws kinesis describe-stream-consumer \ --stream-arn arn:aws:kinesis:us-west-2:012345678912:stream/samplestream \ --consumer-name KinesisConsumerApplication

Ausgabe:

{ "ConsumerDescription": { "ConsumerName": "KinesisConsumerApplication", "ConsumerARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream/consumer/KinesisConsumerApplication:1572383852", "ConsumerStatus": "ACTIVE", "ConsumerCreationTimestamp": 1572383852.0, "StreamARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream" } }

Weitere Informationen finden Sie unter Lesen von Daten aus Amazon Kinesis Data Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungdescribe-stream-summary.

AWS CLI

Um eine Zusammenfassung des Datenstroms zu beschreiben

Das folgende describe-stream-summary Beispiel enthält eine zusammengefasste Beschreibung (ohne die Shard-Liste) des angegebenen Datenstroms.

aws kinesis describe-stream-summary \ --stream-name samplestream

Ausgabe:

{ "StreamDescriptionSummary": { "StreamName": "samplestream", "StreamARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream", "StreamStatus": "ACTIVE", "RetentionPeriodHours": 48, "StreamCreationTimestamp": 1572297168.0, "EnhancedMonitoring": [ { "ShardLevelMetrics": [] } ], "EncryptionType": "NONE", "OpenShardCount": 3, "ConsumerCount": 0 } }

Weitere Informationen finden Sie unter Creating and Managing Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungdescribe-stream.

AWS CLI

Um einen Datenstrom zu beschreiben

Das folgende describe-stream Beispiel gibt die Details des angegebenen Datenstroms zurück.

aws kinesis describe-stream \ --stream-name samplestream

Ausgabe:

{ "StreamDescription": { "Shards": [ { "ShardId": "shardId-000000000000", "HashKeyRange": { "StartingHashKey": "0", "EndingHashKey": "113427455640312821154458202477256070484" }, "SequenceNumberRange": { "StartingSequenceNumber": "49600871682957036442365024926191073437251060580128653314" } }, { "ShardId": "shardId-000000000001", "HashKeyRange": { "StartingHashKey": "113427455640312821154458202477256070485", "EndingHashKey": "226854911280625642308916404954512140969" }, "SequenceNumberRange": { "StartingSequenceNumber": "49600871682979337187563555549332609155523708941634633746" } }, { "ShardId": "shardId-000000000002", "HashKeyRange": { "StartingHashKey": "226854911280625642308916404954512140970", "EndingHashKey": "340282366920938463463374607431768211455" }, "SequenceNumberRange": { "StartingSequenceNumber": "49600871683001637932762086172474144873796357303140614178" } } ], "StreamARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream", "StreamName": "samplestream", "StreamStatus": "ACTIVE", "RetentionPeriodHours": 24, "EnhancedMonitoring": [ { "ShardLevelMetrics": [] } ], "EncryptionType": "NONE", "KeyId": null, "StreamCreationTimestamp": 1572297168.0 } }

Weitere Informationen finden Sie unter Creating and Managing Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungdisable-enhanced-monitoring.

AWS CLI

Um die erweiterte Überwachung für Metriken auf Shard-Ebene zu deaktivieren

Im folgenden disable-enhanced-monitoring Beispiel wird die erweiterte Kinesis-Datenstream-Überwachung für Metriken auf Shard-Ebene deaktiviert.

aws kinesis disable-enhanced-monitoring \ --stream-name samplestream --shard-level-metrics ALL

Ausgabe:

{ "StreamName": "samplestream", "CurrentShardLevelMetrics": [ "IncomingBytes", "OutgoingRecords", "IteratorAgeMilliseconds", "IncomingRecords", "ReadProvisionedThroughputExceeded", "WriteProvisionedThroughputExceeded", "OutgoingBytes" ], "DesiredShardLevelMetrics": [] }

Weitere Informationen finden Sie unter Monitoring Streams in Amazon Kinesis Data Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungenable-enhanced-monitoring.

AWS CLI

Um eine erweiterte Überwachung von Metriken auf Shard-Ebene zu ermöglichen

Das folgende enable-enhanced-monitoring Beispiel ermöglicht die erweiterte Kinesis-Datenstream-Überwachung für Metriken auf Shard-Ebene.

aws kinesis enable-enhanced-monitoring \ --stream-name samplestream \ --shard-level-metrics ALL

Ausgabe:

{ "StreamName": "samplestream", "CurrentShardLevelMetrics": [], "DesiredShardLevelMetrics": [ "IncomingBytes", "OutgoingRecords", "IteratorAgeMilliseconds", "IncomingRecords", "ReadProvisionedThroughputExceeded", "WriteProvisionedThroughputExceeded", "OutgoingBytes" ] }

Weitere Informationen finden Sie unter Monitoring Streams in Amazon Kinesis Data Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungget-records.

AWS CLI

Um Datensätze von einem Shard abzurufen

Im folgenden get-records Beispiel werden Datensätze aus dem Shard eines Kinesis-Datenstreams mithilfe des angegebenen Shard-Iterators abgerufen.

aws kinesis get-records \ --shard-iterator AAAAAAAAAAF7/0mWD7IuHj1yGv/TKuNgx2ukD5xipCY4cy4gU96orWwZwcSXh3K9tAmGYeOZyLZrvzzeOFVf9iN99hUPw/w/b0YWYeehfNvnf1DYt5XpDJghLKr3DzgznkTmMymDP3R+3wRKeuEw6/kdxY2yKJH0veaiekaVc4N2VwK/GvaGP2Hh9Fg7N++q0Adg6fIDQPt4p8RpavDbk+A4sL9SWGE1

Ausgabe:

{ "Records": [], "MillisBehindLatest": 80742000 }

Weitere Informationen finden Sie unter Developing Consumer Using the Kinesis Data Streams API with the AWS SDK for Java im Amazon Kinesis Data Streams Developer Guide.

  • Einzelheiten zur API finden Sie GetRecordsin der AWS CLI Befehlsreferenz.

Das folgende Codebeispiel zeigt die Verwendungget-shard-iterator.

AWS CLI

Um einen Shard-Iterator zu erhalten

Das folgende get-shard-iterator Beispiel verwendet den AT_SEQUENCE_NUMBER Shard-Iteratortyp und generiert einen Shard-Iterator, um mit dem Lesen von Datensätzen genau an der Position zu beginnen, die durch die angegebene Sequenznummer gekennzeichnet ist.

aws kinesis get-shard-iterator \ --stream-name samplestream \ --shard-id shardId-000000000001 \ --shard-iterator-type LATEST

Ausgabe:

{ "ShardIterator": "AAAAAAAAAAFEvJjIYI+3jw/4aqgH9FifJ+n48XWTh/IFIsbILP6o5eDueD39NXNBfpZ10WL5K6ADXk8w+5H+Qhd9cFA9k268CPXCz/kebq1TGYI7Vy+lUkA9BuN3xvATxMBGxRY3zYK05gqgvaIRn94O8SqeEqwhigwZxNWxID3Ej7YYYcxQi8Q/fIrCjGAy/n2r5Z9G864YpWDfN9upNNQAR/iiOWKs" }

Weitere Informationen finden Sie unter Developing Consumer Using the Kinesis Data Streams API with the AWS SDK for Java im Amazon Kinesis Data Streams Developer Guide.

  • Einzelheiten zur API finden Sie GetShardIteratorin der AWS CLI Befehlsreferenz.

Das folgende Codebeispiel zeigt die Verwendungincrease-stream-retention-period.

AWS CLI

Um die Aufbewahrungsdauer von Datenströmen zu verlängern

Im folgenden increase-stream-retention-period Beispiel wird die Aufbewahrungsdauer (die Dauer, für die Datensätze zugänglich sind, nachdem sie dem Stream hinzugefügt wurden) des angegebenen Streams auf 168 Stunden erhöht.

aws kinesis increase-stream-retention-period \ --stream-name samplestream \ --retention-period-hours 168

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Ändern der Datenaufbewahrungsfrist im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendunglist-shards.

AWS CLI

Um Shards in einem Datenstrom aufzulisten

Das folgende list-shards Beispiel listet alle Shards im angegebenen Stream auf, beginnend mit dem Shard, dessen ID unmittelbar auf die angegebene von folgt. exclusive-start-shard-id shardId-000000000000

aws kinesis list-shards \ --stream-name samplestream \ --exclusive-start-shard-id shardId-000000000000

Ausgabe:

{ "Shards": [ { "ShardId": "shardId-000000000001", "HashKeyRange": { "StartingHashKey": "113427455640312821154458202477256070485", "EndingHashKey": "226854911280625642308916404954512140969" }, "SequenceNumberRange": { "StartingSequenceNumber": "49600871682979337187563555549332609155523708941634633746" } }, { "ShardId": "shardId-000000000002", "HashKeyRange": { "StartingHashKey": "226854911280625642308916404954512140970", "EndingHashKey": "340282366920938463463374607431768211455" }, "SequenceNumberRange": { "StartingSequenceNumber": "49600871683001637932762086172474144873796357303140614178" } } ] }

Weitere Informationen finden Sie unter Shards auflisten im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendunglist-streams.

AWS CLI

Um Datenströme aufzulisten

Das folgende list-streams Beispiel listet alle aktiven Datenströme im aktuellen Konto und in der Region auf.

aws kinesis list-streams

Ausgabe:

{ "StreamNames": [ "samplestream", "samplestream1" ] }

Weitere Informationen finden Sie unter Streams auflisten im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendunglist-tags-for-stream.

AWS CLI

Um Tags für einen Datenstrom aufzulisten

Das folgende list-tags-for-stream Beispiel listet die Tags auf, die an den angegebenen Datenstrom angehängt sind.

aws kinesis list-tags-for-stream \ --stream-name samplestream

Ausgabe:

{ "Tags": [ { "Key": "samplekey", "Value": "example" } ], "HasMoreTags": false }

Weitere Informationen finden Sie unter Tagging Your Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungmerge-shards.

AWS CLI

Um Shards zusammenzuführen

Im folgenden merge-shards Beispiel werden zwei benachbarte Shards mit den IDs ShardID-000000000000 und ShardID-000000000001 im angegebenen Datenstrom zusammengeführt und zu einem einzigen Shard kombiniert.

aws kinesis merge-shards \ --stream-name samplestream \ --shard-to-merge shardId-000000000000 \ --adjacent-shard-to-merge shardId-000000000001

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Merging Two Shards im Amazon Kinesis Data Streams Developer Guide.

  • Einzelheiten zur API finden Sie unter Befehlsreferenz MergeShards.AWS CLI

Das folgende Codebeispiel zeigt die Verwendungput-record.

AWS CLI

Um einen Datensatz in einen Datenstrom zu schreiben

Das folgende put-record Beispiel schreibt einen einzelnen Datensatz unter Verwendung des angegebenen Partitionsschlüssels in den angegebenen Datenstrom.

aws kinesis put-record \ --stream-name samplestream \ --data sampledatarecord \ --partition-key samplepartitionkey

Ausgabe:

{ "ShardId": "shardId-000000000009", "SequenceNumber": "49600902273357540915989931256901506243878407835297513618", "EncryptionType": "KMS" }

Weitere Informationen finden Sie unter Entwickeln von Produzenten, die die Amazon Kinesis Data Streams-API mit dem AWS SDK for Java verwenden im Amazon Kinesis Data Streams Developer Guide.

  • Einzelheiten zur API finden Sie PutRecordin der AWS CLI Befehlsreferenz.

Das folgende Codebeispiel zeigt die Verwendungput-records.

AWS CLI

Um mehrere Datensätze in einen Datenstrom zu schreiben

Das folgende put-records Beispiel schreibt in einem einzigen Aufruf einen Datensatz mit dem angegebenen Partitionsschlüssel und einen anderen Datensatz mit einem anderen Partitionsschlüssel.

aws kinesis put-records \ --stream-name samplestream \ --records Data=blob1,PartitionKey=partitionkey1 Data=blob2,PartitionKey=partitionkey2

Ausgabe:

{ "FailedRecordCount": 0, "Records": [ { "SequenceNumber": "49600883331171471519674795588238531498465399900093808706", "ShardId": "shardId-000000000004" }, { "SequenceNumber": "49600902273357540915989931256902715169698037101720764562", "ShardId": "shardId-000000000009" } ], "EncryptionType": "KMS" }

Weitere Informationen finden Sie unter Entwickeln von Produzenten, die die Amazon Kinesis Data Streams-API mit dem AWS SDK for Java verwenden im Amazon Kinesis Data Streams Developer Guide.

  • Einzelheiten zur API finden Sie PutRecordsin der AWS CLI Befehlsreferenz.

Das folgende Codebeispiel zeigt die Verwendungregister-stream-consumer.

AWS CLI

Um einen Data Stream-Consumer zu registrieren

Im folgenden register-stream-consumer Beispiel wird ein Consumer registriert, der KinesisConsumerApplication mit dem angegebenen Datenstrom aufgerufen wurde.

aws kinesis register-stream-consumer \ --stream-arn arn:aws:kinesis:us-west-2:012345678912:stream/samplestream \ --consumer-name KinesisConsumerApplication

Ausgabe:

{ "Consumer": { "ConsumerName": "KinesisConsumerApplication", "ConsumerARN": "arn:aws:kinesis:us-west-2: 123456789012:stream/samplestream/consumer/KinesisConsumerApplication:1572383852", "ConsumerStatus": "CREATING", "ConsumerCreationTimestamp": 1572383852.0 } }

Weitere Informationen finden Sie unter Entwickeln von Verbrauchern mit erweitertem Fan-Out mithilfe der Kinesis Data Streams-API im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungremove-tags-from-stream.

AWS CLI

Um Tags aus einem Datenstrom zu entfernen

Im folgenden remove-tags-from-stream Beispiel wird das Tag mit dem angegebenen Schlüssel aus dem angegebenen Datenstrom entfernt.

aws kinesis remove-tags-from-stream \ --stream-name samplestream \ --tag-keys samplekey

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Tagging Your Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungsplit-shard.

AWS CLI

Um Shards zu teilen

Im folgenden split-shard Beispiel wird der angegebene Shard unter Verwendung eines neuen Start-Hash-Schlüssels von 10 in zwei neue Shards aufgeteilt.

aws kinesis split-shard \ --stream-name samplestream \ --shard-to-split shardId-000000000000 \ --new-starting-hash-key 10

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Splitting a Shard im Amazon Kinesis Data Streams Developer Guide.

  • Einzelheiten zur API finden Sie unter Befehlsreferenz SplitShard.AWS CLI

Das folgende Codebeispiel zeigt die Verwendungstart-stream-encryption.

AWS CLI

Um die Verschlüsselung von Datenströmen zu aktivieren

Das folgende start-stream-encryption Beispiel aktiviert die serverseitige Verschlüsselung für den angegebenen Stream unter Verwendung des angegebenen AWS KMS-Schlüssels.

aws kinesis start-stream-encryption \ --encryption-type KMS \ --key-id arn:aws:kms:us-west-2:012345678912:key/a3c4a7cd-728b-45dd-b334-4d3eb496e452 \ --stream-name samplestream

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Datenschutz in Amazon Kinesis Data Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungstop-stream-encryption.

AWS CLI

Um die Datenstromverschlüsselung zu deaktivieren

Im folgenden stop-stream-encryption Beispiel wird die serverseitige Verschlüsselung für den angegebenen Stream mithilfe des angegebenen AWS KMS-Schlüssels deaktiviert.

aws kinesis start-stream-encryption \ --encryption-type KMS \ --key-id arn:aws:kms:us-west-2:012345678912:key/a3c4a7cd-728b-45dd-b334-4d3eb496e452 \ --stream-name samplestream

Mit diesem Befehl wird keine Ausgabe zurückgegeben.

Weitere Informationen finden Sie unter Datenschutz in Amazon Kinesis Data Streams im Amazon Kinesis Data Streams Developer Guide.

Das folgende Codebeispiel zeigt die Verwendungupdate-shard-count.

AWS CLI

Um die Anzahl der Shards in einem Datenstream zu aktualisieren

Im folgenden update-shard-count Beispiel wird die Anzahl der Shards des angegebenen Datenstroms auf 6 aktualisiert. In diesem Beispiel wird eine einheitliche Skalierung verwendet, wodurch Shards gleicher Größe erstellt werden.

aws kinesis update-shard-count \ --stream-name samplestream \ --scaling-type UNIFORM_SCALING \ --target-shard-count 6

Ausgabe:

{ "StreamName": "samplestream", "CurrentShardCount": 3, "TargetShardCount": 6 }

Weitere Informationen finden Sie unter Resharding a Stream im Amazon Kinesis Data Streams Developer Guide.

  • Einzelheiten zur API finden Sie unter Befehlsreferenz UpdateShardCount.AWS CLI