postgres parallel copies

Данные

processes <- 1:24
times <- c(
  28.727,
  29.91,
  30.116,
  31.021,
  31.036,
  30.863,
  30.855,
  32.821,
  36.895,
  41.233,
  45.261,
  49.398,
  53.7,
  57.640,
  61.820,
  65.882,
  69.829,
  74.414,
  78.419,
  83.051,
  86.963,
  92.243,
  95.622,
  99.274
)

#Default point mark for a graphic
mark = 19

# Chunk size for a synthetic table
q_uncompressed = 2048

# Compression ratio
q_compressed = 2048 / 4

---

Время исполнения команды copy в зависимости от количества параллельных процессов команды copy

Синяя отсечка означает превышение количества слушающих процессов postgres и обращение к уже занятым.

mybar <-
  barplot(
    height = times,
    names = processes,
    col = "#69b3a2",
    main = expression("Время" ~ bold("copy") ~ "vs количество параллельных процессов"),
    xlab = "процессы",
    ylab = "время, с",
    ylim = c(0, max(times) + 2),
    cex.main = 1,
    font.main = 1
  )
lines(mybar, times, type = "o", pch = mark)

text(x = mybar,
     y = times / 2,
     labels = round(y, 0))
abline(v = mean(mybar[12:13]), col = "blue")

---

Расжатые данные

Скорость выполнения процессов copy в зависимости от количества параллельных процессов

plot(
  processes,
  y = processes * q_uncompressed / times,
  xaxt = "n",
  type = "o",
  bty = "l",
  pch = mark,
  ylim = c(0, q_uncompressed / times[1] * 24),
  col = "#69b3a2",
  main = expression(
    "Процессы" ~ bold("copy") ~ "vs количество параллельных процессов"
  ),
  xlab = "процессы",
  ylab = "МБ/с",
)
axis(1, at = x, las = 2)

expected_speed = q_uncompressed / times[1] * processes
lines(expected_speed,
      type = "o",
      pch = mark,
      col = "red")
legend(
  "topleft",
  legend = c("реальные значения", "максимальные теоретические"),
  col = c("#69b3a2", "red"),
  pch = c(mark, mark),
  inset = c(0.03, 0.03)
)

abline(v = mean(12:13), col = "blue")

Скорость выполнения процесса copy в зависимости от количества параллельных процессов

plot(
  x = processes,
  y = q_uncompressed * processes / times / processes,
  xaxt = "n",
  ylim = c(0, q_uncompressed / times[1]),
  type = "o",
  bty = "l",
  pch = mark,
  col = "#69b3a2",
  main = expression("Скорость выполнения" ~ bold("copy") ~ "приведённо на процесс"),
  xlab = "процессов",
  ylab = "МБ/с",
)
abline(v = mean(12:13), col = "blue")

axis(1, at = processes, las = 2)

---

Сжатые данные

Скорость выполнения процессов copy в зависимости от количества параллельных процессов

plot(
  processes,
  y = processes * q_compressed / times,
  xaxt = "n",
  type = "o",
  bty = "l",
  pch = mark,
  ylim = c(0, q_compressed / times[1] * 24),
  col = "#69b3a2",
  main = expression(
    "Процессы" ~ bold("copy") ~ "vs количество параллельных процессов"
  ),
  xlab = "процессы",
  ylab = "МБ/с",
)
axis(1, at = x, las = 2)

expected_speed = q_compressed / times[1] * processes
lines(expected_speed,
      type = "o",
      pch = mark,
      col = "red")
legend(
  "topleft",
  legend = c("реальные значения", "максимальные теоретические"),
  col = c("#69b3a2", "red"),
  pch = c(mark, mark),
  inset = c(0.03, 0.03)
)

abline(v = mean(12:13), col = "blue")

Скорость выполнения процесса copy в зависимости от количества параллельных процессов