上传腾讯云日志支持错误重试

src/Common/ClsLogger/ClsLog.php

@@ -50,21 +50,24 @@ class ClsLog
     private static function uploadToCls($topicId, $pbData) {
     private static function uploadToCls($topicId, $pbData) {
         $authorization = ClsSignature::create();
         $authorization = ClsSignature::create();
         $uri = 'http://ap-beijing.cls.myqcloud.com/structuredlog?topic_id='.$topicId;
         $uri = 'http://ap-beijing.cls.myqcloud.com/structuredlog?topic_id='.$topicId;
-        $res = (new Client)->post($uri, [
-            'headers' => [
-                'Host' => 'ap-beijing.cls.myqcloud.com',
-                'Authorization' => $authorization,
-                'Content-Type' => 'application/x-protobuf',
-            ], 
-            'body'=>$pbData,
-            'timeout' => 20,
-        ]);
-        if($res->getResponse()->getStatusCode() != 200) {
-            $msg = '上传腾讯云日志服务失败：'.$res->getResult();
-            self::writeClsErrors($msg);
-            return false;
+        for($n = 0;$n < 3;$n++){
+            $res = (new Client)->post($uri, [
+                'headers' => [
+                    'Host' => 'ap-beijing.cls.myqcloud.com',
+                    'Authorization' => $authorization,
+                    'Content-Type' => 'application/x-protobuf',
+                ], 
+                'body'=>$pbData,
+                'timeout' => 30,
+            ]);
+            if($res->getResponse()->getStatusCode() == 200) {
+                return true;
+            }
+            Coroutine::sleep(1);
         }
         }
-        return true;
+        $msg = '上传腾讯云日志服务失败：'.$res->getResult();
+        self::writeClsErrors($msg);
+        return false;
     }
     }
 
 
     /**
     /**