如何在celery中生成每个用户的队列？

from celery import Celery

app = Celery('myapp', broker='redis://localhost:6379/0', backend='redis://localhost:6379/0')

# 配置Celery的一些参数
app.conf.task_routes = {
    'myapp.tasks.*': {'queue': 'default'},
    'myapp.tasks.user.*': {'queue': 'user'},
}

# 导入任务模块
app.autodiscover_tasks(['myapp.tasks'])

from myapp.celery import app

@app.task
def process_task(user_id):
    # 处理任务的逻辑
    pass

from myapp.tasks import process_task

# 生成用户队列
user_id = 123
process_task.apply_async(args=[user_id], queue='user')