Kinesis-Beispiele mit 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.

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.

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.

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.

Um einen Datenstromverbraucher 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.

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.

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.

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.

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.

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.

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.

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 Consumers Using the Kinesis Data Streams API with the AWS SDK for Java im Amazon Kinesis Data Streams Developer Guide.

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 Consumers Using the Kinesis Data Streams API with the AWS SDK for Java im Amazon Kinesis Data Streams Developer Guide.

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.

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.

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.

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.

Um Shards zusammenzuführen

Im folgenden merge-shards Beispiel werden zwei benachbarte Shards mit IDs den Werten 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.

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 Developing Producers Using the Amazon Kinesis Data Streams API with the AWS SDK for Java im Amazon Kinesis Data Streams Developer Guide.

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 Developing Producers Using the Amazon Kinesis Data Streams API with the AWS SDK for Java im Amazon Kinesis Data Streams Developer Guide.

Um einen Datenstromverbraucher 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.

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.

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.

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.

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 Schlüssels deaktiviert. AWS KMS

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.

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.