0

我的任务进入芹菜并取得成果。我知道这一点，因为我可以做到这一点。

>>> ts = TaskState.objects.all()[0]
>>> ts
Out[31]: <TaskState: SUCCESS apps.checklist.tasks.bulk_checklist_process(ec01461b-3431-478d-adfc-6d6cf162e9ad) ts:2012-07-20 14:35:41>
>>> ts.state
Out[32]: u'SUCCESS'
>>> ts.result
Out[33]: u'{\'info\': ["Great",]}'

但是，当我尝试使用记录在案的方式来获得结果时 - 一切都乱套了..

>>> from celery.result import BaseAsyncResult
>>> result = BaseAsyncResult(ts.task_id)
>>> result.get()
../lib/python2.7/site-packages/djcelery/managers.py:178: TxIsolationWarning: Polling results with transaction isolation level repeatable-read within the same transaction may give outdated results. Be sure to commit the transaction for each poll iteration.
  "Polling results with transaction isolation level "

所以我有两个问题。

  1. 我在导致此错误的 celery 设置中缺少什么。我显然有结果，但 BaseAsyncResult 被抬高了。我什至不知道在哪里寻找这个？
  2. 忽略 1 秒，看起来只要我有，ts.state == SUCCESS我就可以使用ts.result. 这样做的缺点是什么，结果是什么格式？

更新

所以第二部分很简单。 可怕但容易..

context['results'] = resulting_values = result.get(propagate=False)
if not isinstance(resulting_values, dict):
    context['results'] = resulting_values = eval(context['task'].result)
    log.error("We should not be here..")
4

1 回答 1

0

它在您粘贴的警告中说得很对：

TxIsolationWarning: Polling results with transaction isolation level repeatable-read 
within the same transaction may give outdated results. Be sure to commit the transaction   
for each poll iteration.

要将数据库用于结果，并且如果您想在同一进程中轮询它们，那么您需要将数据库的隔离级别配置为READ-COMMITTED 或者在检查结果之前提交事务。

也BaseAsyncResult已弃用，请使用

from celery.result import AsyncResult
于 2012-07-27T14:19:38.183 回答