芹菜延迟回调

Question

我正在使用 django-celery。我需要下载一个大的视频文件。我想在文件下载完成后更新我的数据库。当任务完成时，有没有办法添加一个回调来调用 django 代码，而不是另一个任务？我理想的代码应该是这样的......

from video.tasks import video_download
from video.models import Video

def my_callback(v):    
    v.status = "downloaded"
    v.save()

def download_http(request):
   v = Video.objects.latest().id #this is a string
   a = video_download.delay(v, my_callback)

如果在 celery 任务完成后还有其他方法可以更新对象，我也会对此感兴趣。

PS：我尝试传入v = Video.objects.latest() 而不是v = Video.objects.latest().id，所以我可以一路更新实例，但 celery 不喜欢它，因为它是一个对象而不是字符串。虽然它没有抛出任何错误，但每次我调用 a.ready 时它都会返回 False。

Answer 1

您可以从任务中调用您的 Django 代码。例如：

def video_download(v):
     from video.models import Video
     v = Video.objects.get(pk=v)
     do_download(v)
     v.status = "downloaded"
     v.save()