Celery 任务是在后续任务中分配本地实例属性

Question

我有一个任务，每次处理新任务时都会创建任务历史记录。我在任务函数的开头实例化一个新的任务历史记录实例。由于某种原因，在上一个任务中分配的任务历史记录类属性将分配给后续任务中的任务历史记录类属性。例如，如果任务成功，我将分配：

 task_history.meta['success'] = 'Successfully processed {} rows '.format(row_count)'

在后续任务中，它可能会失败，我分配：

task_history.meta['error'] = 'Processed {} rows '.format(row_count) + str(e)

后续任务应该只分配meta['error']，

但它也会分配以前的meta['成功']值，即使task_history被重新实例化。

下面是调用任务的代码：

args = [file_ids]
kwargs = {'requester': request.user.profile}
csv_import.apply_async(args=args, kwargs=kwargs)

下面是任务函数：

@task
def csv_import(file_ids, requester=None):
    task_history = TaskHistory()
    task_history.requester = requester
    task_history.status = 'pending'
    task_history.started = timezone.now()
    task_history.save()
    row_count = 0
    try:
       //main logic goes here
       task_history.status = 'completed'
       task_history.completed = now()
       task_history.meta['success'] = 'Successfully processed {} rows '.format(row_count)
       task_history.save()
    except Exception as e:
        task_history.status = 'failed'
        task_history.completed = timezone.now()
        task_history.meta['error'] = 'Processed {} rows '.format(row_count) + str(e)
        task_history.save()
        raise Exception

Answer 1

最后，

这与芹菜无关，而是与我在模型中为元字段设置默认值的方式有关。元字段是一个 JSONfield（），我将默认值设置为 default={}，这将创建一个可变实例并在 JSONfield 的所有实例之间共享。我通过将其设置为可调用的字典来解决此问题。新字段现在如下所示：

meta = JSONField(default=dict)

有关这方面的更多信息可以在这里找到 https://docs.djangoproject.com/es/1.9/ref/contrib/postgres/fields/#jsonfield。这是应用于所有模型默认值的相同标准。