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.
# Surveillez Kinesis Data Streams
Vous pouvez surveiller vos flux de données dans Amazon Kinesis Data Streams en utilisant les fonctionnalités suivantes :
+ [CloudWatch métriques](monitoring-with-cloudwatch.md) — Kinesis Data Streams envoie à CloudWatch Amazon des métriques personnalisées avec un suivi détaillé pour chaque flux.
+ [Kinesis Agent : l'agent](agent-health.md) Kinesis publie des CloudWatch métriques personnalisées pour aider à évaluer si l'agent fonctionne comme prévu.
+ [Journalisation d'API](logging-using-cloudtrail.md) : Kinesis Data Streams utilise AWS CloudTrail pour consigner les appels d'API et stocker les données dans un compartiment Amazon S3.
+ [Bibliothèque client Kinesis](monitoring-with-kcl.md) : La bibliothèque client Kinesis (KCL) fournit des métriques pour chaque partition, application de travail et application KCL.
+ [Bibliothèque Kinesis Producer](monitoring-with-kpl.md) : Amazon Kinesis Producer Library (KPL) fournit des statistiques par partition, par travailleur et par application KPL.
Pour obtenir plus d'informations sur les problèmes, les questions et le dépannage courants en matière de surveillance, consultez les ressources suivantes :
+ [Quels indicateurs utiliser pour surveiller et résoudre les problèmes liés à Kinesis Data Streams ?](https://aws.amazon.com/premiumsupport/knowledge-center/kinesis-data-streams-troubleshoot/)
+ [Pourquoi la IteratorAgeMilliseconds valeur de Kinesis Data Streams continue-t-elle d'augmenter ?](https://aws.amazon.com/premiumsupport/knowledge-center/kinesis-data-streams-iteratorage-metric/)
# Surveillez le service Amazon Kinesis Data Streams avec Amazon CloudWatch
Amazon Kinesis Data Streams et CloudWatch Amazon sont intégrés afin que vous puissiez collecter, consulter et CloudWatch analyser les métriques de vos flux de données Kinesis. Par exemple, pour suivre l'utilisation de la partition, vous pouvez surveiller les métriques `IncomingBytes` et `OutgoingBytes`, et les comparer au nombre de partitions dans le flux.
Les métriques de stream et les métriques au niveau des partitions que vous configurez sont automatiquement collectées et transmises à CloudWatch chaque minute. Les métriques sont archivées pendant deux semaines ; après cette période, les données sont supprimées.
Le tableau suivant décrit la surveillance de base au niveau des flux et la surveillance avancée au niveau des partitions pour les flux de données Kinesis.
| Type | Description |
| --- | --- |
| Basique (au niveau du flux) | Les données au niveau des flux sont envoyées automatiquement et gratuitement toutes les minutes. |
| Avancée (au niveau des partitions) | Les données au niveau des flux sont envoyées toutes les minutes avec un coût additionnel. Pour obtenir ce niveau de données, vous devez l'activer spécifiquement pour le flux à l'aide de l'opération [EnableEnhancedMonitoring](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_EnableEnhancedMonitoring.html). Pour plus d'informations sur les tarifs, consultez la [page CloudWatch produit d'Amazon](https://aws.amazon.com/cloudwatch). |
## Dimensions et statistiques d'Amazon Kinesis Data Streams
Kinesis Data Streams envoie des métriques CloudWatch à deux niveaux : le niveau du flux et, éventuellement, le niveau de la partition. Les métriques au niveau des cours d'eau concernent les cas d'utilisation de surveillance les plus courants dans des conditions normales. Les métriques au niveau des partitions concernent des tâches de surveillance spécifiques généralement associées au dépannage des problèmes et sont activées à l'aide de l'opération [EnableEnhancedMonitoring](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_EnableEnhancedMonitoring.html).
Pour une explication des statistiques collectées à partir des CloudWatch métriques, consultez la section [CloudWatch Statistiques](https://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/cloudwatch_concepts.html#Statistic) du *guide de CloudWatch l'utilisateur Amazon*.
**Topics**
+ [
### Indicateurs de base au niveau du stream
](#kinesis-metrics-stream)
+ [
### Mesures améliorées au niveau des partitions
](#kinesis-metrics-shard)
+ [
### Dimensions des métriques Amazon Kinesis Data Streams
](#kinesis-metricdimensions)
+ [
### Mesures Amazon Kinesis Data Streams recommandées
](#kinesis-metric-use)
### Indicateurs de base au niveau du stream
L'espace de noms `AWS/Kinesis` inclut les métriques au niveau des flux suivantes.
Kinesis Data Streams envoie ces mesures CloudWatch au niveau du flux à chaque minute. Ces métriques sont toujours disponibles.
| Métrique | Description |
| --- | --- |
| GetRecords.Bytes | Nombre d'octets extraits du flux Kinesis mesurés pendant la période spécifiée. Les statistiques Minimum, Maximum et Moyenne représentent le nombre d'octets dans une même opération `GetRecords` pour le flux dans la période déterminée. Nom de la métrique au niveau des partitions : `OutgoingBytes` Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : octets |
| GetRecords.IteratorAge | Cette métrique n'est plus utilisée. Utilisez `GetRecords.IteratorAgeMilliseconds`. |
| GetRecords.IteratorAgeMilliseconds | L'âge du dernier enregistrement parmi tous les appels `GetRecords` effectués sur un flux Kinesis, mesuré pendant la période spécifiée. L'âge est la différence entre l'heure actuelle et le moment où le dernier enregistrement de l'appel `GetRecords` a été écrit dans le flux. Les statistiques Minimum et Maximum peuvent être utilisées pour suivre l'avancement des applications consommateur Kinesis. Une valeur de zéro indique que les enregistrements en cours de lecture sont totalement absorbés par le flux. Nom de la métrique au niveau des partitions : `IteratorAgeMilliseconds` Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Exemples Unités : millisecondes |
| GetRecords.Latency | Délai nécessaire par opération `GetRecords`, mesurée pendant la période spécifiée. Dimensions : StreamName Statistiques : Minimum, Maximum, moyenne Unités : millisecondes |
| GetRecords.Records | Nombre d'enregistrements extraits de la partition, mesurés pendant la période spécifiée. Les statistiques Minimum, Maximum et Moyenne représentent les enregistrements dans une même opération `GetRecords` pour le flux dans la période déterminée. Nom de la métrique au niveau des partitions : `OutgoingRecords` Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| GetRecords.Success | Nombre d'opérations `GetRecords` réussies par flux mesurées pendant la période spécifiée. Dimensions : StreamName Statistiques : Moyenne, Somme, Exemples Unités : nombre |
| IncomingBytes | Nombre d'octets placés avec succès dans le flux Kinesis au cours de la période spécifiée. Cette métrique inclut le nombre d'octets des opérations `PutRecord` et `PutRecords`. Les statistiques Minimum, Maximum et Moyenne représentent le nombre d'octets dans une même opération put pour le flux dans la période déterminée. Nom de la métrique au niveau des partitions : `IncomingBytes` Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : octets |
| IncomingRecords | Nombre d'enregistrements placés avec succès dans le flux Kinesis au cours de la période spécifiée. Cette métrique inclut le nombre d'enregistrements des opérations `PutRecord` et `PutRecords`. Les statistiques Minimum, Maximum et Moyenne représentent les enregistrements dans une même opération put pour le flux dans la période déterminée. Nom de la métrique au niveau des partitions : `IncomingRecords` Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| PutRecord.Bytes | Nombre d'octets placés dans le flux Kinesis à l'aide de l'opération `PutRecord` pendant la période spécifiée. Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : octets |
| PutRecord.Latency | Délai nécessaire par opération `PutRecord`, mesurée pendant la période spécifiée. Dimensions : StreamName Statistiques : Minimum, Maximum, moyenne Unités : millisecondes |
| PutRecord.Success | Nombre d'opérations `PutRecord` réussies par flux Kinesis mesurées pendant la période spécifiée. La moyenne représente le pourcentage d'opérations d'écriture réussies dans un flux. Dimensions : StreamName Statistiques : Moyenne, Somme, Exemples Unités : nombre |
| PutRecords.Bytes | Nombre d'octets placés dans le flux Kinesis à l'aide de l'opération `PutRecords` pendant la période spécifiée. Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : octets |
| PutRecords.Latency | Délai nécessaire par opération `PutRecords`, mesurée pendant la période spécifiée. Dimensions : StreamName Statistiques : Minimum, Maximum, moyenne Unités : millisecondes |
| PutRecords.Records | Cette métrique est obsolète. Utilisez `PutRecords.SuccessfulRecords`. Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| PutRecords.Success | Nombre d'opérations `PutRecords` où au moins un enregistrement a abouti, par flux Kinesis, mesurées pendant la période spécifiée. Dimensions : StreamName Statistiques : Moyenne, Somme, Exemples Unités : nombre |
| PutRecords.TotalRecords | Nombre total d'enregistrements envoyés à une opération `PutRecords` par flux de données Kinesis, mesuré sur la période spécifiée. Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| PutRecords.SuccessfulRecords | Nombre d'enregistrements réussis dans une opération `PutRecords` par flux de données Kinesis mesurés pendant la période spécifiée. Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| PutRecords.FailedRecords | Nombre d'enregistrements rejetés à cause de défaillances internes d'une opération `PutRecords` par flux de données Kinesis, mesuré sur la période spécifiée. Des défaillances internes occasionnelles peuvent survenir et doivent être réessayées. Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| PutRecords.ThrottledRecords | Nombre d'enregistrements rejetés à cause de limitations dans une opération `PutRecords` par flux de données Kinesis, mesuré sur la période spécifiée. Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| ReadProvisionedThroughputExceeded | Nombre d'appels `GetRecords` limités pour le flux au cours de la période spécifiée. La statistique la plus couramment utilisée pour cette métrique est Moyenne. Lorsque la statistique Minimum a une valeur de 1, tous les enregistrements ont été limités pour le flux au cours de la période spécifiée. Lorsque la statistique Maximum a une valeur de 0 (zéro), aucun enregistrement n'a été limité pour le flux au cours de la période spécifiée. Nom de la métrique au niveau des partitions : `ReadProvisionedThroughputExceeded` Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| SubscribeToShard.RateExceeded | Cette métrique est émise lorsqu'une nouvelle tentative d'abonnement échoue, car il existe déjà un abonnement actif par le même consommateur ou car vous dépassez le nombre d'appels par seconde autorisés pour cette opération.Dimensions : StreamName, ConsumerName |
| SubscribeToShard.Success | Cette métrique indique si l' SubscribeToShardabonnement a été établi avec succès. L'abonnement n'est actif que pendant 5 minutes maximum. Par conséquent, cette métrique est émise au moins une fois toutes les 5 minutes. Dimensions : StreamName, ConsumerName |
| SubscribeToShardEvent.Bytes | Nombre d'octets reçus de la partition, mesuré pendant la période spécifiée. Les statistiques Minimum, Maximum et Moyenne représentent les octets publiés dans un seul événement pour la période déterminée. Nom de la métrique au niveau des partitions : `OutgoingBytes` Dimensions : StreamName, ConsumerName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : octets |
| SubscribeToShardEvent.MillisBehindLatest | Le nombre de millisecondes pendant lesquelles les enregistrements lus se situent à partir de la fin du flux, indiquant à quel point le consommateur est en retard sur l'heure actuelle. Dimensions : StreamName, ConsumerName Statistiques : Minimum, Maximum, Moyenne, Exemples Unités : millisecondes |
| SubscribeToShardEvent.Records | Nombre d'enregistrements reçus de la partition, mesurés pendant la période spécifiée. Les statistiques Minimum, Maximum et Moyenne représentent les enregistrements dans un seul événement pour la période déterminée. Nom de la métrique au niveau des partitions : `OutgoingRecords` Dimensions : StreamName, ConsumerName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| SubscribeToShardEvent.Success | Cette métrique est émise chaque fois qu'un événement est publié avec succès. Elle est émise uniquement lorsqu'il existe un abonnement actif.Dimensions : StreamName, ConsumerNameStatistiques : Minimum, Maximum, Moyenne, Somme, ExemplesUnités : nombre |
| WriteProvisionedThroughputExceeded | Nombre d'enregistrements rejetés à cause de la limitation du flux au cours de la période spécifiée. Cette métrique inclut la limitation des opérations `PutRecord` et `PutRecords`. La statistique la plus couramment utilisée pour cette métrique est Moyenne. Lorsque la statistique Minimum a une valeur différente de zéro, les enregistrements ont été limités pour le flux au cours de la période spécifiée. Lorsque la statistique Maximum a une valeur de 0 (zéro), aucun enregistrement n'a été limité pour le flux au cours de la période spécifiée. Nom de la métrique au niveau des partitions : `WriteProvisionedThroughputExceeded` Dimensions : StreamName Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
### Mesures améliorées au niveau des partitions
L'espace de noms `AWS/Kinesis` inclut les métriques suivantes au niveau des partitions.
Kinesis envoie les mesures suivantes au niveau des partitions toutes les minutes. CloudWatch Chaque dimension métrique crée une CloudWatch métrique et effectue environ 43 200 appels d'`PutMetricData`API par mois. Ces métriques ne sont pas activées par défaut. Des frais sont associés aux métriques améliorées émises depuis Kinesis. Pour plus d'informations, consultez [Amazon CloudWatch Pricing](https://aws.amazon.com/cloudwatch/pricing/) sous la rubrique *Amazon CloudWatch Custom Metrics*. Les frais sont fournis par partition par métrique par mois.
| Métrique | Description |
| --- | --- |
| IncomingBytes | Nombre d'octets placés avec succès dans la partition au cours de la période spécifiée. Cette métrique inclut le nombre d'octets des opérations `PutRecord` et `PutRecords`. Les statistiques Minimum, Maximum et Moyenne représentent le nombre d'octets dans une même opération put pour la partition dans la période déterminée. Nom de la métrique au niveau des flux : `IncomingBytes` Dimensions : StreamName, ShardId Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : octets |
| IncomingRecords | Nombre d'enregistrements placés avec succès dans la partition au cours de la période spécifiée. Cette métrique inclut le nombre d'enregistrements des opérations `PutRecord` et `PutRecords`. Les statistiques Minimum, Maximum et Moyenne représentent les enregistrements dans une même opération put pour la partition dans la période déterminée. Nom de la métrique au niveau des flux : `IncomingRecords` Dimensions : StreamName, ShardId Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| IteratorAgeMilliseconds | Age du dernier enregistrement parmi tous les appels `GetRecords` effectués sur une partition, mesuré pendant la période spécifiée. L'âge est la différence entre l'heure actuelle et le moment où le dernier enregistrement de l'appel `GetRecords` a été écrit dans le flux. Les statistiques Minimum et Maximum peuvent être utilisées pour suivre l'avancement des applications consommateur Kinesis. Une valeur de 0 (zéro) indique que les enregistrements en cours de lecture sont totalement absorbés par le flux. Nom de la métrique au niveau des flux : `GetRecords.IteratorAgeMilliseconds` Dimensions : StreamName, ShardId Statistiques : Minimum, Maximum, Moyenne, Exemples Unités : millisecondes |
| OutgoingBytes | Nombre d'octets extraits de la partition, mesuré pendant la période spécifiée. Les statistiques Minimum, Maximum et Moyenne représentent le nombre d'octets renvoyés dans une même opération `GetRecords` ou publiés dans un seul événement `SubscribeToShard` pour la partition dans la période déterminée. Nom de la métrique au niveau des flux : `GetRecords.Bytes` Dimensions : StreamName, ShardId Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : octets |
| OutgoingRecords | Nombre d'enregistrements extraits de la partition, mesurés pendant la période spécifiée. Les statistiques Minimum, Maximum et Moyenne représentent le nombre d'enregistrements renvoyés dans une même opération `GetRecords` ou publiés dans un seul événement `SubscribeToShard` pour la partition dans la période déterminée. Nom de la métrique au niveau des flux : `GetRecords.Records` Dimensions : StreamName, ShardId Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| ReadProvisionedThroughputExceeded | Nombre d'appels `GetRecords` limités pour la partition au cours de la période spécifiée. Ce nombre d'exceptions couvre toutes les dimensions des limites suivantes : 5 lectures par partition par seconde ou 2 Mo par seconde par partition. La statistique la plus couramment utilisée pour cette métrique est Moyenne. Lorsque la statistique Minimum a une valeur de 1, tous les enregistrements ont été limités pour la partition au cours de la période spécifiée. Lorsque la statistique Maximum a une valeur de 0 (zéro), aucun enregistrement n'a été limité pour la partition au cours de la période spécifiée. Nom de la métrique au niveau des flux : `ReadProvisionedThroughputExceeded` Dimensions : StreamName, ShardId Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
| WriteProvisionedThroughputExceeded | Nombre d'enregistrements rejetés à cause de la limitation de la partition au cours de la période spécifiée. Cette métrique inclut la limitation des opérations `PutRecord` et `PutRecords` et couvre toutes les dimensions des limites suivantes : 1 000 enregistrements par seconde par partition ou 1 Mo par seconde par partition. La statistique la plus couramment utilisée pour cette métrique est Moyenne. Lorsque la statistique Minimum a une valeur différente de zéro, les enregistrements ont été limités pour la partition au cours de la période spécifiée. Lorsque la statistique Maximum a une valeur de 0 (zéro), aucun enregistrement n'a été limité pour la partition au cours de la période spécifiée. Nom de la métrique au niveau des flux : `WriteProvisionedThroughputExceeded` Dimensions : StreamName, ShardId Statistiques : Minimum, Maximum, Moyenne, Somme, Exemples Unités : nombre |
### Dimensions des métriques Amazon Kinesis Data Streams
| Dimension | Description |
| --- | --- |
| StreamName | Nom du flux Kinesis. Toutes les statistiques disponibles sont filtrées par `StreamName`. |
### Mesures Amazon Kinesis Data Streams recommandées
Certains indicateurs Amazon Kinesis Data Streams peuvent particulièrement intéresser les clients de Kinesis Data Streams. La liste suivante contient les métriques recommandées et leurs utilisations.
| Métrique | Notes d’utilisation |
| --- | --- |
| `GetRecords.IteratorAgeMilliseconds` | Suit la position de lecture sur toutes les partitions et applications consommateur du flux. Si l'ancienneté de l'itérateur dépasse 50 % de la période de conservation (par défaut 24 heures, configurable jusqu'à 7 jours), il y a un risque de perte de données suite à l'expiration des enregistrements. Nous vous recommandons d'utiliser des CloudWatch alarmes sur la statistique Maximum pour vous avertir avant que cette perte ne constitue un risque. Pour obtenir un exemple de scénario qui utilise cette métrique, consultez la page [Le traitement des dossiers des consommateurs prend du retard](troubleshooting-consumers.md#record-processing-falls-behind). |
| `ReadProvisionedThroughputExceeded` | Lorsque le traitement de votre enregistrement côté consommateur est en retard, il est parfois difficile de savoir où se situe le goulot d'étranglement. Utilisez cette métrique pour déterminer si vos lectures sont limitées suite au dépassement de vos limites de débit de lecture. La statistique la plus couramment utilisée pour cette métrique est Moyenne. |
| WriteProvisionedThroughputExceeded | Elle a le même objectif que la métrique ReadProvisionedThroughputExceeded mais du côté producteur (put) du flux. La statistique la plus couramment utilisée pour cette métrique est Moyenne. |
| PutRecord.Success, PutRecords.Success | Nous vous recommandons d'utiliser des CloudWatch alarmes sur la statistique Average pour indiquer à quel moment les enregistrements ne parviennent pas au flux. Sélectionnez un type put ou les deux en fonction de ce que votre producteur utilise. Si vous utilisez la bibliothèque Amazon Kinesis Producer (KPL), utilisez. PutRecords.Success |
| GetRecords.Success | Nous vous recommandons d'utiliser des CloudWatch alarmes sur la statistique Average pour indiquer quand les enregistrements du flux échouent. |
## Accédez aux CloudWatch métriques Amazon pour Kinesis Data Streams
Vous pouvez surveiller les métriques de Kinesis Data Streams à l'aide de CloudWatch la console, de la ligne de commande ou de CloudWatch l'API. Les procédures suivantes vous montrent comment accéder aux métriques à l'aide de ces différentes méthodes.
**Pour accéder aux métriques à l'aide de la CloudWatch console**
1. Ouvrez la CloudWatch console à l'adresse [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/).
1. Sélectionnez une région dans la barre de navigation.
1. Dans le panneau de navigation, sélectionnez **Métriques**.
1. Dans le volet **CloudWatch Metrics by Category**, sélectionnez **Kinesis** Metrics.
1. Cliquez sur la ligne correspondante pour afficher les statistiques pour les valeurs spécifiées **MetricName**et **StreamName**.
**Remarque :** La plupart des noms de statistiques de console correspondent aux noms de CloudWatch métriques correspondants répertoriés précédemment, à l'exception du débit de **lecture et du débit** d'**écriture**. Ces statistiques sont calculées sur des intervalles de 5 minutes : le **débit d'écriture** surveille la `IncomingBytes` CloudWatch métrique et le débit de lecture surveille le **débit de lecture**. `GetRecords.Bytes`
1. (Facultatif) Dans le volet graphique, sélectionnez une statistique et une période, puis créez une CloudWatch alarme à l'aide de ces paramètres.
**Pour accéder aux métriques à l'aide du AWS CLI**
Utilisez les [métriques et [get-metric-statistics](https://docs.aws.amazon.com/cli/latest/reference/cloudwatch/get-metric-statistics.html)les commandes de liste](https://docs.aws.amazon.com/cli/latest/reference/cloudwatch/list-metrics.html).
**Pour accéder aux métriques à l'aide de la CloudWatch CLI**
Utilisez les commandes [mon-list-metrics](https://docs.aws.amazon.com/AmazonCloudWatch/latest/cli/cli-mon-list-metrics.html) et [mon-get-stats](https://docs.aws.amazon.com/AmazonCloudWatch/latest/cli/cli-mon-get-stats.html).
**Pour accéder aux métriques à l'aide de l' CloudWatch API**
Utilisez les opérations [ListMetrics](https://docs.aws.amazon.com/AmazonCloudWatch/latest/APIReference/API_ListMetrics.html) et [GetMetricStatistics](https://docs.aws.amazon.com/AmazonCloudWatch/latest/APIReference/API_GetMetricStatistics.html).
# Surveillez l'état de santé des agents Kinesis Data Streams avec Amazon CloudWatch
L'agent publie des CloudWatch métriques personnalisées avec un espace de noms de **AWS KinesisAgent**. Ces métriques vous permettent d'évaluer si l'agent soumet des données dans Kinesis Data Streams comme spécifié, et s'il est sain, et utilise la quantité appropriée de ressources d'UC et de mémoire pour l'application qui produit les données. Les métriques telles que le nombre d'enregistrements et d'octets envoyés sont utiles pour comprendre le rythme auquel l'agent soumet des données au flux. Lorsque ces métriques deviennent inférieurs d'un certain pourcentage aux seuils attendus ou nulles, elles peuvent traduire des problèmes de configuration, des erreurs réseau ou des problèmes d'état de l'agent. Les métriques comme l'utilisation de l'UC ou de la mémoire sur l'hôte et les compteurs d'erreurs de l'agent indiquent l'utilisation des ressources de l'application productrice de données et donnent des informations sur la configuration potentielle ou les erreurs de l'hôte. Enfin, l'agent consigne également les exceptions au niveau du service pour mieux examiner les problèmes de l'agent. Ces métriques sont signalées dans la région spécifiée dans le paramètre de configuration de l'agent`cloudwatch.endpoint`. CloudWatch les métriques publiées par plusieurs agents Kinesis sont agrégées ou combinées. Pour en savoir plus sur la configuration de l'agent, consultez [Spécifiez les paramètres de configuration de l'agent](writing-with-agents.md#agent-config-settings).
## Moniteur avec CloudWatch
L'agent Kinesis Data Streams envoie les métriques CloudWatch suivantes à.
| Métrique | Description |
| --- | --- |
| BytesSent | Nombre d'octets envoyés à Kinesis Data Streams au cours de la période spécifiée. Unités : octets |
| RecordSendAttempts | Nombre d'enregistrements tentés (une première fois ou lors d'une nouvelle tentative) dans un appel de `PutRecords` au cours de la période spécifiée. Unités : nombre |
| RecordSendErrors | Nombre d'enregistrements qui ont renvoyé un état d'échec dans un appel de `PutRecords`, y compris les nouvelle tentatives, au cours de la période spécifiée. Unités : nombre |
| ServiceErrors | Nombre d'appels de `PutRecords` qui ont provoqué une erreur de service (autre qu'une erreur de limitation) au cours de la période spécifiée. Unités : nombre |
# Enregistrez les appels d'API Amazon Kinesis Data Streams avec AWS CloudTrail
Amazon Kinesis Data Streams est intégré AWS CloudTrailà un service qui fournit un enregistrement des actions effectuées par un utilisateur, un rôle ou AWS un service dans Kinesis Data Streams. CloudTrail capture tous les appels d'API pour Kinesis Data Streams sous forme d'événements. Les appels capturés incluent les appels de la console Kinesis Data Streams et les appels de code adressés aux opérations d'API Kinesis Data Streams. Si vous créez un suivi, vous pouvez activer la diffusion continue d' CloudTrail événements vers un compartiment Amazon S3, y compris des événements pour Kinesis Data Streams. Si vous ne configurez pas de suivi, vous pouvez toujours consulter les événements les plus récents dans la CloudTrail console dans **Historique des événements**. À l'aide des informations collectées par CloudTrail, vous pouvez déterminer la demande envoyée à Kinesis Data Streams, l'adresse IP à partir de laquelle la demande a été effectuée, l'auteur de la demande, la date à laquelle elle a été faite, ainsi que des informations supplémentaires.
Pour en savoir plus CloudTrail, notamment comment le configurer et l'activer, consultez le [guide de AWS CloudTrail l'utilisateur](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/).
## Informations sur Kinesis Data Streams dans CloudTrail
CloudTrail est activé sur votre AWS compte lorsque vous le créez. Lorsqu'une activité événementielle prise en charge se produit dans Kinesis Data Streams, cette activité est enregistrée dans CloudTrail un événement avec AWS d'autres événements de service **dans** l'historique des événements. Vous pouvez consulter, rechercher et télécharger les événements récents dans votre AWS compte. Pour plus d’informations, consultez [Affichage des événements avec l’historique des événements CloudTrail](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/view-cloudtrail-events.html).
Pour un enregistrement continu des événements de votre AWS compte, y compris des événements liés à Kinesis Data Streams, créez une trace. Un *suivi* permet CloudTrail de fournir des fichiers journaux à un compartiment Amazon S3. Par défaut, lorsque vous créez un parcours dans la console, celui-ci s'applique à toutes les AWS régions. Le journal enregistre les événements de toutes les régions de la AWS partition et transmet les fichiers journaux au compartiment Amazon S3 que vous spécifiez. En outre, vous pouvez configurer d'autres AWS services pour analyser plus en détail les données d'événements collectées dans les CloudTrail journaux et agir en conséquence. Pour plus d’informations, consultez les ressources suivantes :
+ [Vue d’ensemble de la création d’un journal d’activité](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-create-and-update-a-trail.html)
+ [CloudTrail Services et intégrations pris en charge](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-aws-service-specific-topics.html#cloudtrail-aws-service-specific-topics-integrations)
+ [Configuration des notifications Amazon SNS pour CloudTrail](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/getting_notifications_top_level.html)
+ [Réception de fichiers CloudTrail journaux de plusieurs régions](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/receive-cloudtrail-log-files-from-multiple-regions.html) et [réception de fichiers CloudTrail journaux de plusieurs comptes](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-receive-logs-from-multiple-accounts.html)
Kinesis Data Streams prend en charge l'enregistrement des actions suivantes sous forme d'événements CloudTrail dans des fichiers journaux :
+ [AddTagsToStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_AddTagsToStream.html)
+ [CreateStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_CreateStream.html)
+ [DecreaseStreamRetentionPeriod](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DecreaseStreamRetentionPeriod.html)
+ [DeleteStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DeleteStream.html)
+ [DeregisterStreamConsumer](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DeregisterStreamConsumer.html)
+ [DescribeStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DescribeStream.html)
+ [DescribeStreamConsumer](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DescribeStreamConsumer.html)
+ [DisableEnhancedMonitoring](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DisableEnhancedMonitoring.html)
+ [EnableEnhancedMonitoring](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_EnableEnhancedMonitoring.html)
+ [GetRecords](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html)
+ [GetShardIterator](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html)
+ [IncreaseStreamRetentionPeriod](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_IncreaseStreamRetentionPeriod.html)
+ [ListStreamConsumers](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_ListStreamConsumers.html)
+ [ListStreams](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_ListStreams.html)
+ [ListTagsForStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_ListTagsForStream.html)
+ [MergeShards](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_MergeShards.html)
+ [PutRecord](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html)
+ [PutRecords](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html)
+ [RegisterStreamConsumer](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_RegisterStreamConsumer.html)
+ [RemoveTagsFromStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_RemoveTagsFromStream.html)
+ [SplitShard](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_SplitShard.html)
+ [StartStreamEncryption](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_StartStreamEncryption.html)
+ [StopStreamEncryption](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_StopStreamEncryption.html)
+ [SubscribeToShard](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_SubscribeToShard.html)
+ [UpdateShardCount](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_UpdateShardCount.html)
+ [UpdateStreamMode](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_UpdateStreamMode.html)
Chaque événement ou entrée de journal contient des informations sur la personne ayant initié la demande. Les informations relatives à l’identité permettent de déterminer les éléments suivants :
+ Si la demande a été faite avec les informations d'identification de l'utilisateur root ou Gestion des identités et des accès AWS (IAM).
+ Si la demande a été effectuée avec les informations d’identification de sécurité temporaires d’un rôle ou d’un utilisateur fédéré.
+ Si la demande a été faite par un autre AWS service.
Pour plus d’informations, consultez la section [Élément userIdentity CloudTrail](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-event-reference-user-identity.html).
## Exemple : entrées du fichier journal Kinesis Data Streams
Un suivi est une configuration qui permet de transmettre des événements sous forme de fichiers journaux à un compartiment Amazon S3 que vous spécifiez. CloudTrail les fichiers journaux contiennent une ou plusieurs entrées de journal. Un événement représente une demande individuelle à partir d'une source quelconque et comprend des informations sur l'action demandée, sur tous les paramètres, les paramètres de la demande, etc. Les fichiers journaux CloudTrail ne sont pas des séries ordonnées retraçant les appels d'API publics. Ils ne suivent aucun ordre précis.
L'exemple suivant montre une entrée de CloudTrail journal qui illustre les `MergeShards` actions `CreateStream` `DescribeStream``ListStreams`,`DeleteStream`,`SplitShard`,, et.
```
{
"Records": [
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:16:31Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "CreateStream",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"shardCount": 1,
"streamName": "GoodStream"
},
"responseElements": null,
"requestID": "db6c59f8-c757-11e3-bc3b-57923b443c1c",
"eventID": "b7acfcd0-6ca9-4ee1-a3d7-c4e8d420d99b"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:17:06Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "DescribeStream",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"streamName": "GoodStream"
},
"responseElements": null,
"requestID": "f0944d86-c757-11e3-b4ae-25654b1d3136",
"eventID": "0b2f1396-88af-4561-b16f-398f8eaea596"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:15:02Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "ListStreams",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"limit": 10
},
"responseElements": null,
"requestID": "a68541ca-c757-11e3-901b-cbcfe5b3677a",
"eventID": "22a5fb8f-4e61-4bee-a8ad-3b72046b4c4d"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:17:07Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "DeleteStream",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"streamName": "GoodStream"
},
"responseElements": null,
"requestID": "f10cd97c-c757-11e3-901b-cbcfe5b3677a",
"eventID": "607e7217-311a-4a08-a904-ec02944596dd"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:15:03Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "SplitShard",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"shardToSplit": "shardId-000000000000",
"streamName": "GoodStream",
"newStartingHashKey": "11111111"
},
"responseElements": null,
"requestID": "a6e6e9cd-c757-11e3-901b-cbcfe5b3677a",
"eventID": "dcd2126f-c8d2-4186-b32a-192dd48d7e33"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:16:56Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "MergeShards",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"streamName": "GoodStream",
"adjacentShardToMerge": "shardId-000000000002",
"shardToMerge": "shardId-000000000001"
},
"responseElements": null,
"requestID": "e9f9c8eb-c757-11e3-bf1d-6948db3cd570",
"eventID": "77cf0d06-ce90-42da-9576-71986fec411f"
}
]
}
```
# Surveillez la bibliothèque cliente Kinesis avec Amazon CloudWatch
La [bibliothèque client Kinesis](https://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers-with-kcl.html) (KCL) pour Amazon Kinesis Data Streams publie des métriques CloudWatch Amazon personnalisées en votre nom, en utilisant le nom de votre application KCL comme espace de noms. Vous pouvez consulter ces statistiques en accédant à la [CloudWatch console](https://console.aws.amazon.com/cloudwatch/) et en choisissant **Mesures personnalisées**. Pour plus d'informations sur les métriques personnalisées, consultez [Publier des métriques personnalisées](https://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/publishingMetrics.html) dans le *guide de CloudWatch l'utilisateur Amazon*.
Des frais nominaux sont facturés pour les métriques téléchargées CloudWatch par la KCL ; en particulier, les frais *Amazon CloudWatch Custom Metrics* et *Amazon CloudWatch API Requests* s'appliquent. Pour plus d'informations, consultez [Amazon CloudWatch Pricing](https://aws.amazon.com/cloudwatch/pricing/).
**Topics**
+ [
## Métriques et espace de noms
](#metrics-namespace)
+ [
## Niveaux métriques et dimensions
](#metric-levels)
+ [
## Configuration métrique
](#metrics-config)
+ [
## Liste des métriques
](#kcl-metrics-list)
## Métriques et espace de noms
L'espace de noms utilisé pour charger les métriques est le nom d'application que vous spécifiez lorsque vous lancez la KCL.
## Niveaux métriques et dimensions
Deux options sont disponibles pour contrôler quelles métriques sont chargées dans CloudWatch :
niveaux de métriques
Chaque métrique se voit attribuer un niveau individuel. Lorsque vous définissez un niveau de rapport de mesures, les mesures dont le niveau individuel est inférieur au niveau de rapport ne sont pas envoyées à CloudWatch. Les niveaux sont : `NONE`, `SUMMARY` et `DETAILED`. Le paramètre par défaut est`DETAILED`, c'est-à-dire que toutes les métriques sont envoyées à CloudWatch. Un niveau de création de rapport `NONE` signifie qu'aucune métrique n'est envoyée. Pour plus d'informations sur les niveaux attribués aux métriques, consultez la page [Liste des métriques](#kcl-metrics-list).
dimensions activées
Chaque métrique KCL possède des dimensions associées qui sont également envoyées à CloudWatch. Dans la KCL 2.x, si la KCL est configurée pour traiter un seul flux de données, toutes les dimensions des métriques (`Operation`, `ShardId`, et`WorkerIdentifier`) sont activées par défaut. De plus, dans la KCL 2.x, si la KCL est configurée pour traiter un seul flux de données, la dimension `Operation` ne peut pas être désactivée. Dans KCL 2.x, si KCL est configuré pour traiter plusieurs flux de données, toutes les dimensions des métriques (`Operation`, `ShardId``StreamId`, et`WorkerIdentifier`) sont activées par défaut. De plus, dans KCL 2.x, si KCL est configuré pour traiter plusieurs flux de données, les `StreamId` dimensions `Operation` et ne peuvent pas être désactivées. `StreamId`la dimension n'est disponible que pour les métriques par partition.
Dans la KCL 1.x, seules les dimensions `Operation` et `ShardId` sont activées par défaut ; la dimension `WorkerIdentifier` est désactivée. Dans la KCL 1.x, la dimension `Operation` ne peut pas être désactivée.
Pour plus d'informations sur les dimensions CloudWatch métriques, consultez la section [Dimensions](https://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/cloudwatch_concepts.html#Dimension) de la rubrique Amazon CloudWatch Concepts du *guide de CloudWatch l'utilisateur Amazon*.
Lorsque la `WorkerIdentifier` dimension est activée, si une valeur différente est utilisée pour la propriété Worker ID chaque fois qu'un worker KCL particulier redémarre, de nouveaux ensembles de métriques avec de nouvelles valeurs de `WorkerIdentifier` dimension sont envoyés à. CloudWatch Si vous avez besoin que la valeur de dimension `WorkerIdentifier` soit égale pour tous les redémarrages d'application de travail KCL spécifiques, vous devez spécifier explicitement la même valeur d'ID d'application de travail lors de l'initialisation de chaque application de travail. Notez que la valeur d'ID d'application de travail de chaque application de travail KCL active doit être unique dans toutes les applications de travail KCL.
## Configuration métrique
Les niveaux métriques et les dimensions activées peuvent être configurés à l'aide de l' KinesisClientLibConfiguration instance, qui est transmise à Worker lors du lancement de l'application KCL. MultiLangDaemon Dans ce cas, les `metricsEnabledDimensions` propriétés `metricsLevel` et peuvent être spécifiées dans le fichier .properties utilisé pour lancer l'application MultiLangDaemon KCL.
Les niveaux des métriques peuvent se voir attribuer l'une des trois valeurs suivantes : NONE, SUMMARY ou DETAILED. Les valeurs de dimensions activées doivent être des chaînes séparées par des virgules avec la liste des dimensions autorisées pour les CloudWatch métriques. Les dimensions utilisées par l'application KCL sont `Operation`, `ShardId` et `WorkerIdentifier`.
## Liste des métriques
La liste de tables suivante répertorie les métriques KCL, regroupées par champ d'application et opération.
**Topics**
+ [
### Per-KCL-application métriques
](#kcl-metrics-per-app)
+ [
### Indicateurs par travailleur
](#kcl-metrics-per-worker)
+ [
### Métriques par partition
](#kcl-metrics-per-shard)
### Per-KCL-application métriques
Ces métriques sont agrégées pour tous les travailleurs KCL relevant du champ d'application de l'application, tels que définis par l'espace de CloudWatch noms Amazon.
**Topics**
+ [
#### LeaseAssignmentManager
](#lease-assignment-manager)
+ [
#### InitializeTask
](#init-task)
+ [
#### ShutdownTask
](#shutdown-task)
+ [
#### ShardSyncTask
](#shard-sync-task)
+ [
#### BlockOnParentTask
](#block-parent-task)
+ [
#### PeriodicShardSyncManager
](#periodic-task)
+ [
#### MultistreamTracker
](#multi-task)
#### LeaseAssignmentManager
L'`LeaseAssignmentManager`exploitation est chargée d'attribuer des baux aux travailleurs et de rééquilibrer les baux entre les travailleurs afin de parvenir à une utilisation uniforme des ressources humaines. La logique de cette opération inclut la lecture des métadonnées relatives aux baux dans le tableau des baux et des mesures du tableau des indicateurs du personnel, ainsi que l'exécution des assignations de bail.
| Métrique | Description |
| --- | --- |
| LeaseAndWorkerMetricsLoad.Heure | Temps nécessaire pour charger tous les baux et saisir les indicateurs relatifs aux employés dans le gestionnaire d'affectation des baux (LAM), le nouvel algorithme d'attribution des baux et d'équilibrage de charge introduit dans KCL 3.x. Niveau de métrique : Detailed Unités : millisecondes |
| TotalLeases | Nombre total de baux pour l'application KCL actuelle. Niveau de métrique : Summary Unités : nombre |
| NumWorkers | Nombre total de travailleurs dans l'application KCL actuelle. Niveau de métrique : Summary Unités : nombre |
| AssignExpiredOrUnassignedLeases.Heure | Il est temps d'attribuer en mémoire les baux expirés. Niveau de métrique : Detailed Unités : millisecondes |
| LeaseSpillover | Nombre de baux qui n'ont pas été attribués en raison de l'atteinte de la limite du nombre maximum de baux ou du débit maximal par travailleur. Niveau de métrique : Summary Unités : nombre |
| BalanceWorkerVariance.Heure | Il est temps de procéder à un équilibrage en mémoire des baux entre les travailleurs. Niveau de métrique : Detailed Unités : millisecondes |
| NumOfLeasesReassignment | Nombre total de réassignations de bail effectuées au cours de l'itération de réaffectation en cours. Niveau de métrique : Summary Unités : nombre |
| FailedAssignmentCount | Nombre d'échecs dans les AssignLease appels à la table des baux DynamoDB. Niveau de métrique : Detailed Unités : nombre |
| ParallelyAssignLeases.Heure | Il est temps d'ajouter les nouvelles affectations à la table des baux de DynamoDB. Niveau de métrique : Detailed Unités : millisecondes |
| ParallelyAssignLeases. Succès | Nombre de nouvelles missions réussies. Niveau de métrique : Detailed Unités : nombre |
| TotalStaleWorkerMetricsEntry | Nombre total d'entrées de mesures relatives aux travailleurs qui doivent être nettoyées. Niveau de métrique : Detailed Unités : nombre |
| StaleWorkerMetricsCleanup.Heure | Il est temps de supprimer les entrées des mesures de travail de la table des métriques de travail DynamoDB. Niveau de métrique : Detailed Unités : millisecondes |
| Heure | Temps consacré à l'`LeaseAssignmentManager`opération. Niveau de métrique : Summary Unités : millisecondes |
| Réussite | Nombre de fois que l'opération `LeaseAssignmentManager` a été effectuée avec succès. Niveau de métrique : Summary Unités : nombre |
| ForceLeaderRelease | Indique que le responsable de la cession des baux a échoué 3 fois de suite et que le principal travailleur est en train de libérer le leadership. Niveau de métrique : Summary Unités : nombre |
| NumWorkersWithInvalidEntry | Nombre d'entrées de métriques relatives aux travailleurs considérées comme non valides. Niveau de métrique : Summary Unités : nombre |
| NumWorkersWithFailingWorkerMetric | Nombre d'entrées de métriques du travailleur dont la valeur -1 (représentant la valeur de la métrique du travailleur n'est pas disponible) comme valeur des métriques du travailleur. Niveau de métrique : Summary Unités : nombre |
| LeaseDeserializationFailureCount | Entrée de bail depuis la table des baux qui n'a pas pu être désérialisée. Niveau de métrique : Summary Unités : nombre |
#### InitializeTask
L'opération `InitializeTask` est chargée d'initialiser le processeur d'enregistrements pour l'application KCL. La logique de cette opération implique d'extraire un itérateur de partition de Kinesis Data Streams et d'initialiser le processeur d'enregistrements.
| Métrique | Description |
| --- | --- |
| KinesisDataFetcher.getIterator.Success | Nombre d'opérations `GetShardIterator` réussies par application KCL. Niveau de métrique : Detailed Unités : nombre |
| KinesisDataFetcher.getIterator.Time | Délai nécessaire par opération `GetShardIterator` pour l'application KCL donnée. Niveau de métrique : Detailed Unités : millisecondes |
| RecordProcessor.Initialiser.time | Délai nécessaire pour la méthode d'initialisation du processeur d'enregistrements. Niveau de métrique : Summary Unités : millisecondes |
| Réussite | Nombre d'initialisations de processeur d'enregistrements réussies. Niveau de métrique : Summary Unités : nombre |
| Heure | Délai nécessaire pour l'initialisation du processeur d'enregistrements par l'application de travail KCL. Niveau de métrique : Summary Unités : millisecondes |
#### ShutdownTask
L'opération `ShutdownTask` initie la séquence de fermeture pour le traitement des partitions. Elle peut avoir lieu lorsqu'une partition est fractionnée ou fusionnée ou que le bail de la partition est perdu par l'application de travail. Dans les deux cas, la fonction `shutdown()` du processeur d'enregistrements est appelée. De nouvelles partitions sont également détectées si une partition a été fractionnée ou fusionnée, ce qui entraîne la création d'une ou de deux nouvelles partitions.
| Métrique | Description |
| --- | --- |
| CreateLease. Succès | Nombre de fois que les nouvelles partitions enfant sont ajoutées avec succès au tableau DynamoDB de l'application KCL suite à un arrêt de la partition parent. Niveau de métrique : Detailed Unités : nombre |
| CreateLease.Heure | Temps nécessaire pour ajouter de nouvelles informations de partition enfant au tableau DynamoDB de l'application KCL. Niveau de métrique : Detailed Unités : millisecondes |
| UpdateLease. Succès | Nombre de points de contrôle finaux réussis au cours de l'arrêt du processeur d'enregistrements. Niveau de métrique : Detailed Unités : nombre |
| UpdateLease.Heure | Délai nécessaire pour l'opération de point de contrôle au cours de l'arrêt du processeur d'enregistrements. Niveau de métrique : Detailed Unités : millisecondes |
| RecordProcessor.Heure d'arrêt | Délai nécessaire pour la méthode de fermeture du processeur d'enregistrements. Niveau de métrique : Summary Unités : millisecondes |
| Réussite | Nombre de tâches de fermeture réussies. Niveau de métrique : Summary Unités : nombre |
| Heure | Délai nécessaire pour la tâche d'arrêt de l'application de travail KCL. Niveau de métrique : Summary Unités : millisecondes |
#### ShardSyncTask
L'opération `ShardSyncTask` détecte les modifications apportées aux informations de partition pour le flux de données Kinesis. Ainsi, de nouvelles partitions peuvent être traitées par l'application KCL.
| Métrique | Description |
| --- | --- |
| CreateLease. Succès | Nombre de tentatives réussies pour ajouter de nouvelles informations de partition au tableau DynamoDB de l'application KCL. Niveau de métrique : Detailed Unités : nombre |
| CreateLease.Heure | Temps nécessaire pour ajouter de nouvelles informations de partition au tableau DynamoDB de l'application KCL. Niveau de métrique : Detailed Unités : millisecondes |
| Réussite | Nombre d'opérations de synchronisation de partitions réussies. Niveau de métrique : Summary Unités : nombre |
| Heure | Délai nécessaire pour l'opération de synchronisation des partitions. Niveau de métrique : Summary Unités : millisecondes |
#### BlockOnParentTask
Si la partition est fractionnée ou fusionnée avec d'autres partitions, de nouvelles partitions enfant sont créées. L'opération `BlockOnParentTask` garantit que le traitement des enregistrements des nouvelles partitions ne démarre pas tant que le traitement des partitions parent par la KCL n'est pas terminé.
| Métrique | Description |
| --- | --- |
| Réussite | Nombre de contrôles réussis pour l'achèvement de la partition parent. Niveau de métrique : Summary Unités : nombre |
| Heure | Temps nécessaire à la réalisation de partitions parent. Niveau de métrique : Summary Unité : millisecondes |
#### PeriodicShardSyncManager
Le `PeriodicShardSyncManager` est chargé d'examiner les flux de données traités par l'application client KCL, d'identifier les flux de données faisant l'objet de baux partiels et de les transférer pour synchronisation.
Les métriques suivantes sont disponibles lorsque KCL est configuré pour traiter un seul flux de données (la valeur de NumStreamsToSync et NumStreamsWithPartialLeases est alors définie sur 1) et également lorsque KCL est configuré pour traiter plusieurs flux de données.
| Métrique | Description |
| --- | --- |
| NumStreamsToSync | Nombre de flux de données (par AWS compte) traités par l'application client qui contient des baux partiels et qui doivent être transférés pour synchronisation. Niveau de métrique : Summary Unités : nombre |
| NumStreamsWithPartialLeases | Nombre de flux de données (par AWS compte) traités par l'application client et contenant des baux partiels. Niveau de métrique : Summary Unités : nombre |
| Réussite | Nombre de fois où `PeriodicShardSyncManager` a réussi à identifier des baux partiels dans les flux de données traités par l'application client. Niveau de métrique : Summary Unités : nombre |
| Heure | Temps (en millisecondes) `PeriodicShardSyncManager` nécessaire pour examiner les flux de données traités par l'application client afin de déterminer quels flux de données nécessitent une synchronisation des partitions. Niveau de métrique : Summary Unités : millisecondes |
#### MultistreamTracker
L'interface `MultistreamTracker` vous permet de créer des applications client KCL capables de traiter plusieurs flux de données en même temps.
| Métrique | Description |
| --- | --- |
| DeletedStreams. Compter | Nombre de flux de données supprimés au cours de cette période. Niveau de métrique : Summary Unités : nombre |
| ActiveStreams. Compter | Nombre de flux de données actifs en cours de traitement. Niveau de métrique : Summary Unités : nombre |
| StreamsPendingDeletion. Compter | Nombre de flux de données en attente de suppression en fonction de `FormerStreamsLeasesDeletionStrategy`. Niveau de métrique : Summary Unités : nombre |
### Indicateurs par travailleur
Ces métriques sont regroupées dans tous les processeurs d'enregistrements qui utilisent des données issues d'un flux de données Kinesis, par exemple d'une instance Amazon EC2.
**Topics**
+ [
#### WorkerMetricStatsReporter
](#worker-metrics-stats)
+ [
#### LeaseDiscovery
](#lease-discovery)
+ [
#### RenewAllLeases
](#renew-leases)
+ [
#### TakeLeases
](#take-leases)
#### WorkerMetricStatsReporter
L'`WorkerMetricStatReporter`opération est chargée de publier périodiquement les métriques du travailleur actuel dans le tableau des métriques du travailleur. Ces mesures sont utilisées par l'`LeaseAssignmentManager`opération pour effectuer les assignations de bail.
| Métrique | Description |
| --- | --- |
| InMemoryMetricStatsReporterFailure | Nombre d'échecs lors de la capture de la valeur de la métrique de travail en mémoire, en raison de l'échec de certaines métriques de travail. Niveau de métrique : Summary Unités : nombre |
| WorkerMetricStatsReporter.Heure | Temps consacré à l'`WorkerMetricsStats`opération. Niveau de métrique : Summary Unités : millisecondes |
| WorkerMetricStatsReporter. Succès | Nombre de fois que l'opération `WorkerMetricsStats` a été effectuée avec succès. Niveau de métrique : Summary Unités : nombre |
#### LeaseDiscovery
L'`LeaseDiscovery`opération est chargée d'identifier les nouveaux baux attribués au travailleur actuel par l'`LeaseAssignmentManager`opération. La logique de cette opération consiste à identifier les baux attribués au travailleur actuel en lisant l'index secondaire global de la table des baux.
| Métrique | Description |
| --- | --- |
| ListLeaseKeysForWorker.Heure | Il est temps d'appeler l'index secondaire global sur la table des baux et d'obtenir les clés de bail attribuées au travailleur actuel. Niveau de métrique : Detailed Unités : millisecondes |
| FetchNewLeases.Heure | Il est temps de récupérer tous les nouveaux baux dans le tableau des baux. Niveau de métrique : Detailed Unités : millisecondes |
| NewLeasesDiscovered | Nombre total de nouveaux baux attribués aux travailleurs. Niveau de métrique : Detailed Unités : nombre |
| Heure | Temps consacré à l'`LeaseDiscovery`opération. Niveau de métrique : Summary Unités : millisecondes |
| Réussite | Nombre de fois que l'opération `LeaseDiscovery` a été effectuée avec succès. Niveau de métrique : Summary Unités : nombre |
| OwnerMismatch | Nombre de défauts de correspondance entre les propriétaires résultant de la réponse du GSI et de la lecture cohérente du tableau des baux. Niveau de métrique : Detailed Unités : nombre |
#### RenewAllLeases
L'opération `RenewAllLeases` renouvelle périodiquement les baux de partition appartenant à une instance d'application de travail spécifique.
| Métrique | Description |
| --- | --- |
| RenewLease. Succès | Nombre de renouvellements de bail réussis par application de travail. Niveau de métrique : Detailed Unités : nombre |
| RenewLease.Heure | Délai nécessaire pour l'opération de renouvellement de bail. Niveau de métrique : Detailed Unités : millisecondes |
| CurrentLeases | Nombre de baux de partition appartenant à l'application de travail après le renouvellement de tous les baux. Niveau de métrique : Summary Unités : nombre |
| LostLeases | Nombre de baux de partition qui ont été perdus suite à une tentative de renouvellement de tous les baux appartenant à l'application de travail. Niveau de métrique : Summary Unités : nombre |
| Réussite | Nombre de fois où l'opération de renouvellement du bail a été couronnée de succès pour le travailleur. Niveau de métrique : Summary Unités : nombre |
| Heure | Délai nécessaire pour le renouvellement de tous les baux d'une application de travail. Niveau de métrique : Summary Unités : millisecondes |
#### TakeLeases
L'opération `TakeLeases` équilibre la charge du traitement des enregistrements entre toutes les applications de travail KCL. Si l'application de travail KCL actuelle possède moins de baux de partition que nécessaire, elle prend des baux de partition à une autre application de travail qui est surchargée.
| Métrique | Description |
| --- | --- |
| ListLeases. Succès | Nombre de fois que tous les baux de partition ont été extraits avec succès du tableau DynamoDB de l'application KCL. Niveau de métrique : Detailed Unités : nombre |
| ListLeases.Heure | Délai nécessaire pour l'extraction de tous les baux de partition depuis le tableau DynamoDB de l'application KCL. Niveau de métrique : Detailed Unités : millisecondes |
| TakeLease. Succès | Nombre de fois que l'application de travail a extrait avec succès des baux de partition d'autres applications de travail KCL. Niveau de métrique : Detailed Unités : nombre |
| TakeLease.Heure | Délai nécessaire pour la mise à jour de la table des baux avec les baux extraits par l'application de travail. Niveau de métrique : Detailed Unités : millisecondes |
| NumWorkers | Nombre total d'applications de travail identifiées par une application de travail spécifique. Niveau de métrique : Summary Unités : nombre |
| NeededLeases | Nombre de baux de partition dont l'application de travail actuelle a besoin pour que la charge de traitement des partitions soit équilibrée. Niveau de métrique : Detailed Unités : nombre |
| LeasesToTake | Nombre de baux que l'application de travail va tenter de prendre. Niveau de métrique : Detailed Unités : nombre |
| TakenLeases | Nombre de baux pris avec succès par l'application de travail. Niveau de métrique : Summary Unités : nombre |
| TotalLeases | Nombre total de partitions en cours de traitement par l'application KCL. Niveau de métrique : Detailed Unités : nombre |
| ExpiredLeases | Nombre total de partitions qui ne sont pas traitées par une application de travail, comme identifié par l'application de travail spécifique. Niveau de métrique : Summary Unités : nombre |
| Réussite | Nombre de fois que l'opération `TakeLeases` a été effectuée avec succès. Niveau de métrique : Summary Unités : nombre |
| Heure | Délai nécessaire pour l'opération `TakeLeases` effectuée par une application de travail. Niveau de métrique : Summary Unités : millisecondes |
### Métriques par partition
Ces métriques sont regroupées sur un processeur d'enregistrements unique.
#### ProcessTask
L'opération `ProcessTask` appelle [GetRecords](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html) avec la position d'itérateur actuelle pour extraire des enregistrements du flux et appeler la fonction `processRecords` du processeur d'enregistrements.
| Métrique | Description |
| --- | --- |
| KinesisDataFetcher.GetRecords.Success | Nombre d'opérations `GetRecords` réussies par partition de flux de données Kinesis. Niveau de métrique : Detailed Unités : nombre |
| KinesisDataFetcher.GetRecords.Time | Délai nécessaire par opération `GetRecords` pour la partition de flux de données Kinesis. Niveau de métrique : Detailed Unités : millisecondes |
| UpdateLease. Succès | Nombre de points de contrôle réussis effectués par le processeur d'enregistrements pour la partition donnée. Niveau de métrique : Detailed Unités : nombre |
| UpdateLease.Heure | Délai nécessaire pour chaque opération de point de contrôle pour la partition donnée. Niveau de métrique : Detailed Unités : millisecondes |
| DataBytesProcessed | Taille totale des enregistrements traités, en octets, à chaque invocation de `ProcessTask`. Niveau de métrique : Summary Unités : octet |
| RecordsProcessed | Nombre d'enregistrements traités à chaque invocation de `ProcessTask`. Niveau de métrique : Summary Unités : nombre |
| ExpiredIterator | Numéro ExpiredIteratorException reçu lors de l'appel`GetRecords`. Niveau de métrique : Summary Unités : nombre |
| MillisBehindLatest | Retard pris par l'itérateur actuel depuis le dernier enregistrement (extrémité) de la partition. Cette valeur est inférieure ou égale à la différence de temps entre le dernier enregistrement figurant dans une réponse et l'heure actuelle. Cela reflète plus précisément la distance entre un fragment et la pointe que la comparaison des horodatages dans le dernier enregistrement de réponse. Cette valeur s'applique au dernier lot d'enregistrements, et non à une moyenne de tous les horodatages de chaque enregistrement.Niveau de métrique : SummaryUnités : millisecondes |
| RecordProcessor.ProcessRecords.Time | Délai nécessaire pour la méthode `processRecords` du processeur d'enregistrements. Niveau de métrique : Summary Unités : millisecondes |
| Réussite | Nombre d'opérations de traitement réussies. Niveau de métrique : Summary Unités : nombre |
| Heure | Délai nécessaire pour l'opération de traitement. Niveau de métrique : Summary Unités : millisecondes |
# Surveillez la bibliothèque Kinesis Producer avec Amazon CloudWatch
L'[Amazon Kinesis Producer Library](https://docs.aws.amazon.com/kinesis/latest/dev/developing-producers-with-kpl.html) (KPL) pour Amazon Kinesis Data Streams publie des statistiques CloudWatch Amazon personnalisées en votre nom. Vous pouvez consulter ces statistiques en accédant à la [CloudWatch console](https://console.aws.amazon.com/cloudwatch/) et en choisissant **Mesures personnalisées**. Pour plus d'informations sur les métriques personnalisées, consultez [Publier des métriques personnalisées](https://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/publishingMetrics.html) dans le *guide de CloudWatch l'utilisateur Amazon*.
Des frais nominaux sont facturés pour les métriques téléchargées CloudWatch par le KPL ; en particulier, les frais Amazon CloudWatch Custom Metrics et Amazon CloudWatch API Requests s'appliquent. Pour plus d'informations, consultez [Amazon CloudWatch Pricing](https://aws.amazon.com/cloudwatch/pricing/). La collecte des métriques locales n'entraîne pas de frais CloudWatch.
**Topics**
+ [
## Métriques, dimensions et espaces de noms
](#kpl-metrics)
+ [
## Niveau métrique et granularité
](#kpl-metrics-granularity)
+ [
## Accès local et CloudWatch téléchargement sur Amazon
](#kpl-metrics-local-upload)
+ [
## Liste des métriques
](#kpl-metrics-list)
## Métriques, dimensions et espaces de noms
Vous pouvez spécifier un nom d'application lors du lancement de la KPL, lequel est alors utilisé pour l'espace de noms lors du chargement des métriques. C'est facultatif. La KPL fournit une valeur par défaut si aucun nom d'application n'est défini.
Vous pouvez également configurer la KPL pour ajouter des dimensions supplémentaires arbitraires aux métriques. Cela est utile si vous souhaitez intégrer des données plus précises à vos indicateurs. CloudWatch Par exemple, vous pouvez ajouter le nom d'hôte comme dimension pour identifier les répartitions de charge inégales dans votre flotte. Tous les paramètres de configuration KPL étant immuables, vous ne pouvez pas modifier ces dimensions supplémentaires après l'initialisation de l'instance KPL.
## Niveau métrique et granularité
Deux options sont disponibles pour contrôler le nombre de métriques chargées sans CloudWatch :
*niveau de métrique*
Le niveau de métrique sert à mesurer approximativement l'importance d'une métrique. Chaque métrique se voit attribuer un niveau. Lorsque vous définissez un niveau, les métriques dont les niveaux sont inférieurs ne sont pas envoyées à CloudWatch. Les niveaux sont : `NONE`, `SUMMARY` et `DETAILED`. Le paramètre par défaut est `DETAILED` ; c'est-à-dire, toutes les métriques. `NONE` signifie qu'il n'y a pas de métriques du tout, donc aucune métrique n'est réellement affectée à ce niveau.
*granularité*
La granularité contrôle si la même métrique est émise à des niveaux de granularité supplémentaires. Les niveaux sont : `GLOBAL`, `STREAM` et `SHARD`. La valeur par défaut est `SHARD`, qui contient les mesures les plus granulaires.
Lorsque `SHARD` est choisi, les métriques sont émises avec le nom du flux et l'ID de partition comme dimensions. En outre, la même métrique est également émise avec uniquement la dimension nom du flux et sans le nom du flux. Cela signifie que, pour une métrique donnée, deux flux contenant chacun deux partitions produiront sept CloudWatch métriques : une pour chaque partition, une pour chaque flux et une pour l'ensemble ; toutes décrivant les mêmes statistiques mais à des niveaux de granularité différents. Ces métriques sont illustrées dans le diagramme ci-dessous.
Les différents niveaux de granularité forment une hiérarchie et toutes les métriques du système forment des arborescences, partant des noms de métrique :
```
MetricName (GLOBAL): Metric X Metric Y
| |
----------------- ------------
| | | |
StreamName (STREAM): Stream A Stream B Stream A Stream B
| |
-------- ---------
| | | |
ShardID (SHARD): Shard 0 Shard 1 Shard 0 Shard 1
```
Les métriques ne sont pas toutes disponibles au niveau de la partition. Certaines sont disponibles au niveau du flux ou globales par nature. Elles ne sont pas générées au niveau de la partition même si vous avez activé les métriques au niveau de la partition (`Metric Y` dans le diagramme précédent).
Lorsque vous spécifiez une dimension supplémentaire, vous devez fournir des valeurs pour`tuple:`. La granularité sert à déterminer l'emplacement auquel la dimension personnalisée est insérée dans la hiérarchie : `GLOBAL` signifie que la dimension supplémentaire est ajoutée après le nom de la métrique, `STREAM` signifie qu'elle est insérée après le nom du flux, et `SHARD` signifie qu'elle est insérée après l'ID de partition. Si plusieurs dimensions supplémentaires sont indiquées par niveau de granularité, elles sont insérées dans l'ordre donné.
## Accès local et CloudWatch téléchargement sur Amazon
Des métriques sont disponibles localement et en temps réel pour l'instance KPL actuelle. Vous pouvez interroger la KPL à tout moment pour les obtenir. Le KPL calcule localement la somme, la moyenne, le minimum, le maximum et le nombre de chaque métrique, comme dans. CloudWatch
Vous pouvez obtenir des statistiques cumulatives du début du programme au moment présent, ou utiliser une fenêtre dynamique sur les dernières secondes *N*, où *N* est un nombre entier compris entre 1 et 60.
Toutes les statistiques peuvent être téléchargées vers CloudWatch. Cela est particulièrement utile pour regrouper les données figurant sur plusieurs hôtes, surveiller et produire des alarmes. Cette fonctionnalité n'est pas disponible localement.
Comme indiqué précédemment, vous pouvez sélectionner les métriques à charger avec les paramètres *niveau de métrique* et *granularité*. Les métriques qui ne sont pas chargées sont disponibles localement.
Le chargement individuel des points de données n'est pas acceptable, car il peut produire des millions de chargements par seconde, si le trafic est élevé. Pour cette raison, le KPL agrège les métriques localement dans des compartiments d'une minute et télécharge un objet de statistiques CloudWatch une fois par minute, par métrique activée.
## Liste des métriques
| Métrique | Description |
| --- | --- |
| UserRecordsReceived | Nombre d'enregistrements utilisateur logiques reçus par le noyau KPL pour les opérations put. Non disponible au niveau de la partition. Niveau de métrique : Detailed Unité : nombre |
| UserRecordsPending | Echantillon périodique indiquant le nombre d'enregistrements utilisateur actuellement en attente. Un enregistrement est en attente s'il est soit actuellement mis en mémoire tampon et en attente d'envoi, soit envoyé et envoyé en cours de transfert au service principal. Non disponible au niveau de la partition. La KPL fournit une méthode dédiée pour extraire cette métrique au niveau général pour permettre aux clients de gérer leur vitesse de placement des données. Niveau de métrique : Detailed Unité : nombre |
| UserRecordsPut | Nombre d'enregistrements utilisateur logiques placés avec succès. La KPL produit un zéro pour les enregistrements ayant échoué. Ainsi, la moyenne correspond au taux de réussite, le nombre correspond au nombre total de tentatives, et la différence entre le nombre et la somme correspond au nombre d'échecs. Niveau de métrique : Summary Unité : nombre |
| UserRecordsDataPut | Nombre d'octets des enregistrements utilisateur logique placés avec succès. Niveau de métrique : Detailed Unité : octets |
| KinesisRecordsPut | Nombre d'enregistrements Kinesis Data Streams placés avec succès (chaque enregistrement Kinesis Data Streams peut contenir plusieurs enregistrements utilisateur). La KPL produit un zéro pour les enregistrements ayant échoué. Ainsi, la moyenne correspond au taux de réussite, le nombre correspond au nombre total de tentatives, et la différence entre le nombre et la somme correspond au nombre d'échecs. Niveau de métrique : Summary Unité : nombre |
| KinesisRecordsDataPut | Octets au sein des enregistrements Kinesis Data Streams. Niveau de métrique : Detailed Unité : octets |
| ErrorsByCode | Nombre de chaque type de code d'erreur. C'est une autre dimension de `ErrorCode`, en plus des dimensions normales comme `StreamName` et `ShardId`. Les erreurs ne peuvent pas toutes être remontées dans une partition. Les erreurs qui ne peuvent pas être remontées ne sont émises qu'au niveau du flux ou au niveau général. Cette métrique capture les informations sur les éléments comme les limites, les modifications de mappage de partition, les défaillances internes, l'indisponibilité de service, les dépassements de délais; etc. Les erreurs provenant de l'API Kinesis Data Streams sont comptabilisées une fois par enregistrement Kinesis Data Streams. Les enregistrements utilisateur multiples dans un enregistrement Kinesis Data Streams ne génèrent pas de nombres multiples. Niveau de métrique : Summary Unité : nombre |
| AllErrors | Cette métrique est déclenchée par les mêmes erreurs que **Errors by Code (Erreurs par code)**, mais ne fait pas la distinction entre les différents types. Elle est très utile pour la surveillance générale du taux d'erreurs sans nécessiter la somme manuelle des chiffres des différents types d'erreurs. Niveau de métrique : Summary Unité : nombre |
| RetriesPerRecord | Nombre de tentatives effectuées par enregistrement utilisateur. Zéro est la valeur émise pour les enregistrements qui ont réussi dès la première tentative. Les données sont émises au moment où un enregistrement utilisateur se termine (lorsqu'il a réussi ou qu'il ne peut plus être réessayé). Si l'enregistrement time-to-live est une valeur importante, cette métrique peut être retardée de manière significative. Niveau de métrique : Detailed Unité : nombre |
| BufferingTime | Délai entre l'arrivée d'un enregistrement utilisateur à la KPL et son départ pour le serveur principal. Ces informations sont renvoyées à l'utilisateur pour chaque enregistrement par, mais sont également disponibles sous forme de statistique groupée. Niveau de métrique : Summary Unité : millisecondes |
| Request Time | Délai nécessaire pour exécuter `PutRecordsRequests`. Niveau de métrique : Detailed Unité : millisecondes |
| User Records per Kinesis Record | Nombre d'enregistrements utilisateur logiques regroupés en un seul enregistrement Kinesis Data Streams. Niveau de métrique : Detailed Unité : nombre |
| Amazon Kinesis Records per PutRecordsRequest | Nombre d'enregistrements Kinesis Data Streams logiques regroupés en un seul `PutRecordsRequest`. Non disponible au niveau de la partition. Niveau de métrique : Detailed Unité : nombre |
| User Records per PutRecordsRequest | Nombre total d'enregistrements utilisateur contenus dans une `PutRecordsRequest`. Il équivaut à peu près au produit des deux métriques précédentes. Non disponible au niveau de la partition. Niveau de métrique : Detailed Unité : nombre |