Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- # Settings
- CELERY_BROKER_URL = u'amqp://{rabbitmq_user}:{rabbitmq_password}@{rabbitmq_host}:{rabbitmq_port}'.format(
- rabbitmq_user='redacted',
- rabbitmq_password='redacted',
- rabbitmq_host='redacted.amazonaws.com',
- rabbitmq_port='5672'
- )
- CELERY_RESULT_BACKEND = CELERY_BROKER_URL
- CELERY_TASK_SERIALIZER = 'msgpack'
- CELERY_RESULT_SERIALIZER = CELERY_TASK_SERIALIZER
- CELERY_ACCEPT_CONTENT = ['msgpack', 'json']
- CELERY_DEFAULT_QUEUE = 'celery'
- CELERY_QUEUES = (
- Queue('celery', Exchange('celery-dev')),
- Queue('lead', Exchange('lead-dev')),
- )
- # celeryapp.py
- from __future__ import absolute_import
- import os
- from celery import Celery
- # set the default Django settings module for the 'celery' program.
- os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'settings')
- app = Celery('redacted')
- # Using a string here means the worker will not have to
- # pickle the object when using Windows.
- app.config_from_object('django.conf:settings', namespace='CELERY')
- app.autodiscover_tasks()
- @app.task(bind=True)
- def debug_task(self):
- print('Request: {0!r}'.format(self.request))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement