Django Channels Group.send не работает в консоли Python?
Я старался Group(groupname).send
в консоли Python, и это не похоже на работу. Почему это?
Это моя договоренность потребителей.py:
def ws_connect(message):
message.reply_channel.send({"accept": True})
Group(secure_group).add(message.reply_channel)
def ws_receive(message):
# Nothing to do here
Group(secure_group).send({
"text": "Received {}".format(message.content['text'])
})
def ws_disconnect(message):
Group(secure_group).discard(message.reply_channel)
Маршрутизация:
from channels.routing import route
from App.consumers import (
ws_connect,
ws_receive,
ws_disconnect
)
channel_routing = [
route("websocket.connect", ws_connect),
route("websocket.receive", ws_receive),
route("websocket.disconnect", ws_disconnect),
]
Терминальные команды:
from channels import Group
#import secure_group here
Group(secure_group).send({ "text": "Tester" })
Все мои клиенты никогда не получали текст.
CHANNEL_LAYERS
конфигурации:
CHANNEL_LAYERS = {
"default": {
"BACKEND": "asgiref.inmemory.ChannelLayer",
"ROUTING": "App.routing.channel_routing",
},
}
1 ответ
Решение
Inmemory
канальный слой не поддерживает cross-process communication
, Вы не можете выполнить групповую отправку в другом терминале. Попробуйте с Redis Backend вы можете отправить сообщение.
Из документа In-Memory