Esempi di Kinesis con Tools for V4 PowerShell

Esempio 1: questo esempio mostra come restituire ed estrarre dati da una serie di uno o più record. L'iteratore supplierd to Get-KINRecord determina la posizione iniziale dei record da restituire, che in questo esempio vengono acquisiti in una variabile, $records. È quindi possibile accedere a ogni record indicizzando la raccolta $records. Supponendo che i dati nel record siano testo con codifica UTF-8, il comando finale mostra come estrarre i dati dall'oggetto e restituirli MemoryStream come testo alla console.

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

Output:

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

$records.Records[0]

Output:

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

Output:

test data from string

Esempio 1: restituisce un’iterazione di shard per lo shard e la posizione iniziale specificati. I dettagli degli identificatori degli shard e dei numeri di sequenza possono essere ottenuti dall'output del Get-KINStream cmdlet, facendo riferimento all'insieme Shards dell'oggetto stream restituito. L'iteratore restituito può essere utilizzato con il Get-KINRecord cmdlet per estrarre i record di dati nello shard.

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

Output:

AAAAAAAAAAGIc....9VnbiRNaP

Esempio 1: restituisce i dettagli del flusso specificato.

Get-KINStream -StreamName "mystream"

Output:

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

Esempio 1: crea un nuovo flusso. Per impostazione predefinita, questo cmdlet non restituisce alcun output, pertanto viene aggiunto lo PassThru switch - per restituire il valore fornito al StreamName parametro - per un uso successivo.

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

Esempio 1: elimina il flusso specificato. Viene richiesta una conferma prima dell’esecuzione del comando. Per disabilitare la richiesta di conferma, utilizza il parametro -Force.

Remove-KINStream -StreamName "mystream"

Esempio 1: scrive un record contenente la stringa fornita al parametro -Text.

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

Esempio 2: scrive un record contenente i dati contenuti nel file specificato. Il file viene trattato come una sequenza di byte. Pertanto, se contiene testo, deve essere scritto con la codifica necessaria prima di utilizzarlo con questo cmdlet.

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