如何在运行时更改 Celery 的任务名称

问题描述

我想根据他们收到的参数来命名我的任务。下面的示例工作正常，但任务名称为空（至少 Flower 没有显示它）。我想修改它，使任务名称基于用户名。

@app.task
def synchronize_users():
    users = crud_user.get_all_active_users()
    for user in users:
        synchronize_user.apply_async(warehouse)


@app.task(serializer='pickle')
def synchronize_user(user):
    user.synchronize()

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）