[bugfix] 解决日志中文报错以及各种utf8问题 (#2328)

This commit is contained in:
xiaomao
2019-01-08 15:27:15 +08:00
committed by 老广
parent 49a166552e
commit 4bf0dfcf7b
3 changed files with 6 additions and 4 deletions

View File

@@ -31,7 +31,7 @@ class CeleryTaskLogApi(generics.RetrieveAPIView):
if not log_path or not os.path.isfile(log_path):
return Response({"data": _("Waiting ...")}, status=203)
with open(log_path, 'r') as f:
with open(log_path, 'r', encoding="utf8") as f:
offset = cache.get(mark, 0)
f.seek(offset)
data = f.read(self.buff_size).replace('\n', '\r\n')

View File

@@ -81,7 +81,7 @@ def pre_run_task_signal_handler(sender, task_id=None, task=None, **kwargs):
t.status = CeleryTask.RUNNING
t.log_path = log_path
t.save()
f = open(full_path, 'w')
f = open(full_path, 'w', encoding="utf-8")
tee = TeeObj(f)
sys.stdout = tee
task.log_f = tee