Ejemplos de Kinesis con herramientas para PowerShell

Ejemplo 1: En este ejemplo se muestra cómo devolver y extraer datos de una serie de un registro o más. El iterador suministrado a Get- KINRecord determina la posición inicial de los registros que se van a devolver, que en este ejemplo se capturan en una variable, $records. Luego, se puede acceder a cada registro individual indexando la colección $records. Suponiendo que los datos del registro son texto codificado en forma de UTF -8, el comando final muestra cómo se pueden extraer los datos del MemoryStream objeto y devolverlos como texto a la consola.

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

Salida:

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

$records.Records[0]

Salida:

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

Salida:

test data from string

Ejemplo 1: devuelve un iterador de particiones para la partición especificada y su posición inicial. Los detalles de los identificadores de los fragmentos y los números de secuencia se pueden obtener en la salida del KINStream cmdlet Get-, haciendo referencia a la colección Shards del objeto de flujo devuelto. El iterador devuelto se puede usar con el KINRecord cmdlet Get- para extraer los registros de datos del fragmento.

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

Salida:

AAAAAAAAAAGIc....9VnbiRNaP

Ejemplo 1: devuelve información detallada del flujo especificada.

Get-KINStream -StreamName "mystream"

Salida:

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

Ejemplo 1: cree una nueva transmisión. De forma predeterminada, este cmdlet no devuelve ningún resultado, por lo que se agrega el PassThru modificador - para devolver el valor proporcionado al StreamName parámetro - para su uso posterior.

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

Ejemplo 1: Elimina el flujo especificado. Se le solicitará una confirmación antes de que se ejecute el comando. Para suprimir la confirmación utilice el conmutador -Force.

Remove-KINStream -StreamName "mystream"

Ejemplo 1: escribe un registro que contiene la cadena proporcionada al parámetro -Text.

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

Ejemplo 2: escribe un registro que contiene los datos contenidos en el archivo especificado. El archivo se trata como una secuencia de bytes, por lo que si contiene texto, debe escribirse con la codificación necesaria antes de usarlo con este cmdlet.

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