【发布时间】:2019-11-10 15:49:46
【问题描述】:
我一直在尝试根据教程设置一个基本的 Django Channels 项目,但我收到了这个错误。我使用 Django python shell 来测试 Redis 是否正常工作。我正在使用“Daphne my_project.asgi:application”运行 Daphne。我找不到关于该问题的任何类似问题或文档。如果您需要查看我的代码的任何其他部分,请告诉我。非常感谢任何帮助!
consumers.py
from channels.generic.websocket import WebsocketConsumer
from asgiref.sync import async_to_sync
import json
class TestConsumer(WebsocketConsumer):
def connect(self):
self.group_name = 'test'
async_to_sync(self.channel_layer.group_add)(
self.group_name,
self.channel_name
)
self.accept()
def disconnect(self, close_code):
async_to_sync(self.channel_layer.group_discard)(
self.group_name,
self.channel_name
)
def receive(self, text_data):
text_data_json = json.loads(text_data)
message = text_data_json['message']
async_to_sync(self.channel_layer.group_send)(
self.group_name,
{
'type': 'chat_message',
'message': message
}
)
def chat_message(self, event):
message = event['message']
self.send(text_data=json.dumps({
'message' : message
}))
project routing.py
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
import main.routing
import sockets.routing
application = ProtocolTypeRouter
({
'websocket' : AuthMiddlewareStack(
URLRouter(
sockets.routing.websocket_urlpatterns
)
)
})
asgi.py
import os
import django
from channels.routing import get_default_application
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'socialapp.settings')
django.setup()
application = get_default_application()
project settings
ASGI_APPLICATION = 'socialapp.routing.application'
CHANNEL_LAYERS = {
"default": {
"BACKEND": "channels_redis.core.RedisChannelLayer",
"CONFIG": {
"hosts": [("localhost", 6379)],
},
},
}
【问题讨论】:
标签: python django websocket django-channels