如何使用芹菜任务 ID 查找已创建的数据库条目

How to find which database entry has been created using celery task id

在我的一项芹菜任务中,我正在创建数据库条目。我知道如何读取我的 celery 任务的状态:

from celery.result import AsyncResult
res = AsyncResult("my-task-id")
res.ready()

但我想知道使用 celery 任务 ID 在特定任务上确切创建了哪个数据库条目。我该怎么做?

提前致谢。

当您插入新的数据库条目时,您将从查询中获取那些新插入的行的 ID。

Celery 任务可以 return "results"。插入数据库条目后,只有 return 那些 id / ids。

您现在可以通过任务 ID 检索任务结果以获取数据库 ID。