Passer au contenu principal
En plus de la surveillance dans la Console, ClickPipes expose des métriques via un endpoint compatible Prometheus pour le scraping. Ces métriques sont publiées avec les autres métriques du service ClickHouse Cloud et vous permettent d’intégrer la surveillance de ClickPipes à votre stack d’observabilité existante (par ex. Grafana, Datadog).

​
Labels de métriques

Les métriques ClickPipes utilisent les labels standard de niveau service (clickhouse_org, clickhouse_service, clickhouse_service_name), ainsi que les labels spécifiques à ClickPipes suivants :
LabelDescription
clickpipe_idL’identifiant unique du ClickPipe
clickpipe_nameLe nom du ClickPipe
clickpipe_sourceLe type de source (par ex. kafka, postgres, s3)
clickpipe_stateL’état du ClickPipe (par ex. Stopped, Provisioning, Running)

​
Exemple de réponse

Voici à quoi ressemblent les métriques ClickPipes dans une réponse de scraping Prometheus : 
# HELP ClickPipes_Info Always equal to 1. Label "clickpipe_state" contains the current state of the pipe: Stopped/Provisioning/Running/Paused/Failed
# TYPE ClickPipes_Info gauge
ClickPipes_Info{clickhouse_org="11dfa1ec-767d-43cb-bfad-618ce2aaf959",clickhouse_service="82b83b6a-5568-4a82-aa78-fed9239db83f",clickhouse_service_name="my service",clickpipe_id="642bb967-940b-459e-9f63-a2833f62ec44",clickpipe_name="my kafka pipe",clickpipe_source="confluent",clickpipe_state="Running"} 1

# HELP ClickPipes_FetchedEvents_Total Total number of records fetched from the source.
# TYPE ClickPipes_FetchedEvents_Total counter
ClickPipes_FetchedEvents_Total{clickhouse_org="11dfa1ec-767d-43cb-bfad-618ce2aaf959",clickhouse_service="82b83b6a-5568-4a82-aa78-fed9239db83f",clickhouse_service_name="my service",clickpipe_id="642bb967-940b-459e-9f63-a2833f62ec44",clickpipe_name="my kafka pipe",clickpipe_source="confluent"} 5535376

# HELP ClickPipes_SentEvents_Total Total number of records sent to ClickHouse
# TYPE ClickPipes_SentEvents_Total counter
ClickPipes_SentEvents_Total{clickhouse_org="11dfa1ec-767d-43cb-bfad-618ce2aaf959",clickhouse_service="82b83b6a-5568-4a82-aa78-fed9239db83f",clickhouse_service_name="my service",clickpipe_id="642bb967-940b-459e-9f63-a2833f62ec44",clickpipe_name="my kafka pipe",clickpipe_source="confluent"} 5534250

# HELP ClickPipes_FetchedBytes_Total Total uncompressed bytes fetched from the source.
# TYPE ClickPipes_FetchedBytes_Total counter
ClickPipes_FetchedBytes_Total{clickhouse_org="11dfa1ec-767d-43cb-bfad-618ce2aaf959",clickhouse_service="82b83b6a-5568-4a82-aa78-fed9239db83f",clickhouse_service_name="my service",clickpipe_id="642bb967-940b-459e-9f63-a2833f62ec44",clickpipe_name="my kafka pipe",clickpipe_source="confluent"} 873286202

# HELP ClickPipes_SentBytes_Total Total uncompressed bytes sent to ClickHouse.
# TYPE ClickPipes_SentBytes_Total counter
ClickPipes_SentBytes_Total{clickhouse_org="11dfa1ec-767d-43cb-bfad-618ce2aaf959",clickhouse_service="82b83b6a-5568-4a82-aa78-fed9239db83f",clickhouse_service_name="my service",clickpipe_id="642bb967-940b-459e-9f63-a2833f62ec44",clickpipe_name="my kafka pipe",clickpipe_source="confluent"} 477187967

# HELP ClickPipes_Errors_Total Total errors ingesting data.
# TYPE ClickPipes_Errors_Total counter
ClickPipes_Errors_Total{clickhouse_org="11dfa1ec-767d-43cb-bfad-618ce2aaf959",clickhouse_service="82b83b6a-5568-4a82-aa78-fed9239db83f",clickhouse_service_name="my service",clickpipe_id="642bb967-940b-459e-9f63-a2833f62ec44",clickpipe_name="my kafka pipe",clickpipe_source="confluent"} 0

# HELP ClickPipes_Latency Time in milliseconds between when the record was produced to when it was written to ClickHouse.
# TYPE ClickPipes_Latency gauge
ClickPipes_Latency{clickhouse_org="11dfa1ec-767d-43cb-bfad-618ce2aaf959",clickhouse_service="82b83b6a-5568-4a82-aa78-fed9239db83f",clickhouse_service_name="my service",clickpipe_id="642bb967-940b-459e-9f63-a2833f62ec44",clickpipe_name="my kafka pipe",clickpipe_source="confluent"} 340

​
Métriques disponibles

​
Transfert de données

MétriqueTypeDescription
ClickPipes_FetchedBytes_TotalCompteurNombre total d’octets non compressés récupérés depuis la source.
ClickPipes_FetchedBytesCompressed_TotalCompteurNombre total d’octets compressés récupérés depuis la source. Si les données source ne sont pas compressées, cette valeur est équivalente à ClickPipes_FetchedBytes_Total.
ClickPipes_FetchedBytesInitialLoad_TotalCompteurCDC ClickPipes Nombre total d’octets non compressés récupérés pendant la phase de chargement initial.
ClickPipes_FetchedBytesResync_TotalCompteurCDC ClickPipes Nombre total d’octets non compressés récupérés lors d’une opération de resynchronisation.
ClickPipes_SentBytes_TotalCompteurNombre total d’octets non compressés envoyés à ClickHouse.
ClickPipes_SentBytesCompressed_TotalCompteurNombre total d’octets compressés envoyés à ClickHouse.

​
Événements et enregistrements

MétriqueTypeDescription
ClickPipes_FetchedEvents_TotalCompteurNombre total d’enregistrements récupérés depuis la source.
ClickPipes_SentEvents_TotalCompteurNombre total d’enregistrements envoyés à ClickHouse.
ClickPipes_FetchedEvents_PerTableGaugeCDC ClickPipes Nombre d’enregistrements récupérés par table de destination et par type d’événement. Utilise des labels supplémentaires destination_table et event_type.

​
Erreurs

MétriqueTypeDescription
ClickPipes_Errors_TotalCompteurNombre total d’erreurs survenues lors de l’ingestion.

​
Latence

MétriqueTypeDescription
ClickPipes_LatencyGauge (avg)Temps écoulé, en millisecondes, entre le moment où un enregistrement est produit à la source et celui où il est écrit dans ClickHouse.
ClickPipes_SourceReplicationLatency_MiBGauge (avg)CDC ClickPipes Retard de réplication à la source, en Mio. Pour les ClickPipes Postgres, cela correspond au retard du slot de réplication.

​
Utilisation des ressources

MétriqueTypeDescription
ClickPipes_Replica_CPUUsageGauge (avg)Utilisation moyenne du CPU des réplicas d’ingestion, en millicœurs.
ClickPipes_Replica_CPULimitGauge (last)Limite de CPU configurée pour les réplicas d’ingestion, en millicœurs.
ClickPipes_Replica_MemoryUsageGauge (avg)Utilisation moyenne de la mémoire des réplicas d’ingestion, en octets.
ClickPipes_Replica_MemoryLimitGauge (last)Limite de mémoire configurée pour les réplicas d’ingestion, en octets.

​
État et progression

MétriqueTypeDescription
ClickPipes_InfoGaugeToujours égal à 1. Utilisez le label clickpipe_state pour filtrer ou déclencher une alerte selon l’état du pipe.
ClickPipes_LastFetchedBatchIdGaugeID du dernier batch récupéré depuis la source.
ClickPipes_LastSentBatchIdGaugeID du dernier batch envoyé à ClickHouse.
  • Endpoint Prometheus — Référence de l’endpoint, authentification et configuration pour les outils externes (p. ex., Grafana, Datadog)
  • Signalement des erreurs — Emplacement de stockage des erreurs liées aux enregistrements et des erreurs système
Dernière modification le 29 juin 2026