Überwachen Sie die Kinesis-Clientbibliothek mit Amazon CloudWatch - Amazon-Kinesis-Data-Streams
Metriken und NamespaceMetrische Ebenen und DimensionenMetrische KonfigurationListe der Metriken

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Überwachen Sie die Kinesis-Clientbibliothek mit Amazon CloudWatch

Die Kinesis Client Library (KCL) für Amazon Kinesis Data Streams veröffentlicht in Ihrem Namen benutzerdefinierte CloudWatch Amazon-Metriken, wobei der Name Ihrer KCL Anwendung als Namespace verwendet wird. Sie können diese Metriken anzeigen, indem Sie zur CloudWatch Konsole navigieren und Benutzerdefinierte Metriken auswählen. Weitere Informationen zu benutzerdefinierten Metriken finden Sie unter Veröffentlichen benutzerdefinierter Metriken im CloudWatch Amazon-Benutzerhandbuch.

Für die CloudWatch von der hochgeladenen Metriken fällt eine geringe Gebühr an. Insbesondere KCL fallen Gebühren für Amazon CloudWatch Custom Metrics und Amazon CloudWatch API Requests an. Weitere Informationen finden Sie unter CloudWatch Amazon-Preise.

Metriken und Namespace

Der Namespace, der zum Hochladen von Metriken verwendet wird, ist der Anwendungsname, den Sie beim Starten von angeben. KCL

Metrische Ebenen und Dimensionen

Es gibt zwei Optionen, um zu steuern, in welche Metriken hochgeladen werden CloudWatch:

Metrikstufen

Jeder Metrik ist eine individuelle Stufe zugewiesen. Wenn Sie eine Berichtsebene für Kennzahlen festlegen, werden Metriken, deren individuelle Ebene unter der Berichtsebene liegt, nicht an diese gesendet CloudWatch. Die Stufen sind: NONE, SUMMARY und DETAILED. Die Standardeinstellung istDETAILED; das heißt, alle Metriken werden an gesendet CloudWatch. Die Berichtsstufe NONE bedeutet, dass keine Kennzahlen gesendet werden. Informationen dazu, welchen Metriken welche Stufen zugewiesen werden, finden Sie unter Liste der Metriken.

aktivierte Dimensionen

Jeder KCL Metrik sind Dimensionen zugeordnet, an die auch gesendet werden CloudWatch. Wenn in KCL 2.x für die Verarbeitung eines einzelnen Datenstroms konfiguriert KCL ist, sind alle Metrikdimensionen (OperationShardId, undWorkerIdentifier) standardmäßig aktiviert. Außerdem kann die Operation Dimension in KCL 2.x nicht deaktiviert werden, wenn sie für die Verarbeitung eines einzelnen Datenstroms konfiguriert KCL ist. In KCL 2.x sind alle Metrikdimensionen (,, undWorkerIdentifier) standardmäßig aktiviert Operation ShardIdStreamId, wenn KCL sie für die Verarbeitung mehrerer Datenströme konfiguriert ist. Außerdem können die Dimensionen und die StreamId Dimensionen in KCL 2.x nicht deaktiviert werden, wenn sie für die Operation Verarbeitung mehrerer Datenströme konfiguriert KCL ist. StreamIdDie Dimension ist nur für die Metriken pro Shard verfügbar.

In KCL 1.x sind standardmäßig nur die ShardId Dimensionen Operation und die Dimension aktiviert, und die WorkerIdentifier Dimension ist deaktiviert. In KCL 1.x kann die Operation Dimension nicht deaktiviert werden.

Weitere Informationen zu CloudWatch metrischen Dimensionen finden Sie im Abschnitt Dimensionen des Themas Amazon CloudWatch Concepts im CloudWatch Amazon-Benutzerhandbuch.

Wenn die WorkerIdentifier Dimension aktiviert ist und bei jedem Neustart eines bestimmten Workers ein anderer Wert für die KCL Worker-ID-Eigenschaft verwendet wird, werden neue Messwerte mit neuen WorkerIdentifier Dimensionswerten an CloudWatch gesendet. Wenn Sie möchten, dass der WorkerIdentifier Dimensionswert bei bestimmten KCL Worker-Neustarts identisch ist, müssen Sie bei der Initialisierung für jeden Worker explizit denselben Worker-ID-Wert angeben. Beachten Sie, dass der Worker-ID-Wert für jeden aktiven KCL Worker für alle KCL Worker eindeutig sein muss.

Metrische Konfiguration

Metrikebenen und aktivierte Dimensionen können mithilfe der KinesisClientLibConfiguration Instanz konfiguriert werden, die beim Starten der KCL Anwendung an Worker übergeben wird. In MultiLangDaemon diesem Fall können die metricsEnabledDimensions Eigenschaften metricsLevel und in der Datei .properties angegeben werden, die zum Starten der MultiLangDaemon KCL Anwendung verwendet wird.

Metrischen Ebenen kann einer von drei Werten zugewiesen werden: NONESUMMARY, oderDETAILED. Bei aktivierten Dimensionswerten muss es sich um kommagetrennte Zeichenketten mit der Liste der Dimensionen handeln, die für die CloudWatch Metriken zulässig sind. Die von der KCL Anwendung verwendeten Dimensionen sind OperationShardId, und. WorkerIdentifier

Liste der Metriken

In den folgenden Tabellen sind die KCL Metriken nach Umfang und Funktionsweise gruppiert aufgeführt.

Per-KCL-application Metriken

Diese Metriken werden für alle KCL Mitarbeiter innerhalb des Anwendungsbereichs aggregiert, wie im CloudWatch Amazon-Namespace definiert.

LeaseAssignmentManager

Der LeaseAssignmentManager Betrieb ist für die Zuweisung von Leasingverträgen an Arbeitnehmer und die Neuverteilung der Mietverträge zwischen den Mitarbeitern verantwortlich, um eine gleichmäßige Auslastung der Personalressourcen zu erreichen. Die Logik für diesen Vorgang umfasst das Lesen der Leasing-bezogenen Metadaten aus der Leasing-Tabelle und der Kennzahlen aus der Tabelle mit den Arbeitskräfte-Metriken sowie das Durchführen von Leasing-Zuweisungen.

Metrik Beschreibung

LeaseAndWorkerMetricsLoad. Zeit

Zeit, die benötigt wurde, um alle Leasingverträge und Worker-Metrik-Einträge im Lease Assignment Manager (LAM) zu laden, dem neuen Algorithmus für Leasingzuweisung und Lastenausgleich, der in KCL 3.x eingeführt wurde.

Metrikstufe: Detailed

Einheiten: Millisekunden
TotalLeases

Gesamtzahl der Leases für die aktuelle Anwendung. KCL

Metrikstufe: Summary

Einheiten: Anzahl
NumWorkers

Gesamtzahl der Arbeitnehmer in der aktuellen KCL Anwendung.

Metrikstufe: Summary

Einheiten: Anzahl

AssignExpiredOrUnassignedLeases. Zeit

Zeit für die In-Memory-Zuweisung abgelaufener Leases.

Metrikstufe: Detailed

Einheiten: Millisekunden
LeaseSpillover

Anzahl der Leases, die nicht zugewiesen wurden, weil das Limit für die maximale Anzahl von Leases oder den maximalen Durchsatz pro Mitarbeiter erreicht wurde.

Metrikstufe: Summary

Einheiten: Anzahl

BalanceWorkerVariance. Zeit

Zeit für den speicherinternen Ausgleich von Mietverträgen zwischen Mitarbeitern.

Metrikstufe: Detailed

Einheiten: Millisekunden

NumOfLeasesReassignment

Gesamtzahl der Neuzuweisungen von Leasingverträgen, die in der aktuellen Iteration der Neuzuweisung vorgenommen wurden.

Metrikstufe: Summary

Einheiten: Anzahl

FailedAssignmentCount

Anzahl der Fehler bei AssignLease Aufrufen der DynamoDB-Leasetabelle.

Metrikstufe: Detailed

Einheiten: Anzahl

ParallelyAssignLeases. Zeit

Zeit, neue Zuweisungen in die DynamoDB-Leasetabelle zu übernehmen.

Metrikstufe: Detailed

Einheiten: Millisekunden

ParallelyAssignLeases. Erfolg

Anzahl der erfolgreich abgewickelten Neuaufträge

Metrikstufe: Detailed

Einheiten: Anzahl

TotalStaleWorkerMetricsEntry

Gesamtzahl der Einträge mit Arbeitskennzahlen, die bereinigt werden müssen.

Metrikstufe: Detailed

Einheiten: Anzahl
StaleWorkerMetricsCleanup. Zeit

Zeit zum Löschen von Worker-Metrik-Einträgen aus der DynamoDB-Worker-Metriktabelle.

Metrikstufe: Detailed

Einheiten: Millisekunden
Zeit

Zeit, die der Vorgang in Anspruch genommen hat. LeaseAssignmentManager

Metrikstufe: Summary

Einheiten: Millisekunden
Herzlichen Glückwunsch

Häufigkeit des erfolgreichen Abschlusses der LeaseAssignmentManager-Operation.

Metrikstufe: Summary

Einheiten: Anzahl
ForceLeaderRelease

Zeigt an, dass der Leasingzuweisungsmanager dreimal hintereinander ausgefallen ist und der leitende Mitarbeiter die Führung freigibt.

Metrikstufe: Summary

Einheiten: Anzahl

NumWorkersWithInvalidEntry

Anzahl der Einträge für Arbeitskräftekennzahlen, die als ungültig angesehen werden.

Metrikstufe: Summary

Einheiten: Anzahl

NumWorkersWithFailingWorkerMetric

Anzahl der Einträge für Arbeitskräftekennzahlen, bei denen -1 (was bedeutet, dass ein Wert für die Arbeitskräftekennzahl nicht verfügbar ist) als einer der Werte für Arbeitskräftekennzahlen angegeben ist.

Metrikstufe: Summary

Einheiten: Anzahl

LeaseDeserializationFailureCount

Leasingeintrag aus der Leasingtabelle, der nicht deserialisiert werden konnte.

Metrikstufe: Summary

Einheiten: Anzahl

InitializeTask

Der InitializeTask Vorgang ist für die Initialisierung des Datensatzprozessors für die Anwendung verantwortlich. KCL Zur Logik dieser Operation gehört der Abruf eines Shard-Iterators von Kinesis Data Streams und die Initialisierung des Datensatzprozessors.

Metrik Beschreibung
KinesisDataFetcher. getIterator. Erfolg

Anzahl erfolgreicher GetShardIterator Operationen pro KCL Anwendung.

Metrikstufe: Detailed

Einheiten: Anzahl
KinesisDataFetcher. getIterator. Zeit

Zeit, die pro GetShardIterator Vorgang für die jeweilige KCL Anwendung benötigt wird.

Metrikstufe: Detailed

Einheiten: Millisekunden
RecordProcessor.initialize.TIME

Zeitbedarf für die Initialisierungsmethode des Datensatzprozessors.

Metrikstufe: Summary

Einheiten: Millisekunden
Herzlichen Glückwunsch

Anzahl der erfolgreichen Initialisierungen des Datensatzprozessors.

Metrikstufe: Summary

Einheiten: Anzahl
Zeit

Zeit, die der KCL Worker für die Initialisierung des Datensatzprozessors benötigt hat.

Metrikstufe: Summary

Einheiten: Millisekunden

ShutdownTask

Die - ShutdownTask Operation initiiert die Abschaltsequenz für die Shard-Verarbeitung. Dies kann auftreten, da ein Shard geteilt oder zusammengeführt ist, oder wenn das Shard-Lease vom Worker verloren ging. In beiden Fällen wird die Datensatzprozessorfunktion shutdown() aufgerufen. Neue Shards werden auch erkannt, wenn ein Shard geteilt oder zusammengeführt wurde, was zur Erstellung von einem oder zwei neuen Shards führt.

Metrik Beschreibung
CreateLease. Erfolg

Häufigkeit, mit der neue untergeordnete Shards nach dem Herunterfahren der übergeordneten Shard erfolgreich zur DynamoDB-Tabelle der KCL Anwendung hinzugefügt wurden.

Metrikstufe: Detailed

Einheiten: Anzahl
CreateLease.Zeit

Zeitaufwand für das Hinzufügen neuer untergeordneter Shard-Informationen zur KCL DynamoDB-Tabelle der Anwendung.

Metrikstufe: Detailed

Einheiten: Millisekunden
UpdateLease. Erfolg

Anzahl der erfolgreichen endgültigen Checkpoints während des Schließens des Datensatzprozessors.

Metrikstufe: Detailed

Einheiten: Anzahl
UpdateLease.Zeit

Zeitbedarf für die Checkpoint-Operation während des Schließens des Datensatzprozessors.

Metrikstufe: Detailed

Einheiten: Millisekunden
RecordProcessor.Herunterfahren.Zeit

Zeitbedarf für die Schließungsmethode des Datensatzprozessors.

Metrikstufe: Summary

Einheiten: Millisekunden
Herzlichen Glückwunsch

Anzahl der erfolgreichen Schließungsvorgänge.

Metrikstufe: Summary

Einheiten: Anzahl
Zeit

Zeit, die der KCL Worker für die Shutdown-Aufgabe benötigt hat.

Metrikstufe: Summary

Einheiten: Millisekunden

ShardSyncTask

Bei ShardSyncTask diesem Vorgang werden Änderungen an den Shard-Informationen für den Kinesis-Datenstrom erkannt, sodass neue Shards von der Anwendung verarbeitet werden können. KCL

Metrik Beschreibung
CreateLease. Erfolg

Anzahl erfolgreicher Versuche, der DynamoDB-Tabelle der KCL Anwendung neue Shard-Informationen hinzuzufügen.

Metrikstufe: Detailed

Einheiten: Anzahl
CreateLease. Zeit

Zeitaufwand für das Hinzufügen neuer Shard-Informationen zur KCL DynamoDB-Tabelle der Anwendung.

Metrikstufe: Detailed

Einheiten: Millisekunden
Herzlichen Glückwunsch

Anzahl der erfolgreichen Shard Synchronisierungsoperationen.

Metrikstufe: Summary

Einheiten: Anzahl
Zeit

Zeitbedarf für die Shard-Synchronisierungsoperation.

Metrikstufe: Summary

Einheiten: Millisekunden

BlockOnParentTask

Wenn der Shard geteilt oder mit anderen Shards zusammengeführt wird, werden neue untergeordnete Shards erstellt. Durch diesen BlockOnParentTask Vorgang wird sichergestellt, dass die Datensatzverarbeitung für die neuen Shards erst beginnt, wenn die übergeordneten Shards vollständig von der verarbeitet wurden. KCL

Metrik Beschreibung
Herzlichen Glückwunsch

Anzahl der erfolgreichen Prüfungen für den Abschluss der übergeordneten Shards.

Metrikstufe: Summary

Einheiten: Anzahl
Zeit

Zeitbedarf für den Abschluss der übergeordneten Shards.

Metrikstufe: Summary

Einheit: Millisekunden

PeriodicShardSyncManager

Der PeriodicShardSyncManager ist dafür verantwortlich, die Datenströme zu untersuchen, die von der KCL Verbraucheranwendung verarbeitet werden, Datenströme zu identifizieren, die teilweise ausgeliehen wurden, und sie zur Synchronisation weiterzuleiten.

Die folgenden Metriken sind verfügbar, wenn sie für die Verarbeitung eines einzelnen Datenstroms konfiguriert KCL NumStreamsWithPartialLeases ist (dann wird der Wert von NumStreamsToSync und auf 1 gesetzt) und auch, wenn sie für die Verarbeitung mehrerer Datenströme konfiguriert KCL ist.

Metrik Beschreibung
NumStreamsToSync

Die Anzahl der Datenströme (pro AWS Konto), die von der Verbraucheranwendung verarbeitet werden, die Teilleasingverträge enthält und die zur Synchronisation übergeben werden müssen.

Metrikstufe: Summary

Einheiten: Anzahl
NumStreamsWithPartialLeases

Die Anzahl der Datenströme (pro AWS Konto), die die Verbraucheranwendung verarbeitet, die Teilleasingverträge enthält.

Metrikstufe: Summary

Einheiten: Anzahl
Herzlichen Glückwunsch

Die Anzahl der Male, in denen PeriodicShardSyncManager erfolgreich Teil-Leases in den Datenströmen identifizieren konnte, die die Verbraucheranwendung verarbeitet.

Metrikstufe: Summary

Einheiten: Anzahl
Zeit

Die Zeit (in Millisekunden), die PeriodicShardSyncManager benötigt wird, um die Datenströme zu untersuchen, die die Verbraucheranwendung verarbeitet, um festzustellen, welche Datenströme eine Shard-Synchronisierung erfordern.

Metrikstufe: Summary

Einheiten: Millisekunden

MultistreamTracker

Die MultistreamTracker Schnittstelle ermöglicht es Ihnen, KCL Verbraucheranwendungen zu erstellen, die mehrere Datenströme gleichzeitig verarbeiten können.

Metrik Beschreibung
DeletedStreams. Zählen

Die Anzahl der in diesem Zeitraum gelöschten Datenströme.

Metrikstufe: Summary

Einheiten: Anzahl
ActiveStreams. Zählen

Die Anzahl der aktiven Datenströme, die verarbeitet werden.

Metrikstufe: Summary

Einheiten: Anzahl
StreamsPendingDeletion. Zählen

Die Anzahl der Datenströme, die aufgrund von FormerStreamsLeasesDeletionStrategy zur Löschung anstehen.

Metrikstufe: Summary

Einheiten: Anzahl

Kennzahlen pro Mitarbeiter

Diese Metriken werden für alle Datensatzprozessoren aggregiert, die Daten aus einem Kinesis-Datenstream, z. B. einer EC2 Amazon-Instance, verbrauchen.

WorkerMetricStatsReporter

Der WorkerMetricStatReporter Vorgang ist dafür verantwortlich, in regelmäßigen Abständen die Kennzahlen des aktuellen Mitarbeiters in der Tabelle mit den Mitarbeiter-Metriken zu veröffentlichen. Diese Kennzahlen werden vom LeaseAssignmentManager Vorgang zur Ausführung von Leasingaufträgen verwendet.

Metrik Beschreibung

InMemoryMetricStatsReporterFailure

Anzahl der Fehler bei der Erfassung des In-Memory-Worker-Metrikwerts, die auf einen Fehler bei einigen Worker-Metriken zurückzuführen sind.

Metrikstufe: Summary

Einheiten: Anzahl

WorkerMetricStatsReporter. Zeit

Zeit, die die WorkerMetricsStats Operation benötigt hat.

Metrikstufe: Summary

Einheiten: Millisekunden

WorkerMetricStatsReporter. Erfolg

Häufigkeit des erfolgreichen Abschlusses der WorkerMetricsStats-Operation.

Metrikstufe: Summary

Einheiten: Anzahl

LeaseDiscovery

Der LeaseDiscovery Vorgang ist dafür verantwortlich, die neuen Leasingverträge zu ermitteln, die dem aktuellen Mitarbeiter durch den LeaseAssignmentManager Vorgang zugewiesen wurden. Die Logik für diesen Vorgang besteht darin, Leasingverträge zu identifizieren, die dem aktuellen Mitarbeiter zugewiesen sind, indem der globale sekundäre Index der Leasingtabelle gelesen wird.

Metrik Beschreibung

ListLeaseKeysForWorker. Zeit

Zeit, den globalen sekundären Index für die Leasing-Tabelle aufzurufen und die Leasingschlüssel abzurufen, die dem aktuellen Worker zugewiesen wurden.

Metrikstufe: Detailed

Einheiten: Millisekunden

FetchNewLeases. Zeit

Zeit, alle neuen Leasingverträge aus der Leasing-Tabelle abzurufen.

Metrikstufe: Detailed

Einheiten: Millisekunden

NewLeasesDiscovered

Gesamtzahl der neuen Leasingverträge, die Arbeitnehmern zugewiesen wurden.

Metrikstufe: Detailed

Einheiten: Anzahl

Zeit

Für die LeaseDiscovery Operation benötigte Zeit.

Metrikstufe: Summary

Einheiten: Millisekunden

Herzlichen Glückwunsch

Häufigkeit des erfolgreichen Abschlusses der LeaseDiscovery-Operation.

Metrikstufe: Summary

Einheiten: Anzahl

OwnerMismatch

Anzahl der Eigentümer stimmt nicht mit der GSI Antwort und dem konsistenten Lesen der Leasingtabelle überein.

Metrikstufe: Detailed

Einheiten: Anzahl

RenewAllLeases

Die Operation RenewAllLeases erneuert periodisch alle Shard-Leases, die zu einer bestimmten Worker-Instance gehören.

Metrik Beschreibung
RenewLease. Erfolg

Anzahl der erfolgreichen Lease-Erneuerungen durch den Worker.

Metrikstufe: Detailed

Einheiten: Anzahl
RenewLease.Zeit

Zeitbedarf für die Operation der Lease-Erneuerung.

Metrikstufe: Detailed

Einheiten: Millisekunden
CurrentLeases

Anzahl der Shard-Leases, die einem Worker nach der Erneuerung aller Leases gehören.

Metrikstufe: Summary

Einheiten: Anzahl
LostLeases

Anzahl der Shard-Leases, die nach einem Versuch zur Erneuerung aller Leases eines Workers verloren gingen.

Metrikstufe: Summary

Einheiten: Anzahl
Herzlichen Glückwunsch

Wie oft der Vorgang zur Verlängerung des Mietvertrags für den Arbeitnehmer erfolgreich war.

Metrikstufe: Summary

Einheiten: Anzahl
Zeit

Zeitbedarf für die Erneuerung aller Leases für den Worker.

Metrikstufe: Summary

Einheiten: Millisekunden

TakeLeases

Bei diesem TakeLeases Vorgang wird die Verarbeitung von Datensätzen auf alle KCL Mitarbeiter verteilt. Wenn der aktuelle KCL Mitarbeiter weniger Shard-Leasingverträge als erforderlich hat, nimmt er Shard-Leasingverträge von einem anderen Mitarbeiter an, der überlastet ist.

Metrik Beschreibung
ListLeases. Erfolg

Häufigkeit, mit der alle Shard-Leases erfolgreich aus der DynamoDB-Tabelle der KCL Anwendung abgerufen wurden.

Metrikstufe: Detailed

Einheiten: Anzahl
ListLeases. Zeit

Zeit, die benötigt wurde, um alle Shard-Leases aus der DynamoDB-Tabelle der KCL Anwendung abzurufen.

Metrikstufe: Detailed

Einheiten: Millisekunden
TakeLease. Erfolg

Häufigkeit, mit der der Arbeiter erfolgreich Shard-Leasingverträge von anderen Mitarbeitern angenommen hat. KCL

Metrikstufe: Detailed

Einheiten: Anzahl
TakeLease. Zeit

Zeitbedarf für die Aktualisierung der Lease-.Tabelle mit Leases des Workers.

Metrikstufe: Detailed

Einheiten: Millisekunden
NumWorkers

Gesamtzahl der Worker, wie von einem spezifischen Worker definiert.

Metrikstufe: Summary

Einheiten: Anzahl
NeededLeases

Anzahl der Shard-Leases, die der aktuelle Worker für eine ausgeglichene Shard-Verarbeitungslast benötigt.

Metrikstufe: Detailed

Einheiten: Anzahl
LeasesToTake

Anzahl der Leases, die der Worker zu übernehmen versuchen wird.

Metrikstufe: Detailed

Einheiten: Anzahl
TakenLeases

Anzahl der von dem Worker erfolgreich übernommenen Leases.

Metrikstufe: Summary

Einheiten: Anzahl

TotalLeases

Gesamtzahl der Shards, die die KCL Anwendung verarbeitet.

Metrikstufe: Detailed

Einheiten: Anzahl
ExpiredLeases

Gesamtzahl der Shards, die nicht von einem Worker verarbeitet werden, wie von einem spezifischen Worker identifiziert.

Metrikstufe: Summary

Einheiten: Anzahl
Herzlichen Glückwunsch

Häufigkeit des erfolgreichen Abschlusses der TakeLeases-Operation.

Metrikstufe: Summary

Einheiten: Anzahl
Zeit

Zeitbedarf für die TakeLeases-Operation für einen Worker.

Metrikstufe: Summary

Einheiten: Millisekunden

Metriken pro Shard

Diese Metriken werden über einen einzigen Datensatzprozessor aggregiert.

ProcessTask

Die ProcessTask Operation ruft GetRecordsmit der aktuellen Iteratorposition auf, um Datensätze aus dem Stream abzurufen, und ruft die Datensatzprozessorfunktion auf. processRecords

Metrik Beschreibung
KinesisDataFetcher. getRecords. Erfolg

Anzahl der erfolgreichen GetRecords-Operationen pro Kinesis-Datenstrom-Shard.

Metrikstufe: Detailed

Einheiten: Anzahl
KinesisDataFetcher. getRecords. Zeit

Zeitbedarf für die GetRecords-Operation für den Kinesis-Datenstrom-Shard.

Metrikstufe: Detailed

Einheiten: Millisekunden
UpdateLease.Erfolg

Anzahl der erfolgreichen Checkpoints durch den Datensatzprozessor für einen bestimmten Shard.

Metrikstufe: Detailed

Einheiten: Anzahl
UpdateLease.Zeit

Zeitbedarf für jede Checkpoint-Operation eines bestimmten Shards.

Metrikstufe: Detailed

Einheiten: Millisekunden
DataBytesProcessed

Gesamtgröße der verarbeiteten Datensätze in Byte bei jedem ProcessTask-Aufruf.

Metrikstufe: Summary

Einheiten: Byte
RecordsProcessed

Anzahl der bei jedem ProcessTask-Aufruf verarbeiteten Datensätze.

Metrikstufe: Summary

Einheiten: Anzahl
ExpiredIterator

Nummer der beim Anruf ExpiredIteratorException GetRecords empfangenen Personen.

Metrikstufe: Summary

Einheiten: Anzahl
MillisBehindLatest Zeitraum, um den der aktuelle Iterator seit dem letzten Datensatz (Tip) in dem Shard verspätet ist. Dieser Wert ist kleiner oder gleich der Zeitdifferenz zwischen dem letzten Datensatz in einer Antwort und dem aktuellen Zeitpunkt. Dies ist ein genaueres Bild davon, wie weit ein Shard von der Spitze entfernt ist, als der Vergleich der Zeitstempel im letzten Antwortdatensatz. Dieser Wert bezieht sich auf den letzten Stapel von Datensätzen, nicht auf den Durchschnitt aller Zeitstempel in jedem Datensatz.

Metrikstufe: Summary

Einheiten: Millisekunden
RecordProcessor. processRecords. Zeit

Zeitbedarf für die processRecords-Methode des Datensatzprozessors.

Metrikstufe: Summary

Einheiten: Millisekunden
Herzlichen Glückwunsch

Anzahl der erfolgreichen Verarbeitungsaufgabenoperationen.

Metrikstufe: Summary

Einheiten: Anzahl
Zeit

Zeitbedarf für die Verarbeitungsaufgabenoperation.

Metrikstufe: Summary

Einheiten: Millisekunden