Доступ к базе данных¶
Django ORM - это синхронный код, поэтому если вы хотите получить к нему доступ из асинхронного кода, вам нужно сделать специальную обработку, чтобы убедиться, что его соединения закрываются должным образом.
Если вы используете SyncConsumer или что-то на его основе - например, JsonWebsocketConsumer - вам не нужно делать ничего особенного, поскольку весь ваш код уже работает в синхронном режиме, а Channels выполнит очистку за вас как часть кода SyncConsumer.
Однако если вы пишете асинхронный код, вам необходимо вызывать методы базы данных в безопасном, синхронном контексте, используя database_sync_to_async.
Подключения к базе данных¶
Каналы потенциально могут открывать гораздо больше соединений с базой данных, чем вы привыкли, если вы используете потоковые потребители (синхронные) - они могут открывать до одного соединения на поток.
Если вы хотите контролировать максимальное количество используемых потоков, установите переменную окружения ASGI_THREADS на максимальное число, которое вы хотите разрешить. По умолчанию количество потоков устанавливается на «количество CPU * 5» для Python 3.7 и ниже, и min(32, os.cpu_count() + 4) для Python 3.8+.
Чтобы избежать слишком большого количества потоков, простаивающих в соединениях, вы можете переписать свой код для использования асинхронных потребителей и использовать потоки только тогда, когда вам нужно использовать ORM Django (используя database_sync_to_async).
база данных_sync_to_async¶
channels.db.database_sync_to_async - это версия asgiref.sync.sync_to_async, которая также очищает соединения с базой данных при выходе.
Чтобы использовать его, напишите свои ORM-запросы в отдельной функции или методе, а затем вызовите его с помощью database_sync_to_async, как показано ниже:
from channels.db import database_sync_to_async
async def connect(self):
self.username = await database_sync_to_async(self.get_name)()
def get_name(self):
return User.objects.all()[0].name
Вы также можете использовать его в качестве декоратора:
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