Exemplos do Kinesis usando o Tools for PowerShell

Exemplo 1: Este exemplo mostra como retornar e extrair dados de uma série de um ou mais registros. O iterador fornecido para Get- KINRecord determina a posição inicial dos registros a serem retornados, os quais, neste exemplo, são capturados em uma variável, $records. Cada registro individual pode então ser acessado indexando a coleção $records. Supondo que os dados no registro sejam texto codificado em UTF -8, o comando final mostra como você pode extrair os dados do MemoryStream objeto e retorná-los como texto para o console.

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

Saída:

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

$records.Records[0]

Saída:

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

Saída:

test data from string

Exemplo 1: retorna um iterador de fragmento para o fragmento e a posição inicial especificados. Detalhes dos identificadores de fragmentos e dos números de sequência podem ser obtidos na saída do KINStream cmdlet Get-, fazendo referência à coleção Shards do objeto de fluxo retornado. O iterador retornado pode ser usado com o KINRecord cmdlet Get- para extrair registros de dados no fragmento.

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

Saída:

AAAAAAAAAAGIc....9VnbiRNaP

Exemplo 1: retorna detalhes do fluxo especificado.

Get-KINStream -StreamName "mystream"

Saída:

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

Exemplo 1: cria um novo fluxo. Por padrão, esse cmdlet não retorna nenhuma saída, então a PassThru opção - é adicionada para retornar o valor fornecido ao StreamName parâmetro - para uso posterior.

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

Exemplo 1: exclui o fluxo especificado. Você será solicitado a confirmar antes que o comando seja executado. Para suprimir a solicitação de confirmação, use a opção -Force.

Remove-KINStream -StreamName "mystream"

Exemplo 1: grava um registro contendo a string fornecida ao parâmetro -Text.

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

Exemplo 2: grava um registro contendo os dados contidos no arquivo especificado. O arquivo é tratado como uma sequência de bytes, portanto, se ele contiver texto, ele deverá ser gravado com qualquer codificação necessária antes de ser usado com esse cmdlet.

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