我有一个向另一个服务发送数据的celery 任务。我已经将celery 任务send_inventory_request添加到RequestSupplyStock类视图中。当我发布时，我应该首先从celery 任务中获取结果，然后继续并返回响应。我想首先等待celery 任务的结果，然后从发布方法中返回响应，这是实现此目的的正确方法。

@app.task
def send_inventory_request(payload,token):
    auth = {'authorization':token}
    HEADERS.update(auth)
    url = PROCUREMENT_SUPPLY_STOCK_REQUESTS_URL
    res = requests.post(url,json=payload,headers=HEADERS)
    inventory_request_data = res.json()
    x= logger.info('Supply Stock Request {0} + {1}'.format(payload,token))
    print(x)
    return inventory_request_data

查看

class RequestSupplyStock(generics.CreateAPIView):

      def post(self, request, format=None):
          ........

          send_inventory_request.delay(payload,get_token(request))

          .........
          return Response(status=status.HTTP_201_CREATED)