Мое приложение Django должно отправлять сообщения вошедшим в систему пользователям циклически.После получения сообщения пользователь должен иметь фиксированное время для ответа, прежде чем сообщение будет отправлено следующему пользователю.Мой текущий потребительский класс, как показано ниже,
class MessageConsumer(WebsocketConsumer):
def connect(self):
self.accept()
global_list.add(self)
def disconnect(self, close_code):
global_list.remove(self)
def receive(self, text_data):
text_data_json = json.loads(text_data)
message = text_data_json['message']
self.send(text_data=json.dumps({
'message': message
}))
У меня есть конечная точка HTTP, которая при получении запроса POST с токеном проходит через global_list
и вызывает self.send(text_data='Notification Sent')
, который не работает.Как правильно это сделать?