扩展 djcelery 任务元表

Question

我想扩展 djcelery taskmeta表，例如我有一个返回整数值的计划任务。

我想添加一个字段来存储此值，以便我可以将此数据与taskmeta表中的date_done字段一起绘制。

我尝试创建一个新模型并与taskmeta表建立外键关系，并在我的任务中根据task_id在此新表中添加一行。

但是我想在任务执行时，我将无法执行，因为我假设此时尚未保存taskmeta数据，即：

 if mover.request.id:
    try:
        task = TaskMeta.objects.get(task_id=mover.request.id)
                    extend_task_info = TaskExtended(task=task)
                    extend_task_info.save()
    except ObjectDoesNotExist:
        logger.error('Task ID: %s not in the DB' % mover.request.id)

添加任务代码：

@task()
def mover():
    for root, dirs, files in os.walk(src_dir):
        path = root.split('/')
        for file in files:
            counter = process_file(os.path.join(root, file))
    if mover.request.id:
        try:
            tn = TaskMeta.objects.get(task_id=mover.request.id)
            extend_task_info = TaskExtended(task=task)
            extend_task_info.counter = counter
            extend_task_info.save()
        except ObjectDoesNotExist:
            logger.error('Task ID: %s not in the DB' % mover.request.id)

Answer 1

使用 task.AsyncResult(task_id) .您可以在此处的文档中阅读有关它的更多信息。