Celery Beat如何为用户列表配置多任务 解决仅最后用户执行问题

你的代码在遍历用户列表时，每次都直接对APP.conf.beat_schedule执行全量赋值操作，且三个任务的键名是固定值，每次循环都会覆盖上一轮写入的配置，最终字典里只会保留最后一次循环（也就是最后一个用户）的三个任务配置，所以只会给最后一个用户下发任务。

先初始化空的定时任务配置字典，遍历用户时为每个用户的每个任务生成全局唯一的键名（比如拼接用户名），所有用户的配置都写入完成后，再一次性赋值给Celery的Beat配置。
修复后的代码示例如下：

# 提前定义好你的用户列表、bo、gg变量
users = ['user1', 'user2', 'user3','user4', 'user5', 'user6']
# bo = xxx
# gg = xxx

# 初始化空的定时任务字典
beat_schedule = {}

for user in users:
    # 每个任务的键名拼接用户名，保证全局唯一
    beat_schedule[f"trigger-sync_books_{user}"] = {
        "task": "call_sync_books",
        "schedule": crontab(minute=0, hour="*/24"),
        "args": (user, bo, gg,),
    }
    beat_schedule[f"trigger-sync_stock_{user}"] = {
        "task": "call_sync_stock",
        "schedule": crontab(minute="*/10"),
        "args": (user, bo, gg,),
    }
    beat_schedule[f"trigger-sync_customer_{user}"] = {
        "task": "call_sync_customer",
        "schedule": crontab(minute=0, hour="*/24"),
        "args": (user, bo, gg,),
    }

# 所有任务配置生成完成后，一次性赋值给Celery配置
APP.conf.beat_schedule = beat_schedule

• 如果你的用户量级超过数百，不建议使用这种静态配置的方式，可以改用自定义Celery Scheduler从数据库/缓存中动态加载用户任务，避免Beat配置文件过大、启动加载慢的问题。
• 必须保证所有任务的键名全局唯一，否则仍会出现配置覆盖的问题。

内容的提问来源于stack exchange，提问作者owgitt