Celery + Channels：在工作人员中接收消息

Question

我正在使用 django 和 celery 构建一种交互式游戏。 Celery 任务正在处理游戏逻辑。

Django/channels 将接收来自游戏 ui 的消息，这些消息需要传递给相同的 celery 任务（每个游戏）。

我还没有找到使用通道向活动 celery 任务发送消息的方法，有什么好的方法吗？

Answer 1

更新：Turns out that celery 4 doesn't work well with asyncio，所以下面的解决方案不断提高got Future <Future pending> attached to a different loop。

---

我通过在 celery 任务中创建通道找到了一种方法：

tasks.py：

@app.task
def task(channel_name):
    worker_channel_name = async_to_sync(channel_layer.new_channel)()
    async_to_sync(channel_layer.send)(channel_name, {'type': 'ping_pong', 'message': worker_channel_name})
    r = async_to_sync(channel_layer.receive)(channel)

consumers.py：

class Consumer(WebsocketConsumer):

    def receive(self, data):
        ...
        tasks.task.delay(self.channel_name)

    def ping_pong(self, event):
        worker_channel_name = event['message']
        async_to_sync(self.channel_layer.send)(worker_channel_name, ...)

使用它，我可以进一步调用receive，使用获取的worker_channel_name 直接与工作人员通信。

有点不清楚的是我应该将worker_channel_name 存储在客户端还是Consumer 内部（如果后续的websocket 请求位于同一节点上）。