websocket.js?565f:28 До парса
16:51:07.384 websocket.js?565f:29 {'id': 58, 'text': 'цуа', 'datetime': '2018-07-04 12:51:07.327731+00:00', 'sender': 'test', 'thread': 1}
16:51:07.384 websocket.js?565f:31 После парса
16:51:07.384 websocket.js?565f:32 {'id': 58, 'text': 'цуа', 'datetime': '2018-07-04 12:51:07.327731+00:00', 'sender': 'test', 'thread': 1}
console.log("До парса");
console.log(evt.data);
const msg = JSON.parse(JSON.stringify(evt.data));
console.log("После парса");
console.log(msg);
store.dispatch({type:types.MESSAGE[0], payload:msg})
class EchoWebSocket(tornado.websocket.WebSocketHandler):
def open(self):
print("WebSocket opened")
redis_client = redis.StrictRedis()
sub = redis_client.pubsub()
sub.subscribe('channel')
for message in sub.listen(): # поместить в основной цикл не могу
print(message.body)
def send_new_message(self, evt):
print(evt.body)
def check_origin(self, origin):
return True
def on_message(self, data):
json_data = json.loads(data)
self.token = json_data['token']
self.message = json_data['message']
self.thread = json_data['thread']
self.post()
from .models import Product, Detail, Comment
class Detailinline(admin.StackedInline):
model = Detail
extra = 1
max_num = 1
class Comment_mod(admin.StackedInline):
model = Comment
class display(admin.ModelAdmin):
inlines = [Detailinline, Comment_mod]
admin.site.register(Product, display)
if cleaned_data['username'] == cleaned_data['password']:
# Вывести ошибку
else:
# Вызвать create_user() передав данные
В торнадо пытаюсь сделать единый обработчик который принимает новые сообщения и итерируется по списку на наличие подписчиков.