Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Monitora il servizio Amazon Kinesis Data Streams con Amazon CloudWatch
Amazon Kinesis Data Streams e Amazon CloudWatch sono integrati in modo da poter raccogliere, visualizzare e analizzare le CloudWatch metriche per i tuoi flussi di dati Kinesis. Ad esempio, per tenere traccia dell'utilizzo degli shard, è possibile monitorare i parametri IncomingBytes e OutgoingBytes e confrontarli con il numero di shard nel flusso.
Le metriche di streaming e le metriche a livello di shard configurate vengono raccolte automaticamente e inviate ogni minuto. CloudWatch I parametri sono conservati per due settimane; dopo tale periodo, i dati vengono eliminati.
La tabella seguente descrive un monitoraggio di base a livello di flusso e un monitoraggio avanzato a livello di partizione per i flussi di dati Kinesis.
| Tipo | Description |
|---|---|
|
Monitoraggio di base (a livello di flusso) |
Stream-level i dati vengono inviati automaticamente ogni minuto senza alcun costo. |
|
Monitoraggio avanzato (a livello di shard) |
Shard-level i dati vengono inviati ogni minuto a un costo aggiuntivo. Per ottenere questo livello di dati, è necessario impostarlo specificamente per il flusso utilizzando l'operazione EnableEnhancedMonitoring. Per informazioni sui prezzi, consulta la pagina CloudWatch del prodotto Amazon |
Dimensioni e metriche di Amazon Kinesis Data Streams
Kinesis Data Streams invia le metriche a due livelli: il CloudWatch livello dello stream e, facoltativamente, il livello dello shard. Stream-level le metriche si riferiscono ai casi d'uso del monitoraggio più comuni in condizioni normali. Shard-level le metriche si riferiscono a specifiche attività di monitoraggio, in genere correlate alla risoluzione dei problemi, e sono abilitate utilizzando l'operazione. EnableEnhancedMonitoring
Per una spiegazione delle statistiche raccolte dalle CloudWatch metriche, consulta CloudWatch Statistics nella Amazon CloudWatch User Guide.
Argomenti
Metriche di base a livello di stream
Il namespace AWS/Kinesis include i parametri a livello di flusso descritti di seguito.
Kinesis Data Streams invia queste metriche a livello di flusso ogni minuto. CloudWatch Tali parametri sono sempre disponibili.
| Metrica | Description |
|---|---|
GetRecords.Bytes |
Il numero di byte recuperati dal flusso Kinesis misurati durante il periodo di tempo specificato. Le statistiche Minimo, Massimo e Media rappresentano i byte in un'unica operazione Shard-level nome della metrica: Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: byte |
GetRecords.IteratorAge |
Questa metrica non viene più utilizzata. Utilizza |
GetRecords.IteratorAgeMilliseconds |
L'età dell'ultimo record in tutte le chiamate Shard-level nome della metrica: Dimensioni: StreamName Statistiche: minimo, massimo, media, esempi Unità: millisecondi |
GetRecords.Latency |
Il tempo necessario per operazione Dimensioni: StreamName Statistiche: minimo, massimo, media Unità: millisecondi |
GetRecords.Records |
Il numero di record recuperati dallo shard, misurati durante il periodo di tempo specificato. Le statistiche Minimo, Massimo e Media rappresentano i record in un'unica operazione Shard-level nome metrico: Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
GetRecords.Success |
Il numero di operazioni Dimensioni: StreamName Statistiche: media, somma, esempi Unità: numero |
IncomingBytes |
Il numero di byte correttamente inseriti nel flusso Kinesis durante il periodo di tempo specificato. Questo parametro include i byte delle operazioni Shard-level nome metrico: Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: byte |
IncomingRecords |
Il numero di record inseriti correttamente nel flusso Kinesis durante il periodo di tempo specificato. Questo parametro include il numero di record delle operazioni Shard-level nome metrico: Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
PutRecord.Bytes |
Il numero di byte inseriti nel flusso Kinesis mediante l'operazione Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: byte |
PutRecord.Latency |
Il tempo necessario per operazione Dimensioni: StreamName Statistiche: minimo, massimo, media Unità: millisecondi |
PutRecord.Success |
Il numero di operazioni Dimensioni: StreamName Statistiche: media, somma, esempi Unità: numero |
PutRecords.Bytes |
Il numero di byte inseriti nel flusso Kinesis mediante l'operazione Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: byte |
PutRecords.Latency |
Il tempo necessario per operazione Dimensioni: StreamName Statistiche: minimo, massimo, media Unità: millisecondi |
PutRecords.Records |
Questo parametro è obsoleto. Utilizza Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
PutRecords.Success |
Il numero di operazioni Dimensioni: StreamName Statistiche: media, somma, esempi Unità: numero |
PutRecords.TotalRecords |
Il numero di record inviati in un'operazione Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
PutRecords.SuccessfulRecords |
Il numero di record riusciti in un'operazione Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
PutRecords.FailedRecords |
Il numero di record rifiutati a causa di errori interni in un'operazione Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
PutRecords.ThrottledRecords |
Il numero di record rifiutati a causa della limitazione in un'operazione Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
ReadProvisionedThroughputExceeded |
Il numero di chiamate Quando il valore della statistica Minimo è 1, tutti i record sono stati sottoposti a throttling per il flusso durante il periodo di tempo specificato. Quando il valore della statistica Massimo è 0 (zero), nessun record è stato sottoposto a throttling per il flusso durante il periodo di tempo specificato. Shard-level nome metrico: Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
SubscribeToShard.RateExceeded |
Questo parametro viene emesso quando un tentativo di nuovo abbonamento non va a buon fine perché è attivo un abbonamento dello stesso consumer oppure hai superato il numero di chiamate al secondo consentite per questa operazione. Dimensioni: StreamName, ConsumerName |
SubscribeToShard.Success |
Questa metrica registra se l' SubscribeToShardabbonamento è stato stabilito correttamente. L'abbonamento non dura più di 5 minuti. Pertanto, questa metrica viene emessa almeno una volta ogni 5 minuti. Dimensioni:, StreamName ConsumerName |
SubscribeToShardEvent.Bytes |
Il numero di byte ricevuti dallo shard, misurati durante il periodo di tempo specificato. Le statistiche Minimo, Massimo e Media rappresentano i byte pubblicati in un singolo evento per il periodo di tempo specificato. Shard-level nome della metrica: Dimensioni: StreamName, ConsumerName Statistiche: minimo, massimo, media, somma, esempi Unità: byte |
SubscribeToShardEvent.MillisBehindLatest |
Il numero di millisecondi in cui i record letti provengono dalla fine dello stream, indicando quanto è indietro l'ora corrente del consumatore. Dimensioni:, StreamName ConsumerName Statistiche: minimo, massimo, media, esempi Unità: millisecondi |
SubscribeToShardEvent.Records |
Il numero di record ricevuti dallo shard, misurati durante il periodo di tempo specificato. Le statistiche Minimo, Massimo e Media rappresentano i record pubblicati in un singolo evento per il periodo di tempo specificato. Shard-level nome della metrica: Dimensioni: StreamName, ConsumerName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
SubscribeToShardEvent.Success |
Questo parametro viene emesso ogni volta che un evento viene pubblicato correttamente. Viene emesso solo in presenza di un abbonamento attivo. Dimensioni: StreamName, ConsumerName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
WriteProvisionedThroughputExceeded |
Il numero di record rifiutati a causa del throttling per il flusso durante il periodo di tempo specificato. Questo parametro include il throttling delle operazioni Quando il valore della statistica Minimo non è 0 (zero), i record sono stati sottoposti a throttling per il flusso durante il periodo di tempo specificato. Quando il valore della statistica Massimo è 0 (zero), nessun record è stato sottoposto a throttling per il flusso durante il periodo di tempo specificato. Shard-level nome della metrica: Dimensioni: StreamName Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
Metriche migliorate a livello di frammento
Il namespace AWS/Kinesis include i parametri a livello di shard descritti di seguito.
Kinesis invia le seguenti metriche a livello di frammento ogni minuto. CloudWatch Ogni dimensione metrica crea 1 CloudWatch metrica ed effettua circa 43.200 chiamate API al mese. PutMetricData Per impostazione predefinita, tali parametri non sono attivati. I parametri avanzati emessi da Kinesis comportano un addebito. Per ulteriori informazioni, consulta Amazon CloudWatch Pricing nella
| Metrica | Description |
|---|---|
IncomingBytes |
Il numero di byte inseriti nello shard durante il periodo di tempo specificato. Questo parametro include i byte delle operazioni Stream-level nome della metrica: Dimensioni: StreamName, ShardId Statistiche: minimo, massimo, media, somma, esempi Unità: byte |
IncomingRecords |
Il numero di record inseriti nello shard durante il periodo di tempo specificato. Questo parametro include il numero di record delle operazioni Stream-level nome della metrica: Dimensioni: StreamName, ShardId Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
IteratorAgeMilliseconds |
L'età dell'ultimo record in tutte le chiamate Stream-level nome della metrica: Dimensioni: StreamName, ShardId Statistiche: minimo, massimo, media, esempi Unità: millisecondi |
OutgoingBytes |
Il numero di byte recuperati dallo shard, misurati durante il periodo di tempo specificato. Le statistiche Minimo, Massimo e Media rappresentano i byte restituiti in un'unica operazione Stream-level nome della metrica: Dimensioni: StreamName, ShardId Statistiche: minimo, massimo, media, somma, esempi Unità: byte |
OutgoingRecords |
Il numero di record recuperati dallo shard, misurati durante il periodo di tempo specificato. Le statistiche Minimo, Massimo e Media rappresentano i record restituiti in un'unica operazione Stream-level nome della metrica: Dimensioni: StreamName, ShardId Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
ReadProvisionedThroughputExceeded |
Il numero di chiamate Quando il valore della statistica Minimo è 1, tutti i record sono stati sottoposti a throttling per lo shard durante il periodo di tempo specificato. Quando il valore della statistica Massimo è 0 (zero), nessun record è stato sottoposto a throttling per lo shard durante il periodo di tempo specificato. Stream-level nome della metrica: Dimensioni: StreamName, ShardId Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
WriteProvisionedThroughputExceeded |
Il numero di record rifiutati a causa del throttling dello shard durante il periodo di tempo specificato. Questo parametro include il throttling delle operazioni Quando il valore della statistica Minimo non è 0 (zero), i record sono stati sottoposti a throttling per lo shard durante il periodo di tempo specificato. Quando il valore della statistica Massimo è 0 (zero), nessun record è stato sottoposto a throttling per lo shard durante il periodo di tempo specificato. Stream-level nome della metrica: Dimensioni: StreamName, ShardId Statistiche: minimo, massimo, media, somma, esempi Unità: numero |
Dimensioni per le metriche di Amazon Kinesis Data Streams
|
Dimensione |
Description |
|---|---|
StreamName
|
Il nome del flusso Kinesis. Tutte le statistiche disponibili vengono filtrate per |
Metriche consigliate di Amazon Kinesis Data Streams
Diversi parametri del flusso di dati Amazon Kinesis potrebbero essere di particolare interesse per i clienti del flusso di dati Kinesis. Il seguente elenco fornisce i parametri consigliati e i loro utilizzi.
| Metrica | Note per l'utilizzo |
|---|---|
|
|
Monitora la posizione di lettura di tutti gli shard e i consumatori nel flusso. Se l'età di un iteratore supera il 50% del periodo di conservazione (per impostazione predefinita, 24 ore, configurabile fino a 7 giorni), c'è il rischio di una perdita di dati a causa della scadenza del record. Ti consigliamo di utilizzare gli CloudWatch allarmi nella statistica Maximum per avvisarti prima che questa perdita diventi un rischio. Per uno scenario di esempio che utilizza questo parametro, consulta L'elaborazione dei record dei consumatori è in ritardo. |
|
|
Quando l'elaborazione di record nel lato del consumer è in ritardo, talvolta è difficile sapere dov'è il collo di bottiglia. Utilizza questo parametro per determinare se le operazioni di lettura vengono sottoposte a throttling a causa del fatto che superano i tuoi limiti di throughput di lettura. La statistica Media è quella più utilizzata per questo parametro. |
WriteProvisionedThroughputExceeded |
Ha lo stesso scopo del parametro ReadProvisionedThroughputExceeded ma per il lato del producer (put) del flusso. La statistica Media è quella più utilizzata per questo parametro. |
PutRecord.Success,
PutRecords.Success |
Consigliamo di utilizzare gli CloudWatch allarmi nella statistica Average per indicare quando i record non riescono ad accedere allo streaming. Scegli uno o entrambi i tipi di put, in base a ciò che utilizza il tuo producer. Se usi Amazon Kinesis Producer Library (KPL), usa. PutRecords.Success |
GetRecords.Success |
Consigliamo di utilizzare gli CloudWatch allarmi nella statistica Average per indicare quando i record non riescono a entrare nello stream. |
Accedi alle CloudWatch metriche Amazon per Kinesis Data Streams
Puoi monitorare le metriche per Kinesis Data Streams utilizzando la CloudWatch console, la riga di comando o l'API. CloudWatch Le procedure seguenti mostrano come accedere ai parametri utilizzando questi diversi metodi.
Per accedere alle metriche utilizzando la console CloudWatch
Apri la CloudWatch console all'indirizzo. https://console.aws.amazon.com/cloudwatch/
-
Nella barra di navigazione, scegli una regione.
-
Nel riquadro di navigazione, seleziona Parametri.
-
Nel riquadro CloudWatch Metriche per categoria, scegli Kinesis Metrics.
-
Fate clic sulla riga pertinente per visualizzare le statistiche relative alle specifiche e. MetricName StreamName
Nota: la maggior parte dei nomi delle statistiche delle console corrisponde ai nomi delle CloudWatch metriche corrispondenti elencati in precedenza, ad eccezione di Read Throughput e Write Throughput. Queste statistiche vengono calcolate su intervalli di 5 minuti: il throughput di scrittura monitora la
IncomingBytesCloudWatch metrica e il throughput di lettura monitora il throughput.GetRecords.Bytes -
(Facoltativo) Nel riquadro del grafico, seleziona una statistica e un periodo di tempo, quindi crea un CloudWatch allarme utilizzando queste impostazioni.
Per accedere alle metriche utilizzando AWS CLI
Utilizza i comandi list-metrics e get-metric-statistics.
Per accedere alle metriche utilizzando la CLI CloudWatch
Utilizza i comandi mon-list-metrics e mon-get-stats.
Per accedere alle metriche utilizzando l'API CloudWatch
Utilizzare le operazioni ListMetrics e GetMetricStatistics.
