Каналы Django — имя группы должно быть допустимой строкой Unicode, содержащей только буквы, цифры, дефисы или точки ASCII.

Мне нужна помощь в создании чатов, это работает так, как будто я вхожу в определенную комнату (например, «Сообщество Python», «DjangoDev» и т. д.). Пакеты, которые я использую:

Django==1.9.7, 
channels==1.1.8, 
asgi-redis==1.4.3

Я использую слаговые поля имени группы, я фильтрую этот слаг в Каналы, нахожу группу и вызываю сохранение каждый раз, когда приходит новое сообщение. Итак, основная причина проблемы заключается в том, что Channels выдает ошибку, в которой говорится, что имя группы неверно:

(venv) alibek@OverlorD:~/Desktop/my_porject/RedProject$ ./manage.py runworker
2018-03-17 13:59:51,607 - INFO - runworker - Using single-threaded worker.
2018-03-17 13:59:51,608 - INFO - runworker - Running worker against channel layer default (asgi_redis.core.RedisChannelLayer)
2018-03-17 13:59:51,608 - INFO - worker - Listening on channels chat-messages, http.request, websocket.connect, websocket.disconnect, websocket.receive
Not Found: /home/
Not Found: /favicon.ico
Traceback (most recent call last):
  File "./manage.py", line 14, in <module>
    execute_from_command_line(sys.argv)
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/django/core/management/__init__.py", line 353, in execute_from_command_line
    utility.execute()
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/django/core/management/__init__.py", line 345, in execute
    self.fetch_command(subcommand).run_from_argv(self.argv)
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/django/core/management/base.py", line 348, in run_from_argv
    self.execute(*args, **cmd_options)
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/django/core/management/base.py", line 399, in execute
    output = self.handle(*args, **options)
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/channels/management/commands/runworker.py", line 83, in handle
    worker.run()
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/channels/worker.py", line 151, in run
    consumer_finished.send(sender=self.__class__)
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/django/dispatch/dispatcher.py", line 192, in send
    response = receiver(signal=self, sender=sender, **named)
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/channels/message.py", line 105, in send_and_flush
    sender.send(message, immediately=True)
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/channels/channel.py", line 88, in send
    self.channel_layer.send_group(self.name, content)
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/asgi_redis/core.py", line 289, in send_group
    assert self.valid_group_name(group), "Group name not valid"
  File "/home/alibek/Desktop/my_porject/venv/local/lib/python2.7/site-packages/asgiref/base_layer.py", line 122, in valid_group_name
    raise TypeError("Group name must be a valid unicode string containing only ASCII alphanumerics, hyphens, or periods.")
TypeError: Group name must be a valid unicode string containing only ASCII alphanumerics, hyphens, or periods.

ВНЕШНИЙ КОД

def chat_room(request, room_name_url):
    room = get_object_or_404(ChatRoom, slug=room_name_url)
    return render(request, 'chat_room.html', {'room': room})


def msg_consumer(message):
    # Save to model
    room_slug = message.content['room']
    room = ChatRoom.objects.filter(slug=room_slug)

    # Broadcast to listening sockets
    Group("chat-%s" % room).send({
        "text": message.content['message'],
    })


# Connected to websocket.connect
@channel_session
@enforce_ordering
def connect(message):

    message.reply_channel.send({"accept": True})
    # Url of room e.g localhost:8000/chat/django
    path = urlsplit(message.content['path'])
    # Returns slug field of room from url, i.e. 'django'
    room = path[2].strip("/chat/").decode('utf-8')
    # Save room in session and add us to the group
    message.channel_session['room'] = room
    message.content['room'] = room
    Group("chat-%s" % room).add(message.reply_channel)


# Connected to websocket.receive
@channel_session
@enforce_ordering
def receive(message):
    # Stick the message onto the processing queue
    Channel("chat-messages").send({
        "room": message.channel_session['room'],
        "message": message['text'],
    })


# Connected to websocket.disconnect
@channel_session
@enforce_ordering
def disconnect(message):
    Group("chat-%s" % message.channel_session['room']).discard(message.reply_channel)

ВНЕШНИЙ КОД

var messages = document.getElementById("messages");
var text = document.getElementById("text");
var button = document.getElementById("send");

var ws_scheme = window.location.protocol === "https:" ? "wss" : "ws";
var socket = new ReconnectingWebSocket(
    ws_scheme
    + '://'
    + window.location.host
    + window.location.pathname
);
socket.onmessage = function (e) {
    var message = document.createElement("p");
    var data = JSON.parse(e.data);
    var noQuotes = data.msg.split('"').join('');
    var user = data.user;
    message.innerHTML = user + ': ' + noQuotes;
    console.log(JSON.parse(e.data));
    messages.appendChild(message);
};
button.addEventListener("click", function (event) {
    event.preventDefault();
    var data_to_server = JSON.stringify(text.value);
    socket.send(data_to_server);
    text.value = '';
    text.focus();
});

Также мне не нравится использовать сессии, Django выдает ошибку при первом входе в приложение. Поэтому я хотел бы услышать некоторые рекомендации по архитектуре приложения.


person nrgx    schedule 17.03.2018    source источник


Ответы (2)


Ну нашел беду. Я использовал объект вместо строки:

room = ChatRoom.objects.filter(slug=room_slug)

# Broadcast to listening sockets
Group("chat-%s" % room).send({...

Решение

Group("chat-%s" % room_slug).send({...
person nrgx    schedule 20.03.2018

В моем случае это была опечатка автозаполнения...

await self.channel_layer.group_discard(self.user_group, -->self.channel_layer<--)

vs

await self.channel_layer.group_discard(self.user_group, -->self.channel_name<--)
person Max Malysh    schedule 11.11.2019