Kinesis-Beispiele mit Tools für V4 PowerShell - AWS SDK-Codebeispiele
Aktionen

Weitere AWS SDK-Beispiele sind im GitHub Repo AWS Doc SDK Examples 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 mit Tools für V4 PowerShell

Die folgenden Codebeispiele zeigen Ihnen, wie Sie mithilfe von AWS -Tools für PowerShell V4 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 die VerwendungGet-KINRecord.

Tools für PowerShell V4

Beispiel 1: In diesem Beispiel wird gezeigt, wie Daten aus einer Reihe von einem oder mehreren Datensätzen zurückgegeben und extrahiert werden können. Der Iterator, an den geliefert Get-KINRecord wird, bestimmt die Startposition der zurückzugebenden Datensätze, die in diesem Beispiel in einer Variablen, $records, erfasst werden. Auf jeden einzelnen Datensatz kann dann durch Indizierung der $records-Sammlung zugegriffen werden. 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 Objekt extrahieren und als Text MemoryStream 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 V4

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

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

Ausgabe:

AAAAAAAAAAGIc....9VnbiRNaP

  • Einzelheiten zur API finden Sie unter AWS -Tools für PowerShell Cmdlet-Referenz (GetShardIteratorV4).

Das folgende Codebeispiel zeigt die Verwendung. Get-KINStream

Tools für PowerShell V4

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 V4

Beispiel 1: Erzeugt einen neuen Stream. Standardmäßig gibt dieses Cmdlet keine Ausgabe zurück, sodass der PassThru Schalter - hinzugefügt wird, 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 V4

Beispiel 1: Löscht den angegebenen Stream. Sie werden um eine Bestätigung gebeten, 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 V4

Beispiel 1: Schreibt einen Datensatz, der die an den Parameter -Text übergebene Zeichenfolge enthält.

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

Beispiel 2: Schreibt einen Datensatz, der die Daten aus der angegebenen Datei enthält. Die Datei wird als Folge von Bytes behandelt. Wenn sie Text enthält, sollte sie daher vor der Verwendung mit diesem Cmdlet mit der erforderlichen Kodierung geschrieben werden.

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