How to solve the error ImportError: cannot import name 'AsyncWebsocketConsumer'?
How to solve the error ImportError: cannot import name 'AsyncWebsocketConsumer'?
我正在使用 Python 3.6、Django 1.11 和 chennels=2。
我正在学习本教程,它在教程第 2 部分之前工作正常:http://channels.readthedocs.io/en/stable/tutorial/part_2.html
当我转到教程第 3 部分并相应地更改 ChatConsumer 文件时:http://channels.readthedocs.io/en/stable/tutorial/part_3.html
我正面临这个问题
ImportError: cannot import name 'AsyncWebsocketConsumer'
Consumer.py:
from channels.generic.websocket import AsyncWebsocketConsumer
import json
class ChatConsumer(AsyncWebsocketConsumer):
async def connect(self):
self.room_name = self.scope['url_route']['kwargs']['room_name']
self.room_group_name = 'chat_%s' % self.room_name
# Join room group
await self.channel_layer.group_add(
self.room_group_name,
self.channel_name
)
await self.accept()
async def disconnect(self, close_code):
# Leave room group
await self.channel_layer.group_discard(
self.room_group_name,
self.channel_name
)
# Receive message from WebSocket
async def receive(self, text_data):
text_data_json = json.loads(text_data)
message = text_data_json['message']
# Send message to room group
await self.channel_layer.group_send(
self.room_group_name,
{
'type': 'chat_message',
'message': message
}
)
# Receive message from room group
async def chat_message(self, event):
message = event['message']
# Send message to WebSocket
await self.send(text_data=json.dumps({
'message': message
}))
错误:
任何一种将不胜感激!
要将您的消费者函数更改为异步性质,您需要从 channels.generic.websocket
导入 AsyncWebsocketConsumer
from channels.generic.websocket import AsyncWebsocketConsumer
已更新到频道版本 2.1,它解决了这个错误!
pip install channels==2.1
我正在使用 Python 3.6、Django 1.11 和 chennels=2。 我正在学习本教程,它在教程第 2 部分之前工作正常:http://channels.readthedocs.io/en/stable/tutorial/part_2.html
当我转到教程第 3 部分并相应地更改 ChatConsumer 文件时:http://channels.readthedocs.io/en/stable/tutorial/part_3.html
我正面临这个问题
ImportError: cannot import name 'AsyncWebsocketConsumer'
Consumer.py:
from channels.generic.websocket import AsyncWebsocketConsumer
import json
class ChatConsumer(AsyncWebsocketConsumer):
async def connect(self):
self.room_name = self.scope['url_route']['kwargs']['room_name']
self.room_group_name = 'chat_%s' % self.room_name
# Join room group
await self.channel_layer.group_add(
self.room_group_name,
self.channel_name
)
await self.accept()
async def disconnect(self, close_code):
# Leave room group
await self.channel_layer.group_discard(
self.room_group_name,
self.channel_name
)
# Receive message from WebSocket
async def receive(self, text_data):
text_data_json = json.loads(text_data)
message = text_data_json['message']
# Send message to room group
await self.channel_layer.group_send(
self.room_group_name,
{
'type': 'chat_message',
'message': message
}
)
# Receive message from room group
async def chat_message(self, event):
message = event['message']
# Send message to WebSocket
await self.send(text_data=json.dumps({
'message': message
}))
错误:
要将您的消费者函数更改为异步性质,您需要从 channels.generic.websocket
AsyncWebsocketConsumer
from channels.generic.websocket import AsyncWebsocketConsumer
已更新到频道版本 2.1,它解决了这个错误!
pip install channels==2.1