В комментарии к прошлому посту, попросили поделиться подробнее про pipline.

Часто кэш читают/пишут «в лоб» — по одному запросу. Но основная цена Redis в проде — это RTT (туда-обратно по сети). Pipeline позволяет отправить пачку команд за один сетевой раунд — сервер выполнит их по порядку, а ответы придут одной очередью.

Что такое pipeline (и чем он НЕ является)
- Pipeline не делает операции атомарными. Это просто «упаковка» команд в один раунд-трип.
- Для атомарности нужен MULTI/EXEC (**TxPipeline** в go-redis) или Lua-скрипт, либо WATCH + TxPipelined.
- Команды в pipeline выполняются по очереди на сервере, но клиент не ждёт ответ после каждой — экономим RTT.

---

Когда использовать
- Серии однотипных чтений/записей (например, 50 ключей GET / `HGETALL`).
- Смешанные операции, где ответы предыдущих команд не нужны для формирования следующих.
- Интеграции «на пути» запроса (критично снижать задержку).

Когда не стоит:
- Когда следующая команда зависит от результата предыдущей → делайте двумя фазами.
- Огромные пакеты (тысячи команд) — растёт задержка одной пачки и риск таймаутов. Лучше батчить.

---

Простой пример на Go.

package main

import (
 "context"
 "encoding/json"
 "fmt"
 "time"

 "github.com/redis/go-redis/v9"
)

type Post struct {
 ID, Author, Title, Content string
}

func main() {
 ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
 defer cancel()

 rdb := redis.NewClient(&redis.Options{Addr: "127.0.0.1:6379"})

 // 1) Запись: тело поста + счётчики одним pipeline
 post := Post{ID: "42", Author: "alice", Title: "Pipeline 101", Content: "…"}
 body, _ := json.Marshal(post)

 _, err := rdb.Pipelined(ctx, func(p redis.Pipeliner) error {
  p.Set(ctx, "post:42:body", body, 10*time.Minute)       // TTL у тела
  p.HSet(ctx, "post:42:counters", "views", 0, "likes", 0) // счётчики отдельно
  p.Persist(ctx, "post:42:counters")                      // живут дольше тела
  return nil
 })
 if err != nil {
  panic(err)
 }

 // 2) Чтение: тело + счётчики за 1 RTT
 var (
  bodyCmd = rdb.Get(ctx, "post:42:body")
  ctrCmd  = rdb.HGetAll(ctx, "post:42:counters")
 )
 // Внимание: без Pipelined() мы сделали 2 команды, но они уйдут подряд на одном соединении.
 // Для явного пайплайна:
 pipe := rdb.Pipeline()
 bodyCmd = pipe.Get(ctx, "post:42:body")
 ctrCmd = pipe.HGetAll(ctx, "post:42:counters")
 if _, err := pipe.Exec(ctx); err != nil && err != redis.Nil {
  panic(err)
 }

 var p Post
 if b, err := bodyCmd.Bytes(); err == nil && len(b) > 0 {
  _ = json.Unmarshal(b, &p)
 }
 counters := ctrCmd.Val()
 fmt.Println("title:", p.Title, "views:", counters["views"])
}