Saltar al contenido principal
Además de la monitorización desde la consola, ClickPipes expone métricas en un endpoint compatible con Prometheus para que puedan recopilarse. Estas métricas se publican junto con otras métricas del servicio de ClickHouse Cloud y permiten integrar la monitorización de ClickPipes con su pila de observabilidad existente (por ejemplo, Grafana, Datadog).

​
Etiquetas de métricas

Las métricas de ClickPipes usan las etiquetas estándar a nivel de servicio (clickhouse_org, clickhouse_service, clickhouse_service_name), además de las siguientes etiquetas específicas de ClickPipes:
EtiquetaDescripción
clickpipe_idEl identificador único del ClickPipe
clickpipe_nameEl nombre del ClickPipe
clickpipe_sourceEl tipo de origen (p. ej., kafka, postgres, s3)
clickpipe_stateEl estado del ClickPipe (p. ej., Stopped, Provisioning, Running)

​
Respuesta de ejemplo

A continuación se muestra el aspecto de las métricas de ClickPipes en una respuesta de scrape de Prometheus: 
# HELP ClickPipes_Info Siempre igual a 1. La etiqueta "clickpipe_state" contiene el estado actual del 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 Número total de registros obtenidos del origen.
# 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 Número total de registros enviados a 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 de bytes sin comprimir obtenidos del origen.
# 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 de bytes sin comprimir enviados a 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 de errores al ingestar datos.
# 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 Tiempo en milisegundos entre el momento en que se produjo el registro y el momento en que se escribió en 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étricas disponibles

​
Transferencia de datos

MétricaTipoDescripción
ClickPipes_FetchedBytes_TotalCounterTotal de bytes sin comprimir obtenidos del origen.
ClickPipes_FetchedBytesCompressed_TotalCounterTotal de bytes comprimidos obtenidos del origen. Si los datos del origen no están comprimidos, equivale a ClickPipes_FetchedBytes_Total.
ClickPipes_FetchedBytesInitialLoad_TotalCounterCDC ClickPipes Total de bytes sin comprimir obtenidos durante la fase de carga inicial.
ClickPipes_FetchedBytesResync_TotalCounterCDC ClickPipes Total de bytes sin comprimir obtenidos durante una operación de resincronización.
ClickPipes_SentBytes_TotalCounterTotal de bytes sin comprimir enviados a ClickHouse.
ClickPipes_SentBytesCompressed_TotalCounterTotal de bytes comprimidos enviados a ClickHouse.

​
Eventos y registros

MétricaTipoDescripción
ClickPipes_FetchedEvents_TotalCounterNúmero total de registros recuperados del origen.
ClickPipes_SentEvents_TotalCounterNúmero total de registros enviados a ClickHouse.
ClickPipes_FetchedEvents_PerTableGaugeCDC ClickPipes Número de registros recuperados por tabla de destino y tipo de evento. Utiliza las etiquetas adicionales destination_table y event_type.

​
Errores

MétricaTipoDescripción
ClickPipes_Errors_TotalContadorTotal de errores detectados durante la ingestión.

​
Latencia

MétricaTipoDescripción
ClickPipes_LatencyGauge (avg)Tiempo, en milisegundos, entre que un registro se genera en el origen y se escribe en ClickHouse.
ClickPipes_SourceReplicationLatency_MiBGauge (avg)CDC ClickPipes Retraso de replicación en el origen, en MiB. En Postgres ClickPipes, esto refleja el retraso del slot de replicación.

​
Uso de recursos

MétricaTipoDescripción
ClickPipes_Replica_CPUUsageGauge (avg)Uso promedio de CPU de las réplicas de ingestión, en milicores.
ClickPipes_Replica_CPULimitGauge (last)Límite de CPU configurado para las réplicas de ingestión, en milicores.
ClickPipes_Replica_MemoryUsageGauge (avg)Uso promedio de memoria de las réplicas de ingestión, en bytes.
ClickPipes_Replica_MemoryLimitGauge (last)Límite de memoria configurado para las réplicas de ingestión, en bytes.

​
Estado y progreso

MétricaTipoDescripción
ClickPipes_InfoGaugeSiempre es igual a 1. Usa la etiqueta clickpipe_state para filtrar o generar alertas sobre el estado del pipe.
ClickPipes_LastFetchedBatchIdGaugeID del último lote obtenido del origen.
ClickPipes_LastSentBatchIdGaugeID del último lote enviado a ClickHouse.
  • endpoint de Prometheus — Referencia del endpoint, autenticación y configuración para herramientas externas (p. ej., Grafana, Datadog)
  • Reporte de errores — Dónde se almacenan los errores de los registros y del sistema
Última modificación el 10 de junio de 2026