我如何延迟并在用 celery 和 django 返回后获得？

Question

目前正在尝试清理 celery 如何与被告知可以异步工作的 django 一起工作

我已经运行了简单的celery 任务，该任务按照文档运行良好，所以我相信我已经安装了 celery 并且运行良好。

但不知何故，我不确定它在return 之后如何工作和运行

例如

我有这个来创建一个新的用户任务

@app.task
def new_user(first, last, table):
    user = UserProfile()
    user.first_name = first
    user.last_name = last
    user.table = table
    user.save()
    return user

我有一个 post api 调用只是为了将其作为 celery 工作原理的示例。

我有这个想法

class List(View):
    def post(self, request):
        all_users = UserMQS().profile()
        output = []
        for user in all_users:
            output.append({
                'id': user.id,
                'first_name': user.first_name,
                'last_name': user.last_name
            })

        ns = new_user.s('First Name1', 'Last Name1', "Table1")
        res = ns.delay()
        return JsonResponse(output, safe=False)
        res.get()

我也尝试过new_user.delay('First Name1', 'Last Name1', "Table1") 之类的方法，但还是不行。

谁能告诉我如何做到这一点？

我希望 return JsonResponse 在创建 new_user 时运行。这不仅仅是为了创建new_user，我只是为了测试 celery 的工作原理，以便在我掌握 celery 后可以实现一些其他的东西。

提前感谢您的任何建议。

Answer 1

你想要达到的目标是不可能的——至少用这种方法是不可能的。方法返回后不能做某事。你需要决定是等待任务的结果还是直接返回一些东西给客户端。

如果您想快速响应用户（直接返回），您需要在浏览器和您的 django/任务队列之间建立另一个通信通道

一个解决方案可能是django result backend，它将您的任务结果写入 django 数据库。与此一起，您可以创建另一个视图，您可以从浏览器调用该视图，直到出现结果，也就是 long polling。

或者你看看websockets。它们使您能够从服务器向客户端发送一些东西，而无需浏览器在前面询问。在 django 世界中，您可能想查看 django channels。在这种情况下，Channels 可能会替代 celery。

这只是实现您所描述的几种可能的方法。