Redis®*: RedisとPythonでの「Connection Closed by Server」エラーの回避

このドキュメントはPythonでの使用ガイドの一部です。完全なガイドはこちらからご覧いただけます：PythonでRedisに接続する方法。

👋 Stackheroのドキュメントへようこそ！

Stackheroは、数多くの利点を提供する、すぐに使えるRedisクラウドソリューションを提供しています。

• Redis Commander Web UIを含む。
• メッセージサイズと転送が無制限。
• ワンクリックで簡単にアップデート。
• プライベートで専用のVMによる最適なパフォーマンスと強力なセキュリティ。

時間を節約し、生活を簡素化：StackheroのRedisクラウドホスティングソリューションを試すのに5分しかかかりません！

redis.exceptions.ConnectionError: Connection closed by serverエラーが発生することがあります。これは、Pythonアプリケーションの非アクティブ状態が原因で接続が自動的に閉じられるためです。アプリが再接続を試みると失敗し、このエラーが発生する可能性があります。

これを軽減するために、Redis接続でhealth_check_intervalパラメータを次のように設定することを検討してください。

r = redis.from_url(
  'rediss://default:<password>@<XXXXXX>.stackhero-network.com:<PORT_TLS>',
  health_check_interval=10,
  socket_connect_timeout=5,
  retry_on_timeout=True,
  socket_keepalive=True
)

RedisのPub/Sub機能を使用する際は、アプリケーションが指定されたhealth_check_interval（この例では10秒ごと）よりも頻繁にget_message()またはlisten()を呼び出すことを確認してください。詳細については、redis-py公式ドキュメントを参照できます。

この間隔内にこれらの呼び出しが行われない場合、「Connection closed by server」エラーが発生する可能性があります。実用的な解決策は、定期的にcheck_health()関数を使用することです。

以下はその実装方法です。

import redis
import threading

# Redisに接続
r = redis.from_url(
  'rediss://default:<password>@<XXXXXX>.stackhero-network.com:<PORT_TLS>',
  health_check_interval=10,
  socket_connect_timeout=5,
  retry_on_timeout=True,
  socket_keepalive=True
)

# PubSubインスタンスを作成
p = r.pubsub()

# チャンネル"test"にサブスクライブ
p.subscribe('test')

# 5秒ごとに`check_health`を呼び出す関数を作成
def redis_auto_check(p):
  t = threading.Timer(5, redis_auto_check, [p])
  t.start()
  p.check_health()

# redis_auto_check関数を呼び出す
redis_auto_check(p)