From d289a15105257871d2f7979beaab641ebf0c57d2 Mon Sep 17 00:00:00 2001
From: lialzm <6356434+lialzm@users.noreply.github.com>
Date: Fri, 15 Apr 2022 21:38:25 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E5=A4=9A=E8=BF=9B=E7=A8=8B=E4=B8=8B?=
 =?UTF-8?q?=E6=97=A0=E6=B3=95=E5=8F=91=E9=80=81=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 aliyun/log/logger_hanlder.py | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/aliyun/log/logger_hanlder.py b/aliyun/log/logger_hanlder.py
index c83d8036..7fa9e2d3 100644
--- a/aliyun/log/logger_hanlder.py
+++ b/aliyun/log/logger_hanlder.py
@@ -21,6 +21,7 @@
 
 import json
 import re
+import os
 
 
 class LogFields(Enum):
@@ -415,6 +416,17 @@ def __init__(self, end_point, access_key_id, access_key, project, log_store, top
 
         self.init_worker()
 
+        self.reg()
+
+
+    def reg(self):
+        if (hasattr(os, 'register_at_fork')):
+            os.register_at_fork(
+                after_in_child=self.__fork_after_in_child)
+
+    def __fork_after_in_child(self):
+        self.init_worker()
+
     def init_worker(self):
         self.worker = Thread(target=self._post)
         self.queue = Queue(self.queue_size)