Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
# Exemples d'utilisation de Kinesis AWS CLI
Les exemples de code suivants vous montrent comment effectuer des actions et implémenter des scénarios courants à l'aide de AWS Command Line Interface with Kinesis.
Les *actions* sont des extraits de code de programmes plus larges et doivent être exécutées dans leur contexte. Alors que les actions vous indiquent comment appeler des fonctions de service individuelles, vous pouvez les voir en contexte dans leurs scénarios associés.
Chaque exemple inclut un lien vers le code source complet, où vous trouverez des instructions sur la configuration et l’exécution du code en contexte.
**Topics**
+ [Actions](#actions)
## Actions
### `add-tags-to-stream`
L'exemple de code suivant montre comment utiliser`add-tags-to-stream`.
**AWS CLI**
**Pour ajouter des balises à un flux de données**
L’exemple `add-tags-to-stream` suivant attribue une balise avec la clé `samplekey` et la valeur `example` au flux spécifié.
```
aws kinesis add-tags-to-stream \
--stream-name samplestream \
--tags samplekey=example
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Balisage de vos flux](https://docs.aws.amazon.com/streams/latest/dev/tagging.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [AddTagsToStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/add-tags-to-stream.html)à la section *Référence des AWS CLI commandes*.
### `create-stream`
L'exemple de code suivant montre comment utiliser`create-stream`.
**AWS CLI**
**Pour créer un flux de données**
L’exemple `create-stream` suivant crée un flux de données nommé samplestream avec 3 partitions.
```
aws kinesis create-stream \
--stream-name samplestream \
--shard-count 3
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Création d’un flux](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-create-stream.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [CreateStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/create-stream.html)à la section *Référence des AWS CLI commandes*.
### `decrease-stream-retention-period`
L'exemple de code suivant montre comment utiliser`decrease-stream-retention-period`.
**AWS CLI**
**Pour réduire la période de conservation des flux de données**
L’exemple `decrease-stream-retention-period` suivant réduit la période de conservation (durée pendant laquelle les enregistrements de données sont accessibles après avoir été ajoutés au flux) d’un flux nommé samplestream à 48 heures.
```
aws kinesis decrease-stream-retention-period \
--stream-name samplestream \
--retention-period-hours 48
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Modification de la période de conservation des données](https://docs.aws.amazon.com/streams/latest/dev/kinesis-extended-retention.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [DecreaseStreamRetentionPeriod](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/decrease-stream-retention-period.html)à la section *Référence des AWS CLI commandes*.
### `delete-stream`
L'exemple de code suivant montre comment utiliser`delete-stream`.
**AWS CLI**
**Pour supprimer un flux de données**
L’exemple `delete-stream` suivant supprime le flux de données spécifié.
```
aws kinesis delete-stream \
--stream-name samplestream
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Suppression d’un flux](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-delete-stream.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [DeleteStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/delete-stream.html)à la section *Référence des AWS CLI commandes*.
### `deregister-stream-consumer`
L'exemple de code suivant montre comment utiliser`deregister-stream-consumer`.
**AWS CLI**
**Pour annuler l’enregistrement d’un consommateur de flux de données**
L’exemple `deregister-stream-consumer` suivant annule l’enregistrement du consommateur spécifié du flux de données spécifié.
```
aws kinesis deregister-stream-consumer \
--stream-arn arn:aws:kinesis:us-west-2:123456789012:stream/samplestream \
--consumer-name KinesisConsumerApplication
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Developing Consumers with Enhanced Fan-Out Using the Kinesis Data Streams API](https://docs.aws.amazon.com/streams/latest/dev/building-enhanced-consumers-api.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [DeregisterStreamConsumer](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/deregister-stream-consumer.html)à la section *Référence des AWS CLI commandes*.
### `describe-limits`
L'exemple de code suivant montre comment utiliser`describe-limits`.
**AWS CLI**
**Pour décrire les limites des partitions**
L'`describe-limits`exemple suivant montre les limites et l'utilisation des partitions pour le AWS compte courant.
```
aws kinesis describe-limits
```
Sortie :
```
{
"ShardLimit": 500,
"OpenShardCount": 29
}
```
Pour plus d’informations, consultez [Repartitionnement d’un flux](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-resharding.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [DescribeLimits](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-limits.html)à la section *Référence des AWS CLI commandes*.
### `describe-stream-consumer`
L'exemple de code suivant montre comment utiliser`describe-stream-consumer`.
**AWS CLI**
**Pour décrire un consommateur de flux de données**
L’exemple `describe-stream-consumer` suivant renvoie la description du consommateur spécifié, enregistré avec le flux de données spécifié.
```
aws kinesis describe-stream-consumer \
--stream-arn arn:aws:kinesis:us-west-2:012345678912:stream/samplestream \
--consumer-name KinesisConsumerApplication
```
Sortie :
```
{
"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"
}
}
```
Pour plus d’informations, consultez [Lire des données à partir d’Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/building-consumers.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [DescribeStreamConsumer](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-stream-consumer.html)à la section *Référence des AWS CLI commandes*.
### `describe-stream-summary`
L'exemple de code suivant montre comment utiliser`describe-stream-summary`.
**AWS CLI**
**Pour décrire le résumé d’un flux de données**
L’exemple `describe-stream-summary` suivant fournit une description résumée du flux de données spécifié (sans la liste de partition).
```
aws kinesis describe-stream-summary \
--stream-name samplestream
```
Sortie :
```
{
"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
}
}
```
Pour plus d’informations, consultez [Création et gestion de flux](https://docs.aws.amazon.com/streams/latest/dev/working-with-streams.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [DescribeStreamSummary](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-stream-summary.html)à la section *Référence des AWS CLI commandes*.
### `describe-stream`
L'exemple de code suivant montre comment utiliser`describe-stream`.
**AWS CLI**
**Pour décrire un flux de données**
L’exemple `describe-stream` suivant renvoie les informations du flux de données spécifié.
```
aws kinesis describe-stream \
--stream-name samplestream
```
Sortie :
```
{
"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
}
}
```
Pour plus d’informations, consultez [Création et gestion de flux](https://docs.aws.amazon.com/streams/latest/dev/working-with-streams.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [DescribeStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/describe-stream.html)à la section *Référence des AWS CLI commandes*.
### `disable-enhanced-monitoring`
L'exemple de code suivant montre comment utiliser`disable-enhanced-monitoring`.
**AWS CLI**
**Pour désactiver la surveillance améliorée des métriques au niveau des partitions**
L’exemple `disable-enhanced-monitoring` suivant désactive la surveillance améliorée du flux de données Kinesis pour les métriques au niveau des partitions.
```
aws kinesis disable-enhanced-monitoring \
--stream-name samplestream --shard-level-metrics ALL
```
Sortie :
```
{
"StreamName": "samplestream",
"CurrentShardLevelMetrics": [
"IncomingBytes",
"OutgoingRecords",
"IteratorAgeMilliseconds",
"IncomingRecords",
"ReadProvisionedThroughputExceeded",
"WriteProvisionedThroughputExceeded",
"OutgoingBytes"
],
"DesiredShardLevelMetrics": []
}
```
Pour plus d’informations, consultez [Monitoring Streams in Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/monitoring.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [DisableEnhancedMonitoring](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/disable-enhanced-monitoring.html)à la section *Référence des AWS CLI commandes*.
### `enable-enhanced-monitoring`
L'exemple de code suivant montre comment utiliser`enable-enhanced-monitoring`.
**AWS CLI**
**Pour activer la surveillance améliorée des métriques au niveau des partitions**
L’exemple `enable-enhanced-monitoring` suivant active la surveillance améliorée du flux de données Kinesis pour les métriques au niveau des partitions.
```
aws kinesis enable-enhanced-monitoring \
--stream-name samplestream \
--shard-level-metrics ALL
```
Sortie :
```
{
"StreamName": "samplestream",
"CurrentShardLevelMetrics": [],
"DesiredShardLevelMetrics": [
"IncomingBytes",
"OutgoingRecords",
"IteratorAgeMilliseconds",
"IncomingRecords",
"ReadProvisionedThroughputExceeded",
"WriteProvisionedThroughputExceeded",
"OutgoingBytes"
]
}
```
Pour plus d’informations, consultez [Monitoring Streams in Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/monitoring.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [EnableEnhancedMonitoring](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/enable-enhanced-monitoring.html)à la section *Référence des AWS CLI commandes*.
### `get-records`
L'exemple de code suivant montre comment utiliser`get-records`.
**AWS CLI**
**Pour obtenir des enregistrements à partir d’une partition**
L’exemple `get-records` suivant obtient des enregistrements de données à partir de la partition d’un flux de données Kinesis à l’aide de l’itérateur de partition spécifié.
```
aws kinesis get-records \
--shard-iterator AAAAAAAAAAF7/0mWD7IuHj1yGv/TKuNgx2ukD5xipCY4cy4gU96orWwZwcSXh3K9tAmGYeOZyLZrvzzeOFVf9iN99hUPw/w/b0YWYeehfNvnf1DYt5XpDJghLKr3DzgznkTmMymDP3R+3wRKeuEw6/kdxY2yKJH0veaiekaVc4N2VwK/GvaGP2Hh9Fg7N++q0Adg6fIDQPt4p8RpavDbk+A4sL9SWGE1
```
Sortie :
```
{
"Records": [],
"MillisBehindLatest": 80742000
}
```
Pour plus d'informations, consultez [Developing Consumers Using the Kinesis Data Streams API with AWS the SDK for](https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-sdk.html) Java dans le manuel *Amazon Kinesis Data Streams Developer Guide*.
+ Pour plus de détails sur l'API, reportez-vous [GetRecords](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/get-records.html)à la section *Référence des AWS CLI commandes*.
### `get-shard-iterator`
L'exemple de code suivant montre comment utiliser`get-shard-iterator`.
**AWS CLI**
**Pour obtenir un itérateur de partition**
L’exemple `get-shard-iterator` suivant utilise le type d’itérateur de partition `AT_SEQUENCE_NUMBER` et génère un itérateur de partition pour commencer à lire les enregistrements de données exactement à partir de la position indiquée par le numéro de séquence spécifié.
```
aws kinesis get-shard-iterator \
--stream-name samplestream \
--shard-id shardId-000000000001 \
--shard-iterator-type LATEST
```
Sortie :
```
{
"ShardIterator": "AAAAAAAAAAFEvJjIYI+3jw/4aqgH9FifJ+n48XWTh/IFIsbILP6o5eDueD39NXNBfpZ10WL5K6ADXk8w+5H+Qhd9cFA9k268CPXCz/kebq1TGYI7Vy+lUkA9BuN3xvATxMBGxRY3zYK05gqgvaIRn94O8SqeEqwhigwZxNWxID3Ej7YYYcxQi8Q/fIrCjGAy/n2r5Z9G864YpWDfN9upNNQAR/iiOWKs"
}
```
Pour plus d'informations, consultez [Developing Consumers Using the Kinesis Data Streams API with AWS the SDK for](https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-sdk.html) Java dans le manuel *Amazon Kinesis Data Streams Developer Guide*.
+ Pour plus de détails sur l'API, reportez-vous [GetShardIterator](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/get-shard-iterator.html)à la section *Référence des AWS CLI commandes*.
### `increase-stream-retention-period`
L'exemple de code suivant montre comment utiliser`increase-stream-retention-period`.
**AWS CLI**
**Pour réduire la période de conservation des flux de données**
L’exemple `increase-stream-retention-period` suivant réduit la période de conservation (durée pendant laquelle les enregistrements de données sont accessibles après avoir été ajoutés au flux) d’un flux spécifié à 168 heures.
```
aws kinesis increase-stream-retention-period \
--stream-name samplestream \
--retention-period-hours 168
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Modification de la période de conservation des données](https://docs.aws.amazon.com/streams/latest/dev/kinesis-extended-retention.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [IncreaseStreamRetentionPeriod](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/increase-stream-retention-period.html)à la section *Référence des AWS CLI commandes*.
### `list-shards`
L'exemple de code suivant montre comment utiliser`list-shards`.
**AWS CLI**
**Pour répertorier les partitions d’un flux de données**
L’exemple `list-shards` suivant répertorie toutes les partitions du flux spécifié, en commençant par la partition dont l’ID suit immédiatement l’`exclusive-start-shard-id` spécifié `shardId-000000000000`.
```
aws kinesis list-shards \
--stream-name samplestream \
--exclusive-start-shard-id shardId-000000000000
```
Sortie :
```
{
"Shards": [
{
"ShardId": "shardId-000000000001",
"HashKeyRange": {
"StartingHashKey": "113427455640312821154458202477256070485",
"EndingHashKey": "226854911280625642308916404954512140969"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49600871682979337187563555549332609155523708941634633746"
}
},
{
"ShardId": "shardId-000000000002",
"HashKeyRange": {
"StartingHashKey": "226854911280625642308916404954512140970",
"EndingHashKey": "340282366920938463463374607431768211455"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49600871683001637932762086172474144873796357303140614178"
}
}
]
}
```
Pour plus d’informations, consultez [Affichage des partitions](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-list-shards.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [ListShards](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/list-shards.html)à la section *Référence des AWS CLI commandes*.
### `list-streams`
L'exemple de code suivant montre comment utiliser`list-streams`.
**AWS CLI**
**Pour répertorier vos flux de données**
L’exemple `list-streams` suivant répertorie tous les flux de données actifs dans le compte et la région actuels.
```
aws kinesis list-streams
```
Sortie :
```
{
"StreamNames": [
"samplestream",
"samplestream1"
]
}
```
Pour plus d’informations, consultez [Affichage de la liste des flux](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-list-streams.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [ListStreams](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/list-streams.html)à la section *Référence des AWS CLI commandes*.
### `list-tags-for-stream`
L'exemple de code suivant montre comment utiliser`list-tags-for-stream`.
**AWS CLI**
**Pour répertorier les balises d’un flux de données**
L’exemple `list-tags-for-stream` suivant répertorie les balises attachées au flux de données spécifié.
```
aws kinesis list-tags-for-stream \
--stream-name samplestream
```
Sortie :
```
{
"Tags": [
{
"Key": "samplekey",
"Value": "example"
}
],
"HasMoreTags": false
}
```
Pour plus d’informations, consultez [Balisage de vos flux](https://docs.aws.amazon.com/streams/latest/dev/tagging.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [ListTagsForStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/list-tags-for-stream.html)à la section *Référence des AWS CLI commandes*.
### `merge-shards`
L'exemple de code suivant montre comment utiliser`merge-shards`.
**AWS CLI**
**Pour fusionner des partitions**
L'`merge-shards`exemple suivant fusionne deux partitions adjacentes avec IDs shardID-000000000000 et shardID-000000000001 dans le flux de données spécifié et les combine en une seule partition.
```
aws kinesis merge-shards \
--stream-name samplestream \
--shard-to-merge shardId-000000000000 \
--adjacent-shard-to-merge shardId-000000000001
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Fusion de deux partitions](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-resharding-merge.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [MergeShards](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/merge-shards.html)à la section *Référence des AWS CLI commandes*.
### `put-record`
L'exemple de code suivant montre comment utiliser`put-record`.
**AWS CLI**
**Pour écrire un enregistrement dans un flux de données**
L’exemple `put-record` suivant écrit un seul enregistrement de données dans le flux de données spécifié à l’aide de la clé de partition spécifiée.
```
aws kinesis put-record \
--stream-name samplestream \
--data sampledatarecord \
--partition-key samplepartitionkey
```
Sortie :
```
{
"ShardId": "shardId-000000000009",
"SequenceNumber": "49600902273357540915989931256901506243878407835297513618",
"EncryptionType": "KMS"
}
```
Pour plus d'informations, consultez la section [Developing Producers Using the Amazon Kinesis Data Streams API with AWS the SDK for](https://docs.aws.amazon.com/streams/latest/dev/developing-producers-with-sdk.html) Java dans le manuel *Amazon Kinesis Data Streams Developer Guide*.
+ Pour plus de détails sur l'API, reportez-vous [PutRecord](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/put-record.html)à la section *Référence des AWS CLI commandes*.
### `put-records`
L'exemple de code suivant montre comment utiliser`put-records`.
**AWS CLI**
**Pour écrire plusieurs enregistrements dans un flux de données**
L’exemple `put-records` suivant écrit un enregistrement de données en utilisant la clé de partition spécifiée et un autre enregistrement de données en utilisant une clé de partition différente en un seul appel.
```
aws kinesis put-records \
--stream-name samplestream \
--records Data=blob1,PartitionKey=partitionkey1 Data=blob2,PartitionKey=partitionkey2
```
Sortie :
```
{
"FailedRecordCount": 0,
"Records": [
{
"SequenceNumber": "49600883331171471519674795588238531498465399900093808706",
"ShardId": "shardId-000000000004"
},
{
"SequenceNumber": "49600902273357540915989931256902715169698037101720764562",
"ShardId": "shardId-000000000009"
}
],
"EncryptionType": "KMS"
}
```
Pour plus d'informations, consultez la section [Developing Producers Using the Amazon Kinesis Data Streams API with AWS the SDK for](https://docs.aws.amazon.com/streams/latest/dev/developing-producers-with-sdk.html) Java dans le manuel *Amazon Kinesis Data Streams Developer Guide*.
+ Pour plus de détails sur l'API, reportez-vous [PutRecords](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/put-records.html)à la section *Référence des AWS CLI commandes*.
### `register-stream-consumer`
L'exemple de code suivant montre comment utiliser`register-stream-consumer`.
**AWS CLI**
**Pour enregistrer un consommateur de flux de données**
L’exemple `register-stream-consumer` suivant enregistre un consommateur appelé `KinesisConsumerApplication` avec le flux de données spécifié.
```
aws kinesis register-stream-consumer \
--stream-arn arn:aws:kinesis:us-west-2:012345678912:stream/samplestream \
--consumer-name KinesisConsumerApplication
```
Sortie :
```
{
"Consumer": {
"ConsumerName": "KinesisConsumerApplication",
"ConsumerARN": "arn:aws:kinesis:us-west-2: 123456789012:stream/samplestream/consumer/KinesisConsumerApplication:1572383852",
"ConsumerStatus": "CREATING",
"ConsumerCreationTimestamp": 1572383852.0
}
}
```
Pour plus d’informations, consultez [Developing Consumers with Enhanced Fan-Out Using the Kinesis Data Streams API](https://docs.aws.amazon.com/streams/latest/dev/building-enhanced-consumers-api.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [RegisterStreamConsumer](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/register-stream-consumer.html)à la section *Référence des AWS CLI commandes*.
### `remove-tags-from-stream`
L'exemple de code suivant montre comment utiliser`remove-tags-from-stream`.
**AWS CLI**
**Pour supprimer des balises d’un flux de données**
L’exemple `remove-tags-from-stream` suivant supprime la balise avec la clé spécifiée du flux de données spécifié.
```
aws kinesis remove-tags-from-stream \
--stream-name samplestream \
--tag-keys samplekey
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Balisage de vos flux](https://docs.aws.amazon.com/streams/latest/dev/tagging.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [RemoveTagsFromStream](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/remove-tags-from-stream.html)à la section *Référence des AWS CLI commandes*.
### `split-shard`
L'exemple de code suivant montre comment utiliser`split-shard`.
**AWS CLI**
**Pour diviser des partitions**
L’exemple `split-shard` suivant divise la partition spécifiée en deux nouvelles partitions en utilisant une nouvelle clé de hachage de départ de 10.
```
aws kinesis split-shard \
--stream-name samplestream \
--shard-to-split shardId-000000000000 \
--new-starting-hash-key 10
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Fractionnement d’une partition](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-resharding-split.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [SplitShard](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/split-shard.html)à la section *Référence des AWS CLI commandes*.
### `start-stream-encryption`
L'exemple de code suivant montre comment utiliser`start-stream-encryption`.
**AWS CLI**
**Pour activer le chiffrement d’un flux de données**
L'`start-stream-encryption`exemple suivant active le chiffrement côté serveur pour le flux spécifié, à l'aide de la clé AWS KMS spécifiée.
```
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
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Protection des données dans Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/server-side-encryption.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [StartStreamEncryption](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/start-stream-encryption.html)à la section *Référence des AWS CLI commandes*.
### `stop-stream-encryption`
L'exemple de code suivant montre comment utiliser`stop-stream-encryption`.
**AWS CLI**
**Pour désactiver le chiffrement d’un flux de données**
L'`stop-stream-encryption`exemple suivant désactive le chiffrement côté serveur pour le flux spécifié, à l'aide de la clé KMS spécifiée 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
```
Cette commande ne produit aucune sortie.
Pour plus d’informations, consultez [Protection des données dans Amazon Kinesis Data Streams](https://docs.aws.amazon.com/streams/latest/dev/server-side-encryption.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [StopStreamEncryption](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/stop-stream-encryption.html)à la section *Référence des AWS CLI commandes*.
### `update-shard-count`
L'exemple de code suivant montre comment utiliser`update-shard-count`.
**AWS CLI**
**Pour mettre à jour le nombre de partitions dans un flux de données**
L’exemple `update-shard-count` suivant met à jour le nombre de partitions du flux de données spécifié sur 6. Cet exemple utilise une mise à l’échelle uniforme, qui crée des partitions de taille égale.
```
aws kinesis update-shard-count \
--stream-name samplestream \
--scaling-type UNIFORM_SCALING \
--target-shard-count 6
```
Sortie :
```
{
"StreamName": "samplestream",
"CurrentShardCount": 3,
"TargetShardCount": 6
}
```
Pour plus d’informations, consultez [Repartitionnement d’un flux](https://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-resharding.html) dans le *Guide du développeur Amazon Kinesis Data Streams*.
+ Pour plus de détails sur l'API, reportez-vous [UpdateShardCount](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kinesis/update-shard-count.html)à la section *Référence des AWS CLI commandes*.