6
芹菜的连接“通过对等连接复位”与错误信息定期重置:芹菜错误
[Errno 104] Connection reset by peer
目前,我输了之后触发,直到我重置服务器任务和任何东西。我有两个问题:(1)是什么导致了错误/我该如何防止它? (2)如何在发生错误时重新捕捉错误并重试我的任务?
我在Heroku上运行。 Celery配置了AMQP(CloudAMQP)作为中间件和redis(REDIS_TO_GO)作为后端结果。
堆栈跟踪:
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
“被连接重置”听起来像是[胡萝卜](https://github.com/ask/carrot)是给你的麻烦 – dokkaebi
据我了解,胡萝卜一直取而代之的是kombu。 kombu可能导致这个问题? – Mike
我遇到了非常类似的设置相同的问题。 –