Django-Channels AsyncConsumer 不工作

Question

使用SyncConsumer 和下面的代码可以正常工作

class BackgroundTaskConsumer(SyncConsumer):
    def create_users(self, message):
        number = message['number']
        id = message['id']
        UserFactory.create_batch(number, groups=(id,))

但是当使用AsyncConsumer 和下面的代码时停止工作

class BackgroundTaskConsumer(AsyncConsumer):
    async def create_users(self, message):
        number = message['number']
        id = message['id']
        await UserFactory.create_batch(number, groups=(id,))

Answer 1

您需要在 database_sync_to_async 中扭曲数据库操作。

class BackgroundTaskConsumer(AsyncConsumer):
    async def create_users(self, message):
        number = message['number']
        id = message['id']
        await database_sync_to_async(UserFactory.create_batch)(number, groups=(id,))

---

你使用database_sync_to_async的方式确实有点奇怪

你以你的方式包装你调用的函数的原因是确保它在被调用之前被包装。

如果你这样做，在 python 中

a = c(b())

b() 在c(..) 之前被调用。

但是database_sync_to_async 需要在您访问数据库之前和之后做一些事情。

通常在 python 中你会使用with contextManager 来执行此操作，但这与从async 转换为sync 不兼容。

所以通过wrapping 你的UserFactory.create_batch 方法然后返回一个你可以用create_batch 调用的新方法。这与@decorator 的工作原理相同