Использование цикла for в django channels async consumer

Я использую AsyncConsumer для своего приложения и в какой-то момент понял, что мне нужно использовать цикл for для итерации по набору запросов, но столкнулся с проблемами асинхронности. Мой код выглядит примерно так:

class ChatConsumer(AsyncConsumer):
    ...
    async def websocket_receive(self, event):
        ....
        chatgroup = await self.get_chatgroup(self.group_id)
        for member in chatgroup.member_chatgroup.all():
            await self.new_notification()
        ...
    async def new_notification(self, member, message):
        await self.channel_layer.group_send(
            self.notification_group_name,
            {
                "type": "notify.message",
                "message": message,
            }
        )

Я знаю, что это совершенно неправильно, но дело в том, что я не знаю, что правильно, и я не нашел ответа в интернете. Поэтому я буду благодарен за любую полезную помощь.

Вернуться на верх