redis-pyを使用していると思います。
ドキュメントはlisten
を参照しています 古いバージョンのライブラリとして...メッセージを読み取るために別の方法を使用する必要があるかもしれません。たとえば、コールバックを使用する
p = r.pubsub()
def my_handler(message):
print 'MY HANDLER: ', message['data']
if item['type'] == 'message':
num += 1
a.parser(item['data'])
print num
p.subscribe('bdwaf', my_handler)
# read the subscribe confirmation message
p.get_message()
編集:
20000メッセージを一度に公開すると、redisサーバーのメモリが不足している可能性があります。 redis.conf
でredisメモリを増やしてみてください ファイル
maxmemory 500mb # or greater if needed
これはメモリの問題です。処理方法の詳細については、この質問を確認してください。