Исправление неточностей

This commit is contained in:
2025-08-09 21:52:45 +03:00
parent f87c036dfc
commit efb573c62c
+31 -20
View File
@@ -56,7 +56,7 @@ git clone https://github.com/dementev-dev/clickhouse-learning-cluster
cd clickhouse-learning-cluster cd clickhouse-learning-cluster
# Запускаем кластер # Запускаем кластер
docker compose up -d docker compose up
# Проверяем статус # Проверяем статус
docker compose ps docker compose ps
@@ -140,35 +140,46 @@ ENGINE = Distributed(c2sh2rep, default, user_scores_local, user_id);
-- Генерируем тестовые данные -- Генерируем тестовые данные
INSERT INTO user_scores INSERT INTO user_scores
SELECT SELECT
number % 100000 + 1 AS user_id, number % 10000000 + 1 AS user_id,
toFloat32(rand() % 50 + rand() % 50) / 10 AS avg_score, toFloat32(rand() % 50 + rand() % 50) / 10 AS avg_score,
now() - (number * 86400 / 1000) AS created_at now() - (number * 86400 / 1000) AS created_at
FROM numbers(100000); FROM numbers(10000000);
-- Проверяем распределение данных по шардам -- Проверяем распределение данных по шардам
SELECT SELECT
_shard_num AS shard_num, shardNum() AS shard_id,
hostName() AS host, count() AS rows_per_shard
count() AS rows FROM user_scores
FROM clusterAllReplicas('c2sh2rep', 'default', 'user_scores_local') GROUP BY shard_id
GROUP BY _shard_num, host ORDER BY shard_id;
ORDER BY _shard_num, host;
``` ```
### Мониторинг репликации ### Мониторинг репликации
```sql ```sql
-- Состояние репликационных очередей -- Состояние репликационных очередей
SELECT SELECT
database, hostName() AS host,
table, database,
replica_name, table,
total_replicas, replica_name,
active_replicas total_replicas,
FROM system.replicas; active_replicas,
is_leader,
is_readonly
FROM clusterAllReplicas('c2sh2rep', 'system', 'replicas')
ORDER BY host, table;
-- Лог репликации -- Лог репликации
SELECT * FROM system.replication_queue LIMIT 10; SELECT
hostName() AS host,
event_time,
table,
event_type, -- NewPart / MergeParts / DownloadPart и т.д.
part_name -- имя парты (универсальное поле)
FROM clusterAllReplicas('c2sh2rep', 'system', 'part_log')
ORDER BY event_time DESC
LIMIT 100;
``` ```
## 🛠️ Структура проекта ## 🛠️ Структура проекта