Hay más ejemplos de AWS SDK disponibles en el GitHub repositorio de [ejemplos de AWS Doc SDK](https://github.com/awsdocs/aws-doc-sdk-examples).
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 que utilizan AWS CLI
Los siguientes ejemplos de código muestran cómo realizar acciones e implementar escenarios comunes mediante el AWS Command Line Interface uso de 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.
**Topics**
+ [Acciones](#actions)
## Acciones
### `add-tags-to-stream`
En el siguiente ejemplo de código, se muestra cómo utilizar `add-tags-to-stream`.
**AWS CLI**
**Para agregar etiquetas a un flujo de datos**
El siguiente ejemplo de `add-tags-to-stream` asigna una etiqueta con la clave `samplekey` y el valor `example` al flujo especificado.
```
aws kinesis add-tags-to-stream \
--stream-name samplestream \
--tags samplekey=example
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Etiquetar sus flujos](https://docs.aws.amazon.com/streams/latest/dev/tagging.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [AddTagsToStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/add-tags-to-stream.html)la *Referencia de AWS CLI comandos*.
### `create-stream`
En el siguiente ejemplo de código, se muestra cómo utilizar `create-stream`.
**AWS CLI**
**Creación de un flujo de datos**
En el siguiente ejemplo de `create-stream` se crea un flujo de datos denominado samplestream con 3 particiones.
```
aws kinesis create-stream \
--stream-name samplestream \
--shard-count 3
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Creación de una secuencia](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-create-stream.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [CreateStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/create-stream.html)la *Referencia de AWS CLI comandos*.
### `decrease-stream-retention-period`
En el siguiente ejemplo de código, se muestra cómo utilizar `decrease-stream-retention-period`.
**AWS CLI**
**Para reducir el período de retención del flujo de datos**
En el siguiente ejemplo de `decrease-stream-retention-period` se reduce el período de retención (el período de tiempo en el que se puede acceder a los registros de datos después de agregarlos al flujo) de un flujo llamado samplestream a 48 horas.
```
aws kinesis decrease-stream-retention-period \
--stream-name samplestream \
--retention-period-hours 48
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Changing the Data Retention Period](https://docs.aws.amazon.com/streams/latest/dev/kinesis-extended-retention.html) en la *Guía para desarrolladores de Amazon Kinesis*.
+ Para obtener más información sobre la API, consulte [DecreaseStreamRetentionPeriod](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/decrease-stream-retention-period.html)la *Referencia de AWS CLI comandos*.
### `delete-stream`
En el siguiente ejemplo de código, se muestra cómo utilizar `delete-stream`.
**AWS CLI**
**Eliminación de un flujo de datos**
En el siguiente ejemplo de `delete-stream` se elimina el flujo de datos especificado.
```
aws kinesis delete-stream \
--stream-name samplestream
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Eliminación de una secuencia](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-delete-stream.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [DeleteStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/delete-stream.html)la *Referencia de AWS CLI comandos*.
### `deregister-stream-consumer`
En el siguiente ejemplo de código, se muestra cómo utilizar `deregister-stream-consumer`.
**AWS CLI**
**Para anular el registro de un consumidor de flujos de datos**
En el ejemplo de `deregister-stream-consumer` siguiente se anula el registro del consumidor especificado del flujo de datos también especificado.
```
aws kinesis deregister-stream-consumer \
--stream-arn arn:aws:kinesis:us-west-2:123456789012:stream/samplestream \
--consumer-name KinesisConsumerApplication
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Desarrollo de consumidores mediante la API de Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/building-enhanced-consumers-api.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [DeregisterStreamConsumer](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/deregister-stream-consumer.html)la *Referencia de AWS CLI comandos*.
### `describe-limits`
En el siguiente ejemplo de código, se muestra cómo utilizar `describe-limits`.
**AWS CLI**
**Para describir los límites de partición**
En el siguiente `describe-limits` ejemplo, se muestran los límites y el uso de los fragmentos de la AWS cuenta corriente.
```
aws kinesis describe-limits
```
Salida:
```
{
"ShardLimit": 500,
"OpenShardCount": 29
}
```
Para obtener más información, consulte [Resharding a Stream](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-resharding.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [DescribeLimits](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-limits.html)la *Referencia de AWS CLI comandos*.
### `describe-stream-consumer`
En el siguiente ejemplo de código, se muestra cómo utilizar `describe-stream-consumer`.
**AWS CLI**
**Para describir un consumidor de flujo de datos**
En el siguiente ejemplo de `describe-stream-consumer` se devuelve la descripción del consumidor especificado, registrado en el flujo de datos especificado.
```
aws kinesis describe-stream-consumer \
--stream-arn arn:aws:kinesis:us-west-2:012345678912:stream/samplestream \
--consumer-name KinesisConsumerApplication
```
Salida:
```
{
"ConsumerDescription": {
"ConsumerName": "KinesisConsumerApplication",
"ConsumerARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream/consumer/KinesisConsumerApplication:1572383852",
"ConsumerStatus": "ACTIVE",
"ConsumerCreationTimestamp": 1572383852.0,
"StreamARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream"
}
}
```
Para obtener más información, consulte [Reading Data from Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/building-consumers.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [DescribeStreamConsumer](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-stream-consumer.html)la *Referencia de AWS CLI comandos*.
### `describe-stream-summary`
En el siguiente ejemplo de código, se muestra cómo utilizar `describe-stream-summary`.
**AWS CLI**
**Para describir un resumen de flujo de datos**
El siguiente ejemplo de `describe-stream-summary` proporciona una descripción resumida (sin la lista de particiones) del flujo de datos especificado.
```
aws kinesis describe-stream-summary \
--stream-name samplestream
```
Salida:
```
{
"StreamDescriptionSummary": {
"StreamName": "samplestream",
"StreamARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream",
"StreamStatus": "ACTIVE",
"RetentionPeriodHours": 48,
"StreamCreationTimestamp": 1572297168.0,
"EnhancedMonitoring": [
{
"ShardLevelMetrics": []
}
],
"EncryptionType": "NONE",
"OpenShardCount": 3,
"ConsumerCount": 0
}
}
```
Para obtener más información, consulte [Creación y administración de secuencias](https://docs.aws.amazon.com/streams/latest/dev/working-with-streams.html) en la *Guía para desarrolladores Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [DescribeStreamSummary](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-stream-summary.html)la *Referencia de AWS CLI comandos*.
### `describe-stream`
En el siguiente ejemplo de código, se muestra cómo utilizar `describe-stream`.
**AWS CLI**
**Descripción de un flujo de datos**
En el siguiente ejemplo de `describe-stream` se devuelven los detalles del flujo de datos especificado.
```
aws kinesis describe-stream \
--stream-name samplestream
```
Salida:
```
{
"StreamDescription": {
"Shards": [
{
"ShardId": "shardId-000000000000",
"HashKeyRange": {
"StartingHashKey": "0",
"EndingHashKey": "113427455640312821154458202477256070484"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49600871682957036442365024926191073437251060580128653314"
}
},
{
"ShardId": "shardId-000000000001",
"HashKeyRange": {
"StartingHashKey": "113427455640312821154458202477256070485",
"EndingHashKey": "226854911280625642308916404954512140969"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49600871682979337187563555549332609155523708941634633746"
}
},
{
"ShardId": "shardId-000000000002",
"HashKeyRange": {
"StartingHashKey": "226854911280625642308916404954512140970",
"EndingHashKey": "340282366920938463463374607431768211455"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49600871683001637932762086172474144873796357303140614178"
}
}
],
"StreamARN": "arn:aws:kinesis:us-west-2:123456789012:stream/samplestream",
"StreamName": "samplestream",
"StreamStatus": "ACTIVE",
"RetentionPeriodHours": 24,
"EnhancedMonitoring": [
{
"ShardLevelMetrics": []
}
],
"EncryptionType": "NONE",
"KeyId": null,
"StreamCreationTimestamp": 1572297168.0
}
}
```
Para obtener más información, consulte [Creación y administración de secuencias](https://docs.aws.amazon.com/streams/latest/dev/working-with-streams.html) en la *Guía para desarrolladores Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [DescribeStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-stream.html)la *Referencia de AWS CLI comandos*.
### `disable-enhanced-monitoring`
En el siguiente ejemplo de código, se muestra cómo utilizar `disable-enhanced-monitoring`.
**AWS CLI**
**Para deshabilitar la supervisión mejorada de métricas de nivel de partición**
En el siguiente ejemplo de `disable-enhanced-monitoring` se deshabilita la supervisión mejorada de flujos de datos de Kinesis para métricas de nivel de partición.
```
aws kinesis disable-enhanced-monitoring \
--stream-name samplestream --shard-level-metrics ALL
```
Salida:
```
{
"StreamName": "samplestream",
"CurrentShardLevelMetrics": [
"IncomingBytes",
"OutgoingRecords",
"IteratorAgeMilliseconds",
"IncomingRecords",
"ReadProvisionedThroughputExceeded",
"WriteProvisionedThroughputExceeded",
"OutgoingBytes"
],
"DesiredShardLevelMetrics": []
}
```
Para obtener más información, consulte [Monitoring Streams in Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/monitoring.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [DisableEnhancedMonitoring](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/disable-enhanced-monitoring.html)la *Referencia de AWS CLI comandos*.
### `enable-enhanced-monitoring`
En el siguiente ejemplo de código, se muestra cómo utilizar `enable-enhanced-monitoring`.
**AWS CLI**
**Para habilitar la supervisión mejorada de métricas de nivel de partición**
En el siguiente ejemplo de `enable-enhanced-monitoring` se habilita la supervisión mejorada de flujos de datos de Kinesis para métricas de nivel de partición.
```
aws kinesis enable-enhanced-monitoring \
--stream-name samplestream \
--shard-level-metrics ALL
```
Salida:
```
{
"StreamName": "samplestream",
"CurrentShardLevelMetrics": [],
"DesiredShardLevelMetrics": [
"IncomingBytes",
"OutgoingRecords",
"IteratorAgeMilliseconds",
"IncomingRecords",
"ReadProvisionedThroughputExceeded",
"WriteProvisionedThroughputExceeded",
"OutgoingBytes"
]
}
```
Para obtener más información, consulte [Monitoring Streams in Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/monitoring.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [EnableEnhancedMonitoring](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/enable-enhanced-monitoring.html)la *Referencia de AWS CLI comandos*.
### `get-records`
En el siguiente ejemplo de código, se muestra cómo utilizar `get-records`.
**AWS CLI**
**Obtención de registros de una partición**
En el siguiente ejemplo de `get-records` se obtienen registros de datos de la partición de un flujo de datos de Kinesis mediante el iterador de partición especificado.
```
aws kinesis get-records \
--shard-iterator AAAAAAAAAAF7/0mWD7IuHj1yGv/TKuNgx2ukD5xipCY4cy4gU96orWwZwcSXh3K9tAmGYeOZyLZrvzzeOFVf9iN99hUPw/w/b0YWYeehfNvnf1DYt5XpDJghLKr3DzgznkTmMymDP3R+3wRKeuEw6/kdxY2yKJH0veaiekaVc4N2VwK/GvaGP2Hh9Fg7N++q0Adg6fIDQPt4p8RpavDbk+A4sL9SWGE1
```
Salida:
```
{
"Records": [],
"MillisBehindLatest": 80742000
}
```
Para obtener más información, consulte [Desarrollo de consumidores mediante la API de Kinesis Data Streams con AWS el SDK para Java en la Guía para](https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-sdk.html) *desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte la Referencia [GetRecords](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/get-records.html)de *AWS CLI comandos*.
### `get-shard-iterator`
En el siguiente ejemplo de código, se muestra cómo utilizar `get-shard-iterator`.
**AWS CLI**
**Para obtener un iterador de particiones**
El siguiente ejemplo de `get-shard-iterator` utiliza el tipo de iterador de particiones `AT_SEQUENCE_NUMBER` y genera un iterador de particiones para empezar a leer los registros de datos exactamente desde la posición indicada por el número de secuencia especificado.
```
aws kinesis get-shard-iterator \
--stream-name samplestream \
--shard-id shardId-000000000001 \
--shard-iterator-type LATEST
```
Salida:
```
{
"ShardIterator": "AAAAAAAAAAFEvJjIYI+3jw/4aqgH9FifJ+n48XWTh/IFIsbILP6o5eDueD39NXNBfpZ10WL5K6ADXk8w+5H+Qhd9cFA9k268CPXCz/kebq1TGYI7Vy+lUkA9BuN3xvATxMBGxRY3zYK05gqgvaIRn94O8SqeEqwhigwZxNWxID3Ej7YYYcxQi8Q/fIrCjGAy/n2r5Z9G864YpWDfN9upNNQAR/iiOWKs"
}
```
Para obtener más información, consulte [Desarrollo de consumidores mediante la API de Kinesis Data Streams con AWS el SDK para Java en la Guía para](https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-sdk.html) *desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte la Referencia [GetShardIterator](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/get-shard-iterator.html)de *AWS CLI comandos*.
### `increase-stream-retention-period`
En el siguiente ejemplo de código, se muestra cómo utilizar `increase-stream-retention-period`.
**AWS CLI**
**Para aumentar el período de retención del flujo de datos**
En el siguiente ejemplo de `increase-stream-retention-period` se aumenta el período de retención (el período de tiempo en el que se puede acceder a los registros de datos después de agregarlos al flujo) del flujo especificado a 168 horas.
```
aws kinesis increase-stream-retention-period \
--stream-name samplestream \
--retention-period-hours 168
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Changing the Data Retention Period](https://docs.aws.amazon.com/streams/latest/dev/kinesis-extended-retention.html) en la *Guía para desarrolladores de Amazon Kinesis*.
+ Para obtener más información sobre la API, consulte [IncreaseStreamRetentionPeriod](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/increase-stream-retention-period.html)la *Referencia de AWS CLI comandos*.
### `list-shards`
En el siguiente ejemplo de código, se muestra cómo utilizar `list-shards`.
**AWS CLI**
**Para enumerar las particiones de un flujo de datos**
En el siguiente ejemplo de `list-shards` se enumeran todas las particiones del flujo especificado, empezando por el fragmento cuyo identificador sigue inmediatamente al `exclusive-start-shard-id` especificado de `shardId-000000000000`.
```
aws kinesis list-shards \
--stream-name samplestream \
--exclusive-start-shard-id shardId-000000000000
```
Salida:
```
{
"Shards": [
{
"ShardId": "shardId-000000000001",
"HashKeyRange": {
"StartingHashKey": "113427455640312821154458202477256070485",
"EndingHashKey": "226854911280625642308916404954512140969"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49600871682979337187563555549332609155523708941634633746"
}
},
{
"ShardId": "shardId-000000000002",
"HashKeyRange": {
"StartingHashKey": "226854911280625642308916404954512140970",
"EndingHashKey": "340282366920938463463374607431768211455"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49600871683001637932762086172474144873796357303140614178"
}
}
]
}
```
Para obtener más información, consulte [Listing Shards](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-list-shards.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [ListShards](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/list-shards.html)la *Referencia de AWS CLI comandos*.
### `list-streams`
En el siguiente ejemplo de código, se muestra cómo utilizar `list-streams`.
**AWS CLI**
**Creación de una lista de flujos de datos**
En el siguiente ejemplo de `list-streams` se enumeran todos los flujos de datos activos de la cuenta y la región actuales.
```
aws kinesis list-streams
```
Salida:
```
{
"StreamNames": [
"samplestream",
"samplestream1"
]
}
```
Para obtener más información, consulte [Visualización de secuencias](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-list-streams.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [ListStreams](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/list-streams.html)la *Referencia de AWS CLI comandos*.
### `list-tags-for-stream`
En el siguiente ejemplo de código, se muestra cómo utilizar `list-tags-for-stream`.
**AWS CLI**
**Para enumerar las etiquetas de flujo de datos**
En el siguiente ejemplo de `list-tags-for-stream` se enumeran las etiquetas adjuntas al flujo de datos especificado.
```
aws kinesis list-tags-for-stream \
--stream-name samplestream
```
Salida:
```
{
"Tags": [
{
"Key": "samplekey",
"Value": "example"
}
],
"HasMoreTags": false
}
```
Para obtener más información, consulte [Etiquetar sus flujos](https://docs.aws.amazon.com/streams/latest/dev/tagging.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [ListTagsForStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/list-tags-for-stream.html)la *Referencia de AWS CLI comandos*.
### `merge-shards`
En el siguiente ejemplo de código, se muestra cómo utilizar `merge-shards`.
**AWS CLI**
**Para fusionar particiones**
En el siguiente `merge-shards` ejemplo, se combinan dos fragmentos adyacentes, los IDs de shardID-000000000000 y shardID-000000000001, en el flujo de datos especificado y los combina en un solo fragmento.
```
aws kinesis merge-shards \
--stream-name samplestream \
--shard-to-merge shardId-000000000000 \
--adjacent-shard-to-merge shardId-000000000001
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Merging Two Shards](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-resharding-merge.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener [MergeShards AWS CLI](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/merge-shards.html)*más información* sobre la API, consulte la Referencia de comandos.
### `put-record`
En el siguiente ejemplo de código, se muestra cómo utilizar `put-record`.
**AWS CLI**
**Escritura de un registro en un flujo de datos**
En el siguiente ejemplo de `put-record` se escribe un único registro de datos en el flujo de datos especificado mediante la clave de partición especificada.
```
aws kinesis put-record \
--stream-name samplestream \
--data sampledatarecord \
--partition-key samplepartitionkey
```
Salida:
```
{
"ShardId": "shardId-000000000009",
"SequenceNumber": "49600902273357540915989931256901506243878407835297513618",
"EncryptionType": "KMS"
}
```
Para obtener más información, consulte [Desarrollo de productores que utilizan la API de Amazon Kinesis Data Streams con AWS el SDK para Java en la Guía para](https://docs.aws.amazon.com/streams/latest/dev/developing-producers-with-sdk.html) *desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte la Referencia [PutRecord](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/put-record.html)de *AWS CLI comandos*.
### `put-records`
En el siguiente ejemplo de código, se muestra cómo utilizar `put-records`.
**AWS CLI**
**Para escribir varios registros en un flujo de datos**
En el siguiente ejemplo de `put-records`, se escribe un registro de datos con la clave de partición especificada y otro registro de datos con una clave de partición diferente en una sola llamada.
```
aws kinesis put-records \
--stream-name samplestream \
--records Data=blob1,PartitionKey=partitionkey1 Data=blob2,PartitionKey=partitionkey2
```
Salida:
```
{
"FailedRecordCount": 0,
"Records": [
{
"SequenceNumber": "49600883331171471519674795588238531498465399900093808706",
"ShardId": "shardId-000000000004"
},
{
"SequenceNumber": "49600902273357540915989931256902715169698037101720764562",
"ShardId": "shardId-000000000009"
}
],
"EncryptionType": "KMS"
}
```
Para obtener más información, consulte [Desarrollo de productores que utilizan la API de Amazon Kinesis Data Streams con AWS el SDK para Java en la Guía para](https://docs.aws.amazon.com/streams/latest/dev/developing-producers-with-sdk.html) *desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte la Referencia [PutRecords](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/put-records.html)de *AWS CLI comandos*.
### `register-stream-consumer`
En el siguiente ejemplo de código, se muestra cómo utilizar `register-stream-consumer`.
**AWS CLI**
**Para registrar un consumidor de flujo de datos**
En el siguiente ejemplo de `register-stream-consumer` se registra un consumidor llamado `KinesisConsumerApplication` con el flujo de datos especificado.
```
aws kinesis register-stream-consumer \
--stream-arn arn:aws:kinesis:us-west-2:012345678912:stream/samplestream \
--consumer-name KinesisConsumerApplication
```
Salida:
```
{
"Consumer": {
"ConsumerName": "KinesisConsumerApplication",
"ConsumerARN": "arn:aws:kinesis:us-west-2: 123456789012:stream/samplestream/consumer/KinesisConsumerApplication:1572383852",
"ConsumerStatus": "CREATING",
"ConsumerCreationTimestamp": 1572383852.0
}
}
```
Para obtener más información, consulte [Desarrollo de consumidores mediante la API de Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/building-enhanced-consumers-api.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [RegisterStreamConsumer](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/register-stream-consumer.html)la *Referencia de AWS CLI comandos*.
### `remove-tags-from-stream`
En el siguiente ejemplo de código, se muestra cómo utilizar `remove-tags-from-stream`.
**AWS CLI**
**Para eliminar etiquetas de un flujo de datos**
En el siguiente ejemplo de `remove-tags-from-stream` se elimina la etiqueta con la clave especificada del flujo de datos indicado.
```
aws kinesis remove-tags-from-stream \
--stream-name samplestream \
--tag-keys samplekey
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Etiquetar sus flujos](https://docs.aws.amazon.com/streams/latest/dev/tagging.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [RemoveTagsFromStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/remove-tags-from-stream.html)la *Referencia de AWS CLI comandos*.
### `split-shard`
En el siguiente ejemplo de código, se muestra cómo utilizar `split-shard`.
**AWS CLI**
**Para dividir particiones**
En el siguiente ejemplo de `split-shard` se divide la partición especificada en dos nuevas particiones mediante una nueva clave hash inicial de 10.
```
aws kinesis split-shard \
--stream-name samplestream \
--shard-to-split shardId-000000000000 \
--new-starting-hash-key 10
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Splitting a Shard](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-resharding-split.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [SplitShard](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/split-shard.html)la *Referencia de AWS CLI comandos*.
### `start-stream-encryption`
En el siguiente ejemplo de código, se muestra cómo utilizar `start-stream-encryption`.
**AWS CLI**
**Para habilitar el cifrado de flujos de datos**
El siguiente `start-stream-encryption` ejemplo habilita el cifrado del lado del servidor para la transmisión especificada mediante la clave AWS KMS especificada.
```
aws kinesis start-stream-encryption \
--encryption-type KMS \
--key-id arn:aws:kms:us-west-2:012345678912:key/a3c4a7cd-728b-45dd-b334-4d3eb496e452 \
--stream-name samplestream
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Data Protection in Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/server-side-encryption.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte la Referencia [StartStreamEncryption](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/start-stream-encryption.html)de *AWS CLI comandos*.
### `stop-stream-encryption`
En el siguiente ejemplo de código, se muestra cómo utilizar `stop-stream-encryption`.
**AWS CLI**
**Para deshabilitar el cifrado de flujos de datos**
El siguiente `stop-stream-encryption` ejemplo deshabilita el cifrado del lado del servidor para la transmisión especificada mediante la clave KMS especificada AWS .
```
aws kinesis start-stream-encryption \
--encryption-type KMS \
--key-id arn:aws:kms:us-west-2:012345678912:key/a3c4a7cd-728b-45dd-b334-4d3eb496e452 \
--stream-name samplestream
```
Este comando no genera ninguna salida.
Para obtener más información, consulte [Data Protection in Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/server-side-encryption.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ *Para obtener más información sobre la API, consulte la Referencia de [StopStreamEncryption](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/stop-stream-encryption.html)comandos AWS CLI .*
### `update-shard-count`
En el siguiente ejemplo de código, se muestra cómo utilizar `update-shard-count`.
**AWS CLI**
**Para actualizar el recuento de particiones en un flujo de datos**
En el siguiente ejemplo de `update-shard-count` se actualiza el recuento de particiones del flujo de datos especificado a 6. En este ejemplo se utiliza escalado uniforme, que crea particiones del mismo tamaño.
```
aws kinesis update-shard-count \
--stream-name samplestream \
--scaling-type UNIFORM_SCALING \
--target-shard-count 6
```
Salida:
```
{
"StreamName": "samplestream",
"CurrentShardCount": 3,
"TargetShardCount": 6
}
```
Para obtener más información, consulte [Resharding a Stream](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-resharding.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener más información sobre la API, consulte [UpdateShardCount](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/update-shard-count.html)la *Referencia de AWS CLI comandos*.