Update Server.py

Author: guswl197

Server.py

@@ -41,7 +41,7 @@ class Settings(BaseSettings):
 rooms_sid = {}
 names_sid = {}
 
-### elasticsearch
+### elk, kibana
 es = Elasticsearch(f'{ES_IP}:{ES_PORT}')  ## 변경
 es.info()
 
@@ -82,12 +82,11 @@ def on_create_room(data):
 
     emit("join-request")
 
-    # elasticsearch
+    # elk
     room_id = data["roomName"]
-    user_nickname = data["userNickname"]
     date = datetime.datetime.now()
     now = date.strftime('%m/%d/%y %H:%M:%S')
-    doc_create = {"des": "create room", "room_id": room_id,"user_nickname" : user_nickname, "@timestamp": utc_time()}
+    doc_create = {"des": "create room", "room_id": room_id, "@timestamp": utc_time()}
     es.index(index=index_name, doc_type="log", body=doc_create)
 
 @socketio.on("join-room")
@@ -113,11 +112,10 @@ def on_join_room(data):
     # broadcast to others in the room
     print("[{}] New member joined: {}<{}>".format(room_id, display_name, sid))
 
-    ### elasticsearch
+    ### elk
     date = datetime.datetime.now()
-    user_nickname = data["userNickname"]
     now = date.strftime('%m/%d/%y %H:%M:%S')
-    doc_join = {"des": "New member joined", "room_id": room_id, "sid": sid,"user_nickname" :user_nickname, "@timestamp": utc_time()}
+    doc_join = {"des": "New member joined", "room_id": room_id, "sid": sid, "@timestamp": utc_time()}
     es.index(index=index_name, doc_type="log", body=doc_join)
     emit("user-connect", {"sid": sid, "name": display_name}, broadcast=True, include_self=False, room=room_id)
 
@@ -169,11 +167,10 @@ def on_disconnect():
     room_id = rooms_sid[sid]
     display_name = names_sid[sid]
 
-    ### efk
+    ### elk
     now = datetime.datetime.now()
-    user_nickname = data["userNickname"]
     now = now.strftime('%m/%d/%y %H:%M:%S')
-    doc_disconnect = {"des": "user-disconnect", "room_id": room_id, "sid": sid,"user_nickname" :user_nickname, "@timestamp": utc_time()}
+    doc_disconnect = {"des": "user-disconnect", "room_id": room_id, "sid": sid, "@timestamp": utc_time()}
     es.index(index=index_name, doc_type="log", body=doc_disconnect)
 
     print("[{}] Member left: {}<{}>".format(room_id, display_name, sid))
@@ -219,17 +216,16 @@ def send_message(message):
     text = message["text"]
     room_id = message["room_id"]
 
-    ### elasticsearch 
+    ### elk
 
     # date = datetime.datetime.now()
     # now = date.strftime('%m/%d/%y %H:%M:%S')
     # doc_chatting= {"des" : "chatting", "room_id" : room_id, "chatting message" : text,"@timestamp": utc_time()}
     # es.index(index=index_name, doc_type="log", body=doc_chatting)
 
-    user_nickname = data["userNickname"]
     date = datetime.datetime.now()
     now = date.strftime('%m/%d/%y %H:%M:%S')
-    doc_chatting = {"des": "chatting", "room_id": room_id, "user_nickname" :user_nickname, "chatting message": text, "@timestamp": utc_time()}
+    doc_chatting = {"des": "chatting", "room_id": room_id, "chatting message": text, "@timestamp": utc_time()}
     es.index(index=index_name, doc_type="log", body=doc_chatting)
 
     data = {