我想路由2个不同的Celery_BROKER_URL

Question

我想将2种不同的芹菜broker_url用于2个不同的IP，并且特定任务应在另一个URL中进行（ex -redis：//127.0.0.2：6379）。

环境文件

CELERY_TASK_TRACK_STARTED=True
CELERY_BROKER_URL="redis://127.0.0.1:6379"

芹菜.py

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'engine.settings')

app = Celery('engine')
app.config_from_object('django.conf:settings')

# Enable sending the "task-sent" notification.
app.conf.task_send_sent_event=True

app.conf.database_engine_options = {'echo': True}

# load task modules from all registered Django app configs.
app.autodiscover_tasks()

@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))