// Monitoring shard load
async function monitorShardLoad() {
  const metrics = await Promise.all(
    shards.map(async (shard, idx) => ({
      shardId: idx,
      qps: await shard.getMetric('queries_per_second'),
      cpuPercent: await shard.getMetric('cpu_utilization'),
      diskIO: await shard.getMetric('disk_io_ops')
    }))
  );

  const avgQps = metrics.reduce((s, m) => s + m.qps, 0) / metrics.length;

  metrics.forEach(m => {
    if (m.qps > avgQps * 2) {
      alert(`Hotspot detected on shard ${m.shardId}: ${m.qps} QPS vs avg ${avgQps}`);
    }
  });
}

Database Sharding — פיצול מסדי נתונים

Database Sharding — פיצול מסדי נתונים

Database Sharding — פיצול מסדי נתונים