Kinesis-Beispiele für die Verwendung von Tools für PowerShell - AWS SDKCode-Beispiele

Weitere AWS SDK Beispiele sind im Repo AWS Doc SDK Examples GitHub verfügbar.

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 für die Verwendung von Tools für PowerShell

Die folgenden Codebeispiele zeigen Ihnen, wie Sie AWS Tools for PowerShell 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. Aktionen zeigen Ihnen zwar, wie Sie einzelne Servicefunktionen aufrufen, aber Sie können Aktionen im Kontext der zugehörigen Szenarien sehen.

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

Themen

Aktionen

Das folgende Codebeispiel zeigt die VerwendungGet-KINRecord.

Tools für PowerShell

Beispiel 1: Dieses Beispiel zeigt, wie Daten aus einer Reihe von einem oder mehreren Datensätzen zurückgegeben und extrahiert werden. Der an Get- gelieferte Iterator KINRecord bestimmt die Startposition der zurückzugebenden Datensätze, die in diesem Beispiel in einer Variablen, $records, erfasst werden. Auf jeden einzelnen Datensatz kann dann zugegriffen werden, indem die $records-Auflistung indexiert wird. Unter der Annahme, dass es sich bei den Daten im Datensatz um UTF -8-codierten Text handelt, zeigt der letzte Befehl, wie Sie die Daten aus dem MemoryStream Objekt extrahieren und als Text an die Konsole zurückgeben können.

$records $records = Get-KINRecord -ShardIterator "AAAAAAAAAAGIc....9VnbiRNaP"

Ausgabe:

MillisBehindLatest NextShardIterator Records ------------------ ----------------- ------- 0 AAAAAAAAAAERNIq...uDn11HuUs {Key1, Key2}
$records.Records[0]

Ausgabe:

ApproximateArrivalTimestamp Data PartitionKey SequenceNumber --------------------------- ---- ------------ -------------- 3/7/2016 5:14:33 PM System.IO.MemoryStream Key1 4955986459776...931586
[Text.Encoding]::UTF8.GetString($records.Records[0].Data.ToArray())

Ausgabe:

test data from string

Das folgende Codebeispiel zeigt die Verwendung. Get-KINShardIterator

Tools für PowerShell

Beispiel 1: Gibt einen Shard-Iterator für den angegebenen Shard und die angegebene Startposition zurück. Einzelheiten zu den Shard-Bezeichnern und Sequenznummern können der Ausgabe des KINStream Cmdlets Get- entnommen werden, indem auf die Shards-Auflistung des zurückgegebenen Stream-Objekts verwiesen wird. Der zurückgegebene Iterator kann zusammen mit dem KINRecord Cmdlet Get- verwendet werden, um Datensätze im Shard abzurufen.

Get-KINShardIterator -StreamName "mystream" -ShardId "shardId-000000000000" -ShardIteratorType AT_SEQUENCE_NUMBER -StartingSequenceNumber "495598645..."

Ausgabe:

AAAAAAAAAAGIc....9VnbiRNaP
  • APIEinzelheiten finden Sie unter GetShardIteratorCmdlet-Referenz.AWS Tools for PowerShell

Das folgende Codebeispiel zeigt die Verwendung. Get-KINStream

Tools für PowerShell

Beispiel 1: Gibt Details des angegebenen Streams zurück.

Get-KINStream -StreamName "mystream"

Ausgabe:

HasMoreShards : False RetentionPeriodHours : 24 Shards : {} StreamARN : arn:aws:kinesis:us-west-2:123456789012:stream/mystream StreamName : mystream StreamStatus : ACTIVE

Das folgende Codebeispiel zeigt die Verwendung. New-KINStream

Tools für PowerShell

Beispiel 1: Erzeugt einen neuen Stream. Standardmäßig gibt dieses Cmdlet keine Ausgabe zurück. Daher wird der PassThru Schalter - hinzugefügt, um den Wert zurückzugeben, der dem StreamName Parameter - zur späteren Verwendung übergeben wurde.

$streamName = New-KINStream -StreamName "mystream" -ShardCount 1 -PassThru

Das folgende Codebeispiel zeigt die Verwendung. Remove-KINStream

Tools für PowerShell

Beispiel 1: Löscht den angegebenen Stream. Sie werden zur Bestätigung aufgefordert, bevor der Befehl ausgeführt wird. Verwenden Sie den Schalter -Force, um die Bestätigungsaufforderung zu unterdrücken.

Remove-KINStream -StreamName "mystream"

Das folgende Codebeispiel zeigt die Verwendung. Write-KINRecord

Tools für PowerShell

Beispiel 1: Schreibt einen Datensatz, der die im Parameter -Text angegebene Zeichenfolge enthält.

Write-KINRecord -Text "test data from string" -StreamName "mystream" -PartitionKey "Key1"

Beispiel 2: Schreibt einen Datensatz, der die in der angegebenen Datei enthaltenen Daten enthält. Die Datei wird als Bytefolge behandelt. Wenn sie Text enthält, sollte sie mit der erforderlichen Kodierung geschrieben werden, bevor sie mit diesem Cmdlet verwendet wird.

Write-KINRecord -FilePath "C:\TestData.txt" -StreamName "mystream" -PartitionKey "Key2"