मुझे लगता है कि आप रेडिस-पीई का उपयोग कर रहे हैं।
दस्तावेज़ीकरण listen
. को संदर्भित करता है lib के पुराने संस्करण के रूप में... शायद आपको संदेश पढ़ने के लिए किसी अन्य विधि का उपयोग करना चाहिए। उदाहरण के लिए कॉलबैक के साथ
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.conf
में रेडिस मेमोरी बढ़ाने का प्रयास करें फ़ाइल
maxmemory 500mb # or greater if needed
यह एक स्मृति समस्या है, इसे संभालने के तरीके के बारे में अधिक जानकारी के लिए यह प्रश्न देखें।