1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

#!/usr/bin/env python

# -*- coding: utf-8 -*-

# @Date    : 2016-12-24 17:32:54

# @Author  : 李滿滿 ([email protected])

# @Link    : http://xmdevops.blog.51cto.com/

# @Version : $Id$

from __future__ import absolute_import

# 說明: 匯入公共模組

from kombu import Queue, Exchange

# 說明: 匯入其它模組

# BROKER_URL = 'amqp://root:[email protected]:5672//'

# CELERY_RESULT_BACKEND = 'redis://172.24.10.1:6379/0'

BROKER_URL = 'amqp://root:[email protected]:5672//'

CELERY_RESULT_BACKEND 

CELERY_TASK_SERIALIZER = 'msgpack'

CELERY_RESULT_SERIALIZER = 'json'

CELERY_TASK_RESULT_EXPIRES = 60 * 60 * 24

CELERY_ACCEPT_CONTENT = ['json', 'msgpack']

CELERYD_MAX_TASKS_PER_CHILD = 40

CELERY_QUEUES = (

    Queue(

        name='email_queue',

        exchange=Exchange('email_exchange', 'direct'),

        routing_key='email'),

    Queue(

        name='wixin_queue',

        exchange=Exchange('wixin_exchange', 'direct'),

        routing_key='wixin'),

)

CELERY_ROUTES = {

    'work.notify.email.send_mail': {

        'queue': 'email_queue',

        'routing_key': 'email'

    }

}