Se ha publicado la versión 5 (V5) de Herramientas de AWS para PowerShell.
Para empezar a utilizar la nueva versión de Tools para PowerShell, consulte la Guía del usuario de Herramientas de AWS para PowerShell (V5), especialmente el tema sobre la Migración a la V5.
Ejemplos de Kinesis con las Herramientas para PowerShell V4
En los siguientes ejemplos de código se muestra cómo ejecutar acciones e implementar escenarios comunes usando 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.
Temas
Acciones
En el siguiente ejemplo de código, se muestra cómo utilizar Get-KINRecord.
- Herramientas para PowerShell V4
-
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. Si se supone que los datos del registro son texto codificado en UTF-8, el comando final muestra cómo se pueden extraer los datos del MemoryStream del 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-
Para obtener información sobre la API, consulte GetRecords en la Referencia de cmdlets de Herramientas de AWS para PowerShell (V4).
-
En el siguiente ejemplo de código, se muestra cómo utilizar Get-KINShardIterator.
- Herramientas para PowerShell V4
-
Ejemplo 1: devuelve un iterador de particiones para la partición especificada y su posición inicial. Los detalles de los identificadores de particiones y los números de secuencia se pueden obtener en el resultado del cmdlet Get-KINStream, mediante una referencia a la colección de particiones del objeto de flujo devuelto. El iterador devuelto se puede usar con el cmdlet Get-KINRecord para extraer los registros de datos de la partición.
Get-KINShardIterator -StreamName "mystream" -ShardId "shardId-000000000000" -ShardIteratorType AT_SEQUENCE_NUMBER -StartingSequenceNumber "495598645..."Salida:
AAAAAAAAAAGIc....9VnbiRNaP-
Para obtener información sobre la API, consulte GetShardIterator en la Referencia de cmdlets de Herramientas de AWS para PowerShell (V4).
-
En el siguiente ejemplo de código, se muestra cómo utilizar Get-KINStream.
- Herramientas para PowerShell V4
-
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-
Para obtener información sobre la API, consulte DescribeStream en la Referencia de cmdlets de Herramientas de AWS para PowerShell (V4).
-
En el siguiente ejemplo de código, se muestra cómo utilizar New-KINStream.
- Herramientas para PowerShell V4
-
Ejemplo 1: cree una nueva transmisión. De forma predeterminada, este cmdlet no devuelve ningún resultado, por lo que se agrega el modificador -PassThru para devolver el valor proporcionado al parámetro -StreamName para su uso posterior.
$streamName = New-KINStream -StreamName "mystream" -ShardCount 1 -PassThru-
Para obtener información sobre la API, consulte CreateStream en la Referencia de cmdlets de Herramientas de AWS para PowerShell (V4).
-
En el siguiente ejemplo de código, se muestra cómo utilizar Remove-KINStream.
- Herramientas para PowerShell V4
-
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"-
Para obtener información sobre la API, consulte DeleteStream en la Referencia de cmdlets de Herramientas de AWS para PowerShell (V4).
-
En el siguiente ejemplo de código, se muestra cómo utilizar Write-KINRecord.
- Herramientas para PowerShell V4
-
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"-
Para obtener información sobre la API, consulte PutRecord en la Referencia de cmdlets de Herramientas de AWS para PowerShell (V4).
-
