Posts

Showing posts with the label celery

Celery issue

(Thank for http://permalink.gmane.org/gmane.comp.python.amqp.celery.user/1695) To create a queue? You know celery automatically declares queues right? You wouldn't 'create' a queue per se, you only declare them, in some context the queue is only actually created when a message is delivered to it. For some transports queues and exchanges *must* be declared by every process that uses them. If you use RabbitMQ then you can create a queue manually like this: from celery import current_app as celery from kombu import Queue, Exchange q = Queue("foo", Exchange("foo", type="direct"), routing_key="foo") with celery.broker_connection() as conn: with conn.channel() as channel: q(channel).declare()

Supervisord and Celery

For setting up supervisord >>> sudo pip install supervisor  note:     Please take care supersivord.conf For setting up celery >>> pip install celery For setting up rabbitmq >>> sudo apt-get install rabbitmq-server