Exemples de Kinesis utilisant des outils pour PowerShell

Exemple 1 : Cet exemple montre comment renvoyer et extraire des données d'une série d'un ou de plusieurs enregistrements. L'itérateur fourni à Get- KINRecord détermine la position de départ des enregistrements à renvoyer qui, dans cet exemple, sont capturés dans une variable, $records. Chaque enregistrement individuel est ensuite accessible en indexant la collection $records. En supposant que les données de l'enregistrement sont du texte codé en UTF -8, la commande finale indique comment extraire les données de l' MemoryStream objet et les renvoyer sous forme de texte à la console.

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

Sortie :

MillisBehindLatest NextShardIterator            Records
------------------ -----------------            -------
0                  AAAAAAAAAAERNIq...uDn11HuUs  {Key1, Key2}

$records.Records[0]

Sortie :

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())

Sortie :

test data from string

Exemple 1 : renvoie un itérateur de partition pour la partition et la position de départ spécifiées. Les détails des identificateurs de partition et des numéros de séquence peuvent être obtenus à partir de la sortie de l'KINStreamapplet de commande Get-, en faisant référence à la collection Shards de l'objet de flux renvoyé. L'itérateur renvoyé peut être utilisé avec l'KINRecordapplet de commande Get- pour extraire des enregistrements de données dans la partition.

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

Sortie :

AAAAAAAAAAGIc....9VnbiRNaP

Exemple 1 : renvoie les détails du flux spécifié.

Get-KINStream -StreamName "mystream"

Sortie :

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

Exemple 1 : crée un nouveau flux. Par défaut, cette applet de commande ne renvoie aucune sortie. Le PassThru commutateur - est donc ajouté pour renvoyer la valeur fournie au StreamName paramètre - pour une utilisation ultérieure.

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

Exemple 1 : Supprime le flux spécifié. Vous êtes invité à confirmer avant l'exécution de la commande. Pour supprimer les demandes de confirmation, utilisez le commutateur -Force.

Remove-KINStream -StreamName "mystream"

Exemple 1 : écrit un enregistrement contenant la chaîne fournie au paramètre -Text.

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

Exemple 2 : écrit un enregistrement contenant les données contenues dans le fichier spécifié. Le fichier est traité comme une séquence d'octets. S'il contient du texte, il doit être écrit avec le codage nécessaire avant de l'utiliser avec cette applet de commande.

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