Consumer Connection Error Socket Closed. Celeryd
Contents |
here for a quick overview of the site Help Center Detailed answers to any cannot connect to amqp connection refused questions you might have Meta Discuss the workings and policies
Consumer Cannot Connect To Amqp Guest * * 127.0 0.1 5672
of this site About Us Learn more about Stack Overflow the company Business Learn more celery errno 111 connection refused about hiring developers or posting ads with us Stack Overflow Questions Jobs Documentation Tags Users Badges Ask Question x Dismiss Join the Stack Overflow Community Stack celery rabbitmq connection refused Overflow is a community of 4.7 million programmers, just like you, helping each other. Join them; it only takes a minute: Sign up Celery: Error in connecting to RabbitMQ Server up vote 7 down vote favorite I am starting to use celery by following this "First Steps with Celery". I exactly used
Amqp://guest:guest@localhost:5672//
the tasks.py indicated on that link. However when I ran the task using, celery -A tasks worker --loglevel=info I am getting this error: [2014-09-16 20:52:57,427: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: Socket closed. Trying again in 2.00 seconds... The rabbitmq server is for sure running and below is the snippet of the log regarding the error: =ERROR REPORT==== 16-Sep-2014::20:53:09 === exception on TCP connection <0.235.0> from 127.0.0.1:58162 {channel0_error,starting, {amqp_error,access_refused, "AMQPLAIN login refused: user 'guest' - invalid credentials", 'connection.start_ok'}} =INFO REPORT==== 16-Sep-2014::20:53:09 === closing TCP connection <0.235.0> from 127.0.0.1:58162 =INFO REPORT==== 16-Sep-2014::20:53:15 === accepted TCP connection on [::]:5672 from 127.0.0.1:58163 =INFO REPORT==== 16-Sep-2014::20:53:15 === starting TCP connection <0.239.0> from 127.0.0.1:58163 =ERROR REPORT==== 16-Sep-2014::20:53:18 === exception on TCP connection <0.239.0> from 127.0.0.1:58163 {channel0_error,starting, {amqp_error,access_refused, "AMQPLAIN login refused: user 'guest' - invalid credentials", 'connection.start_ok'}} =INFO REPORT==== 16-Sep-2014::20:53:18 === closing TCP connection <0.239.0> from 127.0.0.1:58163 With this, I did the following to ensure that the 'guest'
van GoogleInloggenVerborgen veldenZoeken naar groepen of berichten
Support Search GitHub This repository Watch 302 Star https://github.com/celery/celery/issues/1290 5,350 Fork 1,763 celery/celery Code Issues 150 Pull requests 19 Projects 0 Wiki Pulse Graphs New issue Celery worker won't reconnect to broker #1290 https://forum.efa-project.org/viewtopic.php?t=102 Closed dn0 opened this Issue Apr 6, 2013 · 6 comments Projects None yet Labels Status: Feedback Needed Milestone No milestone Assignees No connection refused one assigned 2 participants dn0 commented Apr 6, 2013 A celery worker was stuck in an endless loop when trying to reconnect to broker. The log file got flooded with: [2013-04-06 15:26:37,516: ERROR/MainProcess] consumer: Connection to broker lost. Trying to re-establish the connection... Traceback (most recent cannot connect to call last): File "/opt/myproject/envs/lib/python2.7/site-packages/celery/worker/consumer.py", line 393, in start self.consume_messages() File "/opt/myproject/envs/lib/python2.7/site-packages/celery/worker/consumer.py", line 456, in consume_messages poll_timeout = (fire_timers(propagate=errors) if scheduled File "/opt/myproject/envs/lib/python2.7/site-packages/celery/worker/hub.py", line 157, in fire_timers entry() File "/opt/myproject/envs/lib/python2.7/site-packages/celery/utils/timer2.py", line 59, in __call__ return self.fun(*self.args, **self.kwargs) File "/opt/myproject/envs/lib/python2.7/site-packages/celery/utils/timer2.py", line 164, in _reschedules return fun(*args, **kwargs) File "/opt/myproject/envs/lib/python2.7/site-packages/kombu/connection.py", line 268, in heartbeat_check return self.transport.heartbeat_check(self.connection, rate=rate) File "/opt/myproject/envs/lib/python2.7/site-packages/kombu/transport/pyamqp.py", line 134, in heartbeat_check return connection.heartbeat_tick(rate=rate) File "/opt/myproject/envs/lib/python2.7/site-packages/amqp/connection.py", line 844, in heartbeat_tick raise ConnectionError('Too many heartbeats missed') ConnectionError: Too many heartbeats missed [2013-04-06 15:26:37,762: INFO/MainProcess] consumer: Connected to amqp://myproject@192.168.60.10:5672/myproject. [2013-04-06 15:26:37,774: ERROR/MainProcess] consumer: Connection to broker lost. Trying to re-establish the connection... Traceback (most recent call last): File "/opt/myproject/envs/lib/python2.7/site-packages/celery/worker/consumer.py", line 393, in start self.consume_messages() File "/opt/myproject/envs/lib/python2.7/site-packages/celery/worker/consumer.py", line 470, in consume_messages events = poll(poll_timeout) File "/opt/myproject/envs/lib/python2.7/site-packages/kombu/utils/eventio.py", line 61, in poll return self._poll(timeout) File "/opt/myproject/envs/lib/python2.7/site-packages/kombu/utils/eventio.py", line 200, in _poll read, write, error = _select
Print view Search Advanced search 9 posts • Page 1 of 1 m477 Posts: 11 Joined: 07 Dec 2012 03:01 Baruwa / Celery Broker err, broken.. Quote Postby m477 » 13 Dec 2012 00:16 So when previewing a message in Baruwa, I'm getting:Sorry the requested page is unavailable due to a server malfunction.Enabled debug in Baruwa and it shows:Code: Select allRequest Method: GET
Request URL: http://mail.insolvencysolutions.com.au/messages/preview/538388599.A32D2/
Django Version: 1.2.3
Exception Type: IOError
Exception Value:
Socket closed
Exception Location: /usr/lib/pymodules/python2.6/amqplib/client_0_8/method_framing.py in read_method, line 215
Python Executable: /usr/bin/python
Python Version: 2.6.6
Python Path: ['/usr/lib/python2.6', '/usr/lib/python2.6/plat-linux2', '/usr/lib/python2.6/lib-tk', '/usr/lib/python2.6/lib-old', '/usr/lib/python2.6/lib-dynload', '/usr/local/lib/python2.6/dist-packages', '/usr/lib/python2.6/dist-packages', '/usr/lib/python2.6/dist-packages/PIL', '/usr/lib/pymodules/python2.6']
Server time: Thu, 13 Dec 2012 02:12:05 +0200
So, I'm guessing it's my celery broker details. But I know nothing about celery.Help darky? Top m477 Posts: 11 Joined: 07 Dec 2012 03:01 Re: Baruwa / Celery Broker err, broken.. Quote Postby m477 » 13 Dec 2012 00:23 more info:Code: Select allroot@efa:/etc/mysql# tail -f /var/log/baruwa/celeryd.log
[2012-12-13 02:19:42,198: ERROR/MainProcess] Consumer: Connection Error: Socket closed. Trying again in 6 seconds...
[2012-12-13 02:19:51,210: ERROR/MainProcess] Consumer: Connection Error: Socket closed. Trying again in 8 seconds...
[2012-12-13 02:20:02,223: ERROR/MainProcess] Consumer: Connection Error: Socket closed. Trying again in 10 seconds...
[2012-12-13 02:20:15,252: ERROR/MainProcess] Consumer: Connection Error: Socket closed. Trying again in 12 seconds...
[2012-12-13 02:20:30,268: ERROR/MainProcess] Consumer: Connection Error: Socket closed. Trying again in 14 seconds...
[2012-12-13 02:20:47,303: ERROR/MainProcess] Consumer: Connection Error: Socket closed. Trying again in 16 seconds...
Top m477 Posts: 11 Joined: 07 Dec 2012 03:01 Re: Baruwa / Celery Broker err, broken.. Quote Postby m477 » 13 Dec 2012 01:08 alright I fixed it, not sure what the issue is, but it was rabbitmq.I uninstalled it and purged;Code: Select allapt-get remove rabbitmq-server --purgeThen reinst