0
特定のチャンネルの1台のマシン(セッター)にメッセージを公開し、他のマシン(ハンドラー)で取得する必要があります。問題は、各ハンドラが一意のメッセージを処理する必要があることです。Redisのチャンネルからのポップメッセージ
documentationにあるように、チャンネルからメッセージをポップする標準的な方法はありません。間違った方法で使用しようとしているのでしょうか?ここで
は、ハンドラのコードです:ここで
import redis
r=redis.Redis()
pubsub = r.pubsub()
pubsub.subscribe('test_channel')
for item in self.pubsub.listen():
...
はセッターのコードです:
import redis
r = redis.Redis()
r.publish('test_channel', 'test message')