Kinesis-Beispiele mit AWS CLI - AWS Command Line Interface
Aktionen

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 Service-Funktionen aufrufen, können Sie Aktionen im Kontext der zugehörigen Szenarien anzeigen.

Jedes Beispiel enthält einen Link zum vollständigen Quellcode, wo Sie Anweisungen zum Einrichten und Ausführen des Codes im Kodex finden.

Themen

Aktionen

Das folgende Codebeispiel zeigt, wie Sieadd-tags-to-stream.

AWS CLI

So fügen Sie einem Datenstrom Tags hinzu

Im folgenden Beispiel für add-tags-to-stream wird dem angegebenen Stream ein Tag mit dem Schlüssel samplekey und dem Wert example 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 Markieren Ihrer Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

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

Das folgende Codebeispiel zeigt die Verwendungcreate-stream.

AWS CLI

So erstellen Sie einen Datenstrom

Im folgenden Beispiel für create-stream wird ein Datenstrom 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 Erstellen eines Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

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

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

AWS CLI

So verkürzen Sie die Aufbewahrungsdauer von Datenströmen

Im folgenden Beispiel für decrease-stream-retention-period wird der Aufbewahrungszeitraum (der Zeitraum, in dem auf Datensätze zugegriffen werden kann, nachdem sie dem Stream hinzugefügt wurden) eines Stroms namens samplestream auf 48 Stunden verkürzt.

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 Datenaufbewahrungszeitraums im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungdelete-stream.

AWS CLI

So löschen Sie einen Datenstrom

Im folgenden Beispiel für delete-stream 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 Entwicklerhandbuch für Amazon Kinesis Data Streams.

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

Das folgende Codebeispiel zeigt die Verwendungderegister-stream-consumer.

AWS CLI

So heben Sie die Registrierung eines Datenstromkonsumenten auf

Im folgenden Beispiel für deregister-stream-consumer wird die Registrierung des angegebenen Konsumenten beim angegebenen Datenstrom aufgehoben.

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 Konsumenten mit Enhanced Fan-Out über die API von Kinesis Data Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungdescribe-limits.

AWS CLI

So beschreiben Sie Shard-Limits

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 eines Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

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

Das folgende Codebeispiel zeigt die Verwendungdescribe-stream-consumer.

AWS CLI

So beschreiben Sie einen Datenstromkonsumenten

Im folgenden Beispiel für describe-stream-consumer wird die Beschreibung des angegebenen Konsumenten zurückgegeben, 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 Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungdescribe-stream-summary.

AWS CLI

So beschreiben Sie eine Zusammenfassung des Datenstroms

Im folgenden Beispiel für describe-stream-summary wird eine zusammenfassende Beschreibung (ohne Shard-Liste) des angegebenen Datenstroms bereitgestellt. 

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 Erstellen und Verwalten von Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungdescribe-stream.

AWS CLI

So beschreiben Sie einen Datenstrom

Im folgenden Beispiel für describe-stream werden Details zum angegebenen Datenstrom abgerufen.

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 Erstellen und Verwalten von Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

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

Das folgende Codebeispiel zeigt die Verwendungdisable-enhanced-monitoring.

AWS CLI

So deaktivieren Sie die erweiterte Überwachung für Metriken auf Shard-Ebene

Im folgenden Beispiel für disable-enhanced-monitoring wird die erweiterte Überwachung für Kinesis-Datenströme 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 Überwachen von Streams in Amazon Kinesis Data Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungenable-enhanced-monitoring.

AWS CLI

So aktivieren Sie die erweiterte Überwachung für Metriken auf Shard-Ebene

Im folgenden Beispiel für enable-enhanced-monitoring wird die erweiterte Überwachung für Kinesis-Datenströme für Metriken auf Shard-Ebene aktiviert.

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 Überwachen von Streams in Amazon Kinesis Data Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungget-records.

AWS CLI

So rufen Sie Datensätze aus einem Shard ab

Im folgenden Beispiel für get-records werden Datensätze aus dem Shard eines Kinesis-Datenstroms über den angegebenen Shard-Iterator 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

So rufen Sie einen Shard-Iterator ab

Im folgenden Beispiel für get-shard-iterator wird der Shard-Iteratortyp AT_SEQUENCE_NUMBER verwendet und ein Shard-Iterator generiert, 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

So verlängern Sie die Aufbewahrungsdauer von Datenströmen

Im folgenden Beispiel für increase-stream-retention-period wird der Aufbewahrungszeitraum (der Zeitraum, in dem auf Datensätze zugegriffen werden kann, nachdem sie dem Stream hinzugefügt wurden) des angegebenen Streams auf 168 Stunden verlängert.

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 Datenaufbewahrungszeitraums im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendunglist-shards.

AWS CLI

So listen Sie Shards in einem Datenstrom auf

Im folgenden Beispiel für list-shards werden alle Shards im angegebenen Stream aufgelistet, beginnend mit dem Shard, dessen ID unmittelbar auf die angegebene exclusive-start-shard-id von shardId-000000000000 folgt.

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 Auflisten von Shards im Entwicklerhandbuch für Amazon Kinesis Data Streams.

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

Das folgende Codebeispiel zeigt die Verwendunglist-streams.

AWS CLI

So listen Sie Datenströme auf

Im folgenden Beispiel für list-streams werden alle Parameter im aktuellen Konto und in der aktuellen Region aufgelistet.

aws kinesis list-streams

Ausgabe:

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

Weitere Informationen finden Sie unter Auflisten eines Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

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

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

AWS CLI

So listen Sie Tags für einen Datenstrom auf

Im folgenden Beispiel für list-tags-for-stream werden alle Tags aufgelistet, die dem angegebenen Datenstrom zugeordnet sind.

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

Ausgabe:

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

Weitere Informationen finden Sie unter Markieren Ihrer Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungmerge-shards.

AWS CLI

So führen Sie Shards zusammen

Das folgende merge-shards Beispiel führt zwei benachbarte Shards mit IDs of ShardID-000000000000 und ShardID-000000000001 im angegebenen Datenstrom zusammen und kombiniert sie zu einem einzigen Shard.

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 Zusammenführen zweier Shards im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungput-record.

AWS CLI

So schreiben Sie einen Datensatz in einen Datenstrom

Im folgenden Beispiel für put-record wird ein einzelner Datensatz mithilfe des angegebenen Partitionsschlüssels in den angegebenen Datenstrom geschrieben.

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

So schreiben Sie mehrere Datensätze in einen Datenstrom

Im folgenden Beispiel für put-records werden ein Datensatz mit dem angegebenen Partitionsschlüssel und ein anderer Datensatz mit einem anderen Partitionsschlüssel in einen einzelnen Aufruf geschrieben.

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

So registrieren Sie einen Datenstromkonsumenten

Im folgenden Beispiel für register-stream-consumer wird ein Konsument namens KinesisConsumerApplication beim angegebenen Datenstrom registriert.

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 Konsumenten mit Enhanced Fan-Out über die API von Kinesis Data Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

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

AWS CLI

So entfernen Sie Tags aus einem Datenstrom

Im folgenden Beispiel für remove-tags-from-stream wird das Tag mit dem angegebenen Schlüsselnamen aus der 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 Markieren Ihrer Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungsplit-shard.

AWS CLI

So teilen Sie Shards auf

Im folgenden Beispiel für split-shard wird der angegebene Shard mit dem neuen Start-Hash-Schlüssel 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 Aufteilen von Shards im Entwicklerhandbuch für Amazon Kinesis Data Streams.

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

Das folgende Codebeispiel zeigt die Verwendungstart-stream-encryption.

AWS CLI

So aktivieren Sie die Verschlüsselung von Datenströmen

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 Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungstop-stream-encryption.

AWS CLI

So deaktivieren Sie die Datenstromverschlüsselung

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 Entwicklerhandbuch für Amazon Kinesis Data Streams.

Das folgende Codebeispiel zeigt die Verwendungupdate-shard-count.

AWS CLI

So aktualisieren Sie die Shard-Anzahl in einem Datenstrom

Im folgenden Beispiel für update-shard-count wird die Shard-Anzahl 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 eines Streams im Entwicklerhandbuch für Amazon Kinesis Data Streams.

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