django - 扩展 djcelery taskmeta 表

Question

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

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

我尝试创建一个新模型并与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). 您可以在此处的文档中阅读有关它的更多信息。