Hay más ejemplos de AWS SDK disponibles en el repositorio de ejemplos de AWS Doc SDK.
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 V5 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 V5 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 la V5 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 Get-KINRecord determina la posición inicial de los registros a devolver y, 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 UTF-8 codificado, el último comando muestra cómo 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-
Para obtener más información sobre la API, consulte GetRecords Herramientas de AWS para PowerShell Cmdlet Reference (V5).
-
En el siguiente ejemplo de código, se muestra cómo utilizar Get-KINShardIterator.
- Herramientas para la versión 5 PowerShell
-
Ejemplo 1: devuelve un iterador de particiones para la partición especificada y su posición inicial. Los detalles de los identificadores de fragmentos y los números de secuencia se pueden obtener en la salida del Get-KINStream cmdlet, haciendo referencia a la colección Shards del objeto de transmisión 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 GetShardIterator Herramientas de AWS para PowerShell Cmdlet Reference (V5).
-
En el siguiente ejemplo de código, se muestra cómo utilizar Get-KINStream.
- Herramientas para la versión 5 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-
Para obtener más información sobre la API, consulte DescribeStream Herramientas de AWS para PowerShell Cmdlet Reference (V5).
-
En el siguiente ejemplo de código, se muestra cómo utilizar New-KINStream.
- Herramientas para la versión 5 PowerShell
-
Ejemplo 1: cree una nueva transmisión.
New-KINStream -StreamName "mystream" -ShardCount 1-
Para obtener más información sobre la API, consulte CreateStream Herramientas de AWS para PowerShell Cmdlet Reference (V5).
-
En el siguiente ejemplo de código, se muestra cómo utilizar Remove-KINStream.
- Herramientas para la versión 5 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"-
Para obtener más información sobre la API, consulte DeleteStream Herramientas de AWS para PowerShell Cmdlet Reference (V5).
-
En el siguiente ejemplo de código, se muestra cómo utilizar Write-KINRecord.
- Herramientas para la versión 5 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"-
Para obtener más información sobre la API, consulte PutRecord Herramientas de AWS para PowerShell Cmdlet Reference (V5).
-
