Ejemplos de Kinesis con Tools for V4 PowerShell - Herramientas de AWS para PowerShell (versión 4)
Acciones

La Herramientas de AWS para PowerShell versión 5 (V5) está en versión preliminar. Para ver el contenido de la versión 5, que está sujeto a cambios, y probar la nueva versión, consulta la guía del usuario de la versión 5 (versión preliminar). Para obtener información específica sobre los cambios más importantes y la migración a la V5, consulta el tema sobre migración de esa guía.

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Ejemplos de Kinesis con Tools for V4 PowerShell

Los siguientes ejemplos de código muestran cómo realizar acciones e implementar situaciones comunes mediante el uso de la Herramientas de AWS para PowerShell V4 con Kinesis.

Las acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Mientras las acciones muestran cómo llamar a las distintas funciones de servicio, es posible ver las acciones en contexto en los escenarios relacionados.

En cada ejemplo se incluye un enlace al código de origen completo, con instrucciones de configuración y ejecución del código en el contexto.

Acciones

En el siguiente ejemplo de código, se muestra cómo utilizar Get-KINRecord.

Herramientas para la versión PowerShell 4

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 para ello 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 UTF-8, el comando final muestra cómo extraer los datos del objeto y MemoryStream 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

En el siguiente ejemplo de código, se muestra cómo utilizar Get-KINShardIterator.

Herramientas para la versión 4 PowerShell

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 el resultado del Get-KINStream cmdlet, haciendo referencia a la colección Shards del objeto de flujo devuelto. El iterador devuelto se puede usar con el Get-KINRecord cmdlet para extraer los registros de datos del fragmento.

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

Salida:

AAAAAAAAAAGIc....9VnbiRNaP

  • Para obtener más información sobre la API, consulte GetShardIteratorla referencia del Herramientas de AWS para PowerShell cmdlet (V4).

En el siguiente ejemplo de código, se muestra cómo utilizar Get-KINStream.

Herramientas para la versión 4 PowerShell

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

En el siguiente ejemplo de código, se muestra cómo utilizar New-KINStream.

Herramientas para la versión 4 PowerShell

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

En el siguiente ejemplo de código, se muestra cómo utilizar Remove-KINStream.

Herramientas para la versión 4 PowerShell

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"

En el siguiente ejemplo de código, se muestra cómo utilizar Write-KINRecord.

Herramientas para la versión 4 PowerShell

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"