情况说明:celery 默认解析为 pickle

 class xxxxx():
    def __init__(self,request):
            self.request = request (这个是 django 请求的 requst <WSGIRequest: POST '/server/xxxxx/'>,最后把这个去掉就好了,)
    def funcA(self,x,y):
            return x,y
    def funcB(self):
            # website_request 这是我 app 下的  tasks.py 里的一个函数  ,然后把它放入后台,根据返回结果去调用 self.funcA
             website_request.apply_async(kwargs={'fun':self.funcA,'x':1,'y':1})
     

分析:

  • 把函数传入后台时,不要在初始化的时候,传入一些 pickle 不能解析的函数,列如 接受 django 请求的 request,其他的目前未发现

相关文章:

  • 2022-12-23
  • 2021-12-22
  • 2021-09-12
  • 2021-07-26
  • 2021-08-14
  • 2022-02-28
  • 2022-12-23
  • 2022-12-23
猜你喜欢
  • 2022-12-23
  • 2021-08-03
  • 2022-12-23
  • 2022-12-23
  • 2022-01-17
  • 2022-01-19
  • 2022-03-09
相关资源
相似解决方案