2017-11-20 14 views
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') 

答えて

1

パブ/サブは、このパターンに適合しない - ポップをブロックリストとコールを使用してに見えます代わりにハンドラでの操作。

関連する問題