# Ejemplos de Kinesis que utilizan la AWS CLI
En los siguientes ejemplos de código se muestra cómo realizar acciones e implementar escenarios comunes usando AWS Command Line Interface 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.
**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 información sobre la API, consulte [AddTagsToStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/add-tags-to-stream.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [CreateStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/create-stream.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [DecreaseStreamRetentionPeriod](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/decrease-stream-retention-period.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [DeleteStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/delete-stream.html) en la *Referencia del comando de la AWS CLI*.
### `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 información sobre la API, consulte [DeregisterStreamConsumer](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/deregister-stream-consumer.html) en la *Referencia de comandos de la AWS CLI*.
### `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 ejemplo de `describe-limits` se muestran los límites de partición y el uso de la cuenta actual de AWS.
```
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 detalles sobre la API, consulte [DescribeLimits](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-limits.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [DescribeStreamConsumer](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-stream-consumer.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [DescribeStreamSummary](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-stream-summary.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [DescribeStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-stream.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [DisableEnhancedMonitoring](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/disable-enhanced-monitoring.html) en la *Referencia de la comandos de la AWS CLI*.
### `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 información sobre la API, consulte [EnableEnhancedMonitoring](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/enable-enhanced-monitoring.html) en la *Referencia de comandos de la AWS CLI*.
### `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 el SDK de AWS para Java](https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-sdk.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener detalles sobre la API, consulte [GetRecords](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/get-records.html) en la *Referencia de comandos de la AWS CLI*.
### `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 el SDK de AWS para Java](https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-sdk.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener detalles sobre la API, consulte [GetShardIterator](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/get-shard-iterator.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [IncreaseStreamRetentionPeriod](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/increase-stream-retention-period.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [ListShards](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/list-shards.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [ListStreams](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/list-streams.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [ListTagsForStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/list-tags-for-stream.html) en la *Referencia de comandos de la AWS CLI*.
### `merge-shards`
En el siguiente ejemplo de código, se muestra cómo utilizar `merge-shards`.
**AWS CLI**
**Para fusionar particiones**
En el siguiente ejemplo de `merge-shards` se fusionan dos particiones adyacentes con los ID shardId-000000000000 y shardId-000000000001 en el flujo de datos especificado y los combina en una sola partición.
```
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 información sobre la API, consulte [MergeShards](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/merge-shards.html) en la *Referencia de comandos de la AWS CLI*.
### `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 mediante la API de Kinesis Data Streams con el SDK de AWS para Java](https://docs.aws.amazon.com/streams/latest/dev/developing-producers-with-sdk.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener información sobre la API, consulte [PutRecord](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/put-record.html) en la *Referencia de comandos de la AWS CLI*.
### `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 mediante la API de Kinesis Data Streams con el SDK de AWS para Java](https://docs.aws.amazon.com/streams/latest/dev/developing-producers-with-sdk.html) en la *Guía para desarrolladores de Amazon Kinesis Data Streams*.
+ Para obtener información sobre la API, consulte [PutRecords](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/put-records.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [RegisterStreamConsumer](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/register-stream-consumer.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [RemoveTagsFromStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/remove-tags-from-stream.html) en la *Referencia de comandos de la AWS CLI*.
### `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 información sobre la API, consulte [SplitShard](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/split-shard.html) en la *Referencia de comandos de la AWS CLI*.
### `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 ejemplo de `start-stream-encryption` habilita el cifrado del servidor para el flujo especificado mediante la clave de KMS de AWS indicada.
```
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 información sobre la API, consulte [StartStreamEncryption](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/start-stream-encryption.html) en la *Referencia de comandos de la AWS CLI*.
### `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 ejemplo de `stop-stream-encryption` deshabilita el cifrado del servidor para el flujo especificado mediante la clave de KMS de AWS indicada.
```
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 información sobre la API, consulte [StopStreamEncryption](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/stop-stream-encryption.html) en la *Referencia de comandos de la 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 información sobre la API, consulte [UpdateShardCount](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/update-shard-count.html) en la *Referencia de comandos de la AWS CLI*.