How to execute several database access in async consumers

[wenyuan]

Environment:

• Django==4.2.3
• channels==4.0.0

Description:

When i want to access database in async consumers, i can do like this:

from channels.db import database_sync_to_async

async def connect(self):
    self.username = await self.get_name()

@database_sync_to_async
def get_name(self):
    return User.objects.all()[0].name

but how can i execute several database query operations in one wrapped method?

the following code will throw exception: You cannot call this from an async context - use a thread or sync_to_async.

from channels.db import database_sync_to_async

async def connect(self):
    user, orders, messages = await self.get_user_data(1)

@database_sync_to_async
def get_user_data(self):
    user = User.objects.get(id=user_id)
    orders =Order.objects.filter(user=user)
    messages = Message.objects.filter(user=user)
    return user, orders, messages

Thank you very much for your answer and if you can give me some clues~

[wenyuan]

It was an unexpected small error that I have fixed, thanks to the project