python - 如何将 celery 作业的参数输入到要查询的数据库中；使用 mysql

Question

我使用 MySql 作为 celery 的结果后端。我也想在数据库中存储程序参数。

例如:

add.apply_async(args=[num1, num2, user]

在这种情况下，我想将用户参数存储在数据库中，以便以后查询。

目前，我返回存储在数据库中的参数。

def add(num1, num2, user):
    return [num1+num2, user]

但是当任务处于运行状态时，用户没有被插入，我无法在数据库中查询它。有什么解决方案/破解方法吗？

Answer 1

您是仅使用 MySql 作为结果后端，还是也将它用于队列(我不推荐)？如果您将它用于队列，则一旦发送任务，args 就应该在数据库中。否则，直到任务完成后才能存储任务结果。

如果您需要在任务运行时可查询参数，则需要在任务开始时手动将它们插入到数据库表中。如果您希望它们在任务开始之前可查询，则需要在调用 apply_async 之前将它们插入到数据库表中。