python - Celery 在文件下载完成之前执行解析文件功能。我正在使用 django +celery

Question

我有一个芹菜任务，需要从远程服务器下载文件然后解析它。虽然我先尝试使用普通函数下载（）然后解析（）。但是 celery 甚至在它下载之前就执行了解析函数，这导致了错误有没有办法同步这两个执行？

file.download()   #calling function to download file
file.parse()      #calling function to parse the file
#followed by more code

标签： pythondjangopython-3.xcelerydjango-celery

Answer 1

这是一种链式方法。

chanin = downdload.s()| parse.s()
chain.apply_async()