python - 尝试使用数据库查询时,Django 通道 Async Websocket 抛出错误
问题描述
我不明白。即使我已经在异步等待中转换了所有必需的字段。但我仍然收到以下错误:
HTTP GET /chat/8/ 200 [0.02, 127.0.0.1:51354]
WebSocket HANDSHAKING /ws/chat/8/ [127.0.0.1:51356]
Exception inside application: You cannot call this from an async context - use a thread or sync_to_async.
Traceback (most recent call last):
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/channels/sessions.py", line 183, in __call__
return await self.inner(receive, self.send)
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/channels/middleware.py", line 41, in coroutine_call
await inner_instance(receive, send)
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/channels/consumer.py", line 58, in __call__
await await_many_dispatch(
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/channels/utils.py", line 51, in await_many_dispatch
await dispatch(result)
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/channels/consumer.py", line 73, in dispatch
await handler(message)
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/channels/generic/websocket.py", line 175, in websocket_connect
await self.connect()
File "/media/fahadmdkamal/WORK/B-DOPS/api/chat/consumers.py", line 23, in connect
other_user = await sync_to_async(User.objects.get(id=others_id))
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/django/db/models/manager.py", line 82, in manager_method
return getattr(self.get_queryset(), name)(*args, **kwargs)
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/django/db/models/query.py", line 411, in get
num = len(clone)
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/django/db/models/query.py", line 258, in __len__
self._fetch_all()
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/django/db/models/query.py", line 1261, in _fetch_all
self._result_cache = list(self._iterable_class(self))
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/django/db/models/query.py", line 57, in __iter__
results = compiler.execute_sql(chunked_fetch=self.chunked_fetch, chunk_size=self.chunk_size)
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/django/db/models/sql/compiler.py", line 1150, in execute_sql
cursor = self.connection.cursor()
File "/media/fahadmdkamal/WORK/B-DOPS/api/env/lib/python3.8/site-packages/django/utils/asyncio.py", line 24, in inner
raise SynchronousOnlyOperation(message)
django.core.exceptions.SynchronousOnlyOperation: You cannot call this from an async context - use a thread or sync_to_async.
WebSocket DISCONNECT /ws/chat/8/ [127.0.0.1:51356]
错误说我需要调用sync_to_async。即使我调用了该函数,我仍然会收到此错误。我想打印从数据库中提取的其他用户。但它甚至没有去那个声明,这意味着我的数据库调用可能不正确。我见过其他人的一些代码结构与我的完全一样。我错过了什么?
我的消费者代码:
class ChatConsumer(AsyncWebsocketConsumer):
async def connect(self):
# Get message sender information
self.me = self.scope['user']
# print(self.me)
# Get other user's ID from the url
others_id = self.scope['url_route']['kwargs']['user_id']
# Get Other user object using the collected object.
other_user = await sync_to_async(User.objects.get(id=others_id))
print(other_user)
# Get or create personal thread for the conversation
self.thread_obj = await sync_to_async(
Thread.objects.get_or_create_personal_thread(
self.me,
other_user)
)
# Creating room with the thread object id.
self.room_name = f'presonal_thread_{self.thread_obj.id}'
# Adding room and channel name to to the channel layer group
await self.channel_layer.group_add(
self.room_name,
self.channel_name
)
# Accecpting the connection
await self.accept()
print(f'[{self.channel_name}] - You are connected')
# Codes that will be run while disconnecting the websocket
async def disconnect(self, close_code):
print(f'[{self.channel_name}] - Disonnected')
# remove room and channel name from the channel layer
await self.channel_layer.group_discard(
self.room_name,
self.channel_name
)
# Receive message from WebSocket
async def receive(self, text_data):
# Decode json raw data that was sent from user
text_data_json = json.loads(text_data)
message = text_data_json['message']
print(f'[{self.channel_name}] - Recieved message - {message}')
# Store the received data
await self.store_message(message=message)
# Send message to room group so that it can send to the all users
await self.channel_layer.group_send(
self.room_name,
{
'type': 'chat_message',
'message': message,
}
)
# Receive message from room group
async def chat_message(self, event):
print(f'[{self.channel_name}] - Message sent - {event["message"]}')
message = event['message']
# Send message to WebSocket
await self.send(text_data=json.dumps({
'message': message,
'user_id': self.scope['user'].id,
'username': self.scope['user'].username
}))
@database_sync_to_async
def store_message(self, message):
Message.objects.create(sender=self.me,
thread=self.thread_obj,
message=message)
我的路由代码:
application = ProtocolTypeRouter({
'websocket': AuthMiddlewareStack(
URLRouter([
path('ws/chat/<int:user_id>/', consumers.ChatConsumer)
])
),
})
由于我是 django 频道的新手,如果您能说整个 AsyncWebsocketConsumer 结构是否正常,那会更有帮助?
解决方案
Ohh.. Solved it..
Actually I was constructing the await sync_to_async call improperly. The function should be called seperately the params should be called in separate parenthesis.
Old and wrong Structure:
other_user = await sync_to_async(User.objects.get(id=others_id))
Updated and corrent structure:
other_user = await sync_to_async(User.objects.get)(id=others_id)
Here I'm calling the sync_to_async method to get user object in first parenthesis and in second parenthesis I'm providing the query params.
推荐阅读
- ruby-on-rails - FactoryBot ActiveRecord::AssociationTypeMismatch 错误类错误
- php - 如何在 swoole(php 的 websocket 扩展)上将消息从 php 发送到浏览器?
- ubuntu - 如何在 Ubuntu 上通过符号链接使用 OneDrive
- c# - 以 Windows 形式启动 psexec 进程失败
- r - 按ID分组,按时间分组(每个活动的5分钟内),在R中查找活动的时间差异
- git - 应用 git stash 时,如何自动选择并应用当前签出分支的唯一 stash?
- regex - 如果它们出现在引号之间,则替换所有 <>
- amazon-web-services - 在云托管服务提供商之间迁移
- node.js - Socket IO 服务器重启导致重复客户端发出
- django - Djang-CMS 的拆分测试布局