Commit 09167f5b authored by i317280's avatar i317280

feat: update

parent 828981fe
...@@ -8,6 +8,7 @@ import threading ...@@ -8,6 +8,7 @@ import threading
import time import time
import os import os
import gzip import gzip
import json
import shutil import shutil
from .alignment import MemoryQueue from .alignment import MemoryQueue
...@@ -102,8 +103,11 @@ class ServerReplayRecorder(ReplayRecorder): ...@@ -102,8 +103,11 @@ class ServerReplayRecorder(ReplayRecorder):
""" """
# Todo: <liuzheng712@gmail.com> # Todo: <liuzheng712@gmail.com>
if len(data['data']) > 0: if len(data['data']) > 0:
# print(json.dumps(
# data['data'].decode('utf-8', 'replace')))
self.file.write( self.file.write(
'"' + str(data['timestamp'] - self.starttime) + '":"' + data['data'].decode('utf-8', 'replace') + '",') '"' + str(data['timestamp'] - self.starttime) + '":' + json.dumps(
data['data'].decode('utf-8', 'replace')) + ',')
def session_start(self, session_id): def session_start(self, session_id):
self.starttime = time.time() self.starttime = time.time()
...@@ -113,7 +117,7 @@ class ServerReplayRecorder(ReplayRecorder): ...@@ -113,7 +117,7 @@ class ServerReplayRecorder(ReplayRecorder):
self.file.write('{') self.file.write('{')
def session_end(self, session_id): def session_end(self, session_id):
self.file.write('}') self.file.write('"0":""}')
self.file.close() self.file.close()
with open(os.path.join(self.app.config['LOG_DIR'], session_id + '.replay'), 'rb') as f_in, \ with open(os.path.join(self.app.config['LOG_DIR'], session_id + '.replay'), 'rb') as f_in, \
gzip.open(os.path.join(self.app.config['LOG_DIR'], session_id + '.replay.gz'), 'wb') as f_out: gzip.open(os.path.join(self.app.config['LOG_DIR'], session_id + '.replay.gz'), 'wb') as f_out:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment