Всем привет. Собственно сабж:
#client.py
import redis
from pickle import dumps
r = redis.StrictRedis(host='localhost', port=6379)
r.publish('my-test-channel', dumps('some data1'))
r.publish('my-test-channel', dumps('some data2'))
r.publish('my-test-channel', dumps('some data3'))
r.publish('my-test-channel', dumps('some data4'))
r.publish('my-test-channel', dumps('some data5'))
# server.py
import redis
from pickle import loads
r = redis.StrictRedis(host='localhost', port=6379)
p = r.pubsub()
p.subscribe('my-test-channel')
try:
for message in p.listen():
if message['type'] == 'message':
print loads(message['data']), type(loads(message['data']))
except KeyboardInterrupt:
p.close()
Запускаю два сервера. После этого запускаю клиента, в итоге, оба сервера получают одни и те же данные, а мне надо, чтобы данные распределялись между ними. Подскажите, как исправить это поведение...
