الانتقال إلى المحتوى الرئيسي
بالإضافة إلى المراقبة داخل Console، يوفّر ClickPipes مقاييس عبر نقطة نهاية متوافق مع Prometheus ليتم جمعها. تُنشر هذه المقاييس مع مقاييس خدمة ClickHouse Cloud الأخرى، وتتيح لك دمج مراقبة ClickPipes مع مكدس observability الحالي لديك (مثل Grafana وDatadog).

​
تسميات المقاييس

تستخدم مقاييس ClickPipes التسميات القياسية على مستوى الخدمة (clickhouse_org, clickhouse_service, clickhouse_service_name)، بالإضافة إلى تسميات ClickPipes التالية:
التسميةالوصف
clickpipe_idالمعرّف الفريد لـ ClickPipe
clickpipe_nameاسم ClickPipe
clickpipe_sourceنوع المصدر (على سبيل المثال: kafka أو postgres أو s3)
clickpipe_stateحالة ClickPipe (على سبيل المثال: Stopped أو Provisioning أو Running)

​
استجابة نموذجية

يوضح ما يلي شكل مقاييس ClickPipes في استجابة سحب من 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

​
المقاييس المتاحة

​
نقل البيانات

المقياسالنوعالوصف
ClickPipes_FetchedBytes_Totalعدادإجمالي البايتات غير المضغوطة التي جرى جلبها من المصدر.
ClickPipes_FetchedBytesCompressed_Totalعدادإجمالي البايتات المضغوطة التي جرى جلبها من المصدر. إذا كانت بيانات المصدر غير مضغوطة، فهذا يعادل ClickPipes_FetchedBytes_Total.
ClickPipes_FetchedBytesInitialLoad_TotalعدادCDC ClickPipes إجمالي البايتات غير المضغوطة التي جرى جلبها خلال مرحلة التحميل الأولي.
ClickPipes_FetchedBytesResync_TotalعدادCDC ClickPipes إجمالي البايتات غير المضغوطة التي جرى جلبها أثناء عملية إعادة المزامنة.
ClickPipes_SentBytes_Totalعدادإجمالي البايتات غير المضغوطة المُرسلة إلى ClickHouse.
ClickPipes_SentBytesCompressed_Totalعدادإجمالي البايتات المضغوطة المُرسلة إلى ClickHouse.

​
الأحداث والسجلات

المقياسالنوعالوصف
ClickPipes_FetchedEvents_Totalعدادإجمالي عدد السجلات التي تم جلبها من المصدر.
ClickPipes_SentEvents_Totalعدادإجمالي عدد السجلات التي تم إرسالها إلى ClickHouse.
ClickPipes_FetchedEvents_PerTableمقياسCDC ClickPipes عدد السجلات التي تم جلبها لكل جدول وجهة ولكل نوع حدث. يستخدم تسميتي destination_table وevent_type الإضافيتين.

​
الأخطاء

المقياسالنوعالوصف
ClickPipes_Errors_Totalعدّادإجمالي الأخطاء التي تمت مواجهتها أثناء الاستيعاب.

​
زمن الاستجابة

المقياسالنوعالوصف
ClickPipes_Latencyمقياس (avg)الوقت، بالمللي ثانية، بين إنشاء سجل في المصدر وكتابته إلى ClickHouse.
ClickPipes_SourceReplicationLatency_MiBمقياس (avg)CDC ClickPipes تأخر النسخ المتماثل في المصدر بوحدة MiB. بالنسبة إلى Postgres ClickPipes، يعكس هذا تأخر replication slot.

​
استخدام الموارد

مقياسالنوعالوصف
ClickPipes_Replica_CPUUsageمقياس (avg)متوسط استخدام CPU للنسخ المتماثلة الخاصة بالاستيعاب، بوحدة millicores.
ClickPipes_Replica_CPULimitمقياس (last)حد CPU المُعدّ للنسخ المتماثلة الخاصة بالاستيعاب، بوحدة millicores.
ClickPipes_Replica_MemoryUsageمقياس (avg)متوسط استخدام الذاكرة للنسخ المتماثلة الخاصة بالاستيعاب، بالبايت.
ClickPipes_Replica_MemoryLimitمقياس (last)حد الذاكرة المُعدّ للنسخ المتماثلة الخاصة بالاستيعاب، بالبايت.

​
الحالة والتقدم

المقياسالنوعالوصف
ClickPipes_Infoمقياسيساوي دائمًا 1. استخدم التسمية clickpipe_state للتصفية أو التنبيه استنادًا إلى حالة الـ pipe.
ClickPipes_LastFetchedBatchIdمقياسمعرّف آخر دفعة جرى جلبها من المصدر.
ClickPipes_LastSentBatchIdمقياسمعرّف آخر دفعة أُرسلت إلى ClickHouse.
آخر تعديل في ٢٩ يونيو ٢٠٢٦