Получить результат задачи по идентификатору в сельдерей

Question

Я пытаюсь получить результат выполнения задачи. Это работает

from proj.tasks import add 
res = add.delay(3,4) 
res.get() 
7 
res.status 
'SUCCESS' 
res.id 
'0d4b36e3-a503-45e4-9125-cfec0a7dca30' 

Но я хочу, чтобы запустить это из другого приложения. Поэтому я перезапустил оболочку python и попробовал:

from proj.tasks import add 
res = add.AsyncResult('0d4b36e3-a503-45e4-9125-cfec0a7dca30') 
res.status 
'PENDING' 
res.get() # Error 

Как получить результат?

Answer 1

Работает с использованием AsyncResult. (См это answer)

Так сначала создать задачу:

from cel.tasks import add 
res = add.delay(3,4) 
res.status 
'SUCCESS' 
res.id 
'432890aa-4f02-437d-aaca-1999b70efe8d' 

Затем начать другую оболочку Python:

from celery.result import AsyncResult 
from cel.tasks import app 
res = AsyncResult('432890aa-4f02-437d-aaca-1999b70efe8d',app=app) 
res.state 
'SUCCESS' 
res.get() 
7 

Answer 2

Это связано с RabbitMQ not actually storing the results. Если вам нужна возможность получить результаты позже, используйте redis или SQL в качестве результата.