2012-10-16 22 views
6

अजवाइन का कनेक्शन 'सहकर्मी से कनेक्शन रीसेट' समय-समय त्रुटि संदेश के साथ रीसेट है:अजवाइन त्रुटि

[Errno 104] Connection reset by peer 

वर्तमान में, मैं काम और कुछ भी बाद में शुरू हो रहा जब तक मैं सर्वर रीसेट खो देते हैं। मेरे पास 2 प्रश्न हैं: (1) त्रुटि का कारण क्या है/मैं इसे कैसे रोक सकता हूं? (2) जब यह होता है तो मैं त्रुटि को कैसे पकड़ सकता हूं और अपने कार्यों को पुनः प्रयास कर सकता हूं?

मैं हेरोकू पर चल रहा हूं। सेलेरी को परिणामस्वरूप बैकएंड के रूप में ब्रोकर और रेडिस (REDIS_TO_GO) के रूप में AMQP (CloudAMQP) के साथ कॉन्फ़िगर किया गया है।

स्टैकट्रेस: ​​

File "celery/task/trace.py", line 224, in trace_task 
    R = retval = fun(*args, **kwargs) 
File "myapp/tasks.py", line 310, in mytask1 
    mytask2.delay(message) 
File "celery/app/task.py", line 343, in delay 
    return self.apply_async(args, kwargs) 
File "celery/app/task.py", line 458, in apply_async 
    with app.producer_or_acquire(producer) as P: 
File "python2.7/contextlib.py", line 17, in __enter__ 
    return self.gen.next() 
File "celery/app/base.py", line 256, in producer_or_acquire 
    with self.amqp.producer_pool.acquire(block=True) as producer: 
File "kombu/connection.py", line 712, in acquire 
    R = self.prepare(R) 
File "kombu/pools.py", line 57, in prepare 
    p.revive(connection.default_channel) 
File "kombu/connection.py", line 626, in default_channel 
    self._default_channel = self.channel() 
File "kombu/connection.py", line 167, in channel 
    chan = self.transport.create_channel(self.connection) 
File "kombu/transport/amqplib.py", line 324, in create_channel 
    return connection.channel() 
File "kombu/transport/amqplib.py", line 243, in channel 
    return Channel(self, channel_id) 
File "kombu/transport/amqplib.py", line 267, in __init__ 
    super(Channel, self).__init__(*args, **kwargs) 
File "amqplib/client_0_8/channel.py", line 82, in __init__ 
    self._x_open() 
File "amqplib/client_0_8/channel.py", line 469, in _x_open 
    self._send_method((20, 10), args) 
File "amqplib/client_0_8/abstract_channel.py", line 76, in _send_method 
    method_sig, args, content) 
File "amqplib/client_0_8/method_framing.py", line 252, in write_method 
    self.dest.write_frame(1, channel, payload) 
File "amqplib/client_0_8/transport.py", line 165, in write_frame 
    frame_type, channel, size, payload, 0xce)) 
File "python2.7/socket.py", line 224, in meth 
    return getattr(self._sock,name)(*args) 

संस्करण:

Django==1.4.1 
django-celery==3.0.9 
celery==3.0.9 
celery-with-redis==3.0 
amqplib==1.0.2 
kombu==2.4.7 
+0

'सहकर्मी से कनेक्शन रीसेट' की तरह [गाजर] (https://github.com/ask/carrot) आप मुसीबत – dokkaebi

+0

दे रहा है मैं इसे समझने के रूप में, गाजर हो गया है लगता है कोम्बु द्वारा प्रतिस्थापित किया गया। क्या कॉम्बु इस मुद्दे का कारण बन सकता है? – Mike

+0

मुझे एक ही समस्या है जो बहुत ही समान सेटअप के साथ है। –

उत्तर

2

ऐसा लगता है कि आप कनेक्शन से बाहर चल रहे हैं। जब आप क्लाउडएमक्यूपी कंसोलखोलें कनेक्शन आप इसे सत्यापित कर सकते हैं।

शायद अजवाइन पर एक नज़र डालें BROKER_POOL_LIMIT

+0

'BROKER_POOL_LIMIT = none'' को सेट करने से मेरी सहायता हुई। धन्यवाद। – Stanislav

संबंधित मुद्दे