【入門編】パイプライニング – Redis

やあ。Redisの世界へようこそ。
Redisを「単なる高速なデータベース」だと思っているなら、それはまだ入り口に立ったばかりだ。今日は、Redisの真のポテンシャルを引き出すための第一歩、「パイプライニング」という魔法について話そう。

専門用語の羅列なんてつまらないことはしない。まずは、君がカフェのカウンターにいるところを想像してみてほしい。

—

君がカフェで注文をするとしよう。

1. 「コーヒーを一つ」と伝える。
2. 店員さんがそれを受け取り、コーヒーを淹れる。
3. 君が受け取る。
4. 次に「やっぱりクロワッサンも」と言って、また店員さんがパンを取りに行く。

これでは、注文の数だけ「店員さんとのやりとり（ネットワークの往復）」が発生してしまうよね。注文が10個あれば、10回もカウンターを行き来しなければならない。これが、システムにおける「ネットワークの遅延（レイテンシ）」の正体だ。

Redisも同じだ。通常、コマンドを一つ投げるたびに、サーバーからの「了解！」という返事を待つ。1万件のデータを保存したいとき、1万回もこの「行って、帰って」を繰り返せば、どんなにRedisが高速でも、ネットワークの制限で足が止まってしまうんだ。

ここで登場するのがパイプライニングだ。

先ほどのカフェの例で言えば、「コーヒーと、クロワッサンと、サラダと、紅茶を一度にまとめて紙に書いてカウンターに渡す」ようなものだね。

店員さんは「注文が全部揃っているな」と理解して、次々と商品を並べてくれる。君は最後にまとめて受け取ればいい。これなら、カウンターとの往復はたったの1回で済む。

これがパイプライニングの神髄だ。「複数のコマンドを一度にまとめて送り、最後に返答を一気に受け取る」。これだけで、スループット（処理能力）は劇的に跳ね上がる。

理屈はわかったね。では、実際にどう書くのか。今回は最も汎用的なRedisクライアント（Pythonの `redis-py`）を例に見てみよう。

import redis

Redisサーバーに接続
r = redis.Redis(host=’localhost’, port=6379, db=0)

パイプラインオブジェクトを作成
これが「注文をまとめて書くためのメモ帳」になる
pipe = r.pipeline()

コマンドを次々と「書き込む」。この時点ではまだ送信されない
for i in range(1000):
pipe.set(f’key:{i}’, i)

最後に一気に送信！
これ一回で1000個のコマンドがサーバーへ飛ぶ
results = pipe.execute()

print(“1000個のデータを一瞬で保存しました。”)

たったこれだけだ。`pipeline()` を呼び出し、いつものように `set` や `get` を呼ぶ。最後に `execute()` を叩くことで、魔法が発動するんだ。

ただし、伝説のアーキテクトとして一つだけ忠告しておこう。

一度に100万件もまとめると、メモリを圧迫したり、ネットワークパケットのサイズが大きすぎて逆に効率が悪くなることがある。数千件単位で区切るのが、実務における「職人の勘」というものだ。

パイプライニングは「まとめて送る」技術であって、途中で失敗しても他の処理が止まるわけではない。厳密な「全か無か」の処理が必要な場合は、別の仕組み（MULTI/EXEC）を使う必要がある。

—

パイプライニングを使いこなせるようになれば、君が書くアプリケーションのレスポンスは、これまでとは見違えるほど軽快になるはずだ。

「1回ずつ丁寧に送る」のは礼儀正しいが、エンジニアリングの世界では「まとめて効率よく」が正義になることもある。このバランス感覚を身につけた君なら、どんな大規模なシステムでもRedisを自在に操れるようになるだろう。

ここをクリアした君には、もう怖いものはない。次は「データ構造の使い分け」や「Pub/Sub」といった深淵を覗いてみないか？

Redisの世界へ、ようこそ。またいつでも相談に乗るよ。