内容分发网络(cdn)：GetRefreshOrPreloadTask V3版本上线；容器服务(kce)：新增CreateWebSocketPublicUri；

Author: fengyikai

ksyun/__init__.py

@@ -14,4 +14,4 @@
 # limitations under the License.
 
 
-__version__ = '1.5.8.58'
+__version__ = '1.5.8.60'

ksyun/client/cdn/v3/client.py

@@ -974,3 +974,26 @@ def SetCertificateConfig(self, request):
                 raise KsyunSDKException(message=str(e))
 
 
+    def GetRefreshOrPreloadTask(self, request):
+        """刷新预热进度查询接口迭代
+        :param request: Request instance for GetRefreshOrPreloadTask.
+        :type request: :class:`ksyun.client.cdn.v3.models.GetRefreshOrPreloadTaskRequest`
+        """
+        try:
+            params = request._serialize()
+            body = self.call_judge("GetRefreshOrPreloadTask", params, "application/json")
+            response = json.loads(body)
+            if "Error" not in response:
+                return body
+            else:
+                code = response["Error"]["Code"]
+                message = response["Error"]["Message"]
+                req_id = response["RequestId"]
+                raise KsyunSDKException(code, message, req_id)
+        except Exception as e:
+            if isinstance(e, KsyunSDKException):
+                raise
+            else:
+                raise KsyunSDKException(message=str(e))
+
+

ksyun/client/cdn/v3/models.py

@@ -1289,3 +1289,59 @@ def _deserialize(self, params):
             self.PrivateKey = params.get("PrivateKey")
 
 
+class GetRefreshOrPreloadTaskRequest(AbstractModel):
+    """GetRefreshOrPreloadTask请求参数结构体
+    """
+
+    def __init__(self):
+        r"""刷新预热进度查询接口迭代
+        :param StartTime: 获取数据起始时间点，不能超出可查询范围的起始时间点，日期格式按ISO8601表示法，北京时间，格式为：YYYY-MM-DDThh:mm+0800，例如：2022-03-10T21:00+0800
+        :type PathPrefix: String
+        :param EndTime: 结束时间需大于起始时间；获取日期格式按照ISO8601表示法，北京时间，格式为：YYYY-MM-DDThh:mm+0800，例如：2022-03-10T21:10+0800
+        :type PathPrefix: String
+        :param TaskId: 支持按任务ID查询，只允许输入单个任务ID
+        :type PathPrefix: String
+        :param DomainName: 支持按域名查询，只允许输入单个域名
+        :type PathPrefix: String
+        :param Urls: Url组成的数组，支持按Url路径查询，准确匹配
+        :type PathPrefix: Array
+        :param Type: 支持按内容管理任务的类型查询，传参可取值：refresh、preload。其中，refresh表示刷新任务类型，preload表示预热任务类型，不传参表示查询所有类型。
+        :type PathPrefix: String
+        :param SubType: 支持按任务的细分类型查询，传参可取值：REFRESH_FILE、REFRESH_DIR。若Type取值refresh或者不传参，则该传参可生效，其中，REFRESH_FILE表示URL刷新，REFRESH_DIR表示目录刷新，不传参表示查询所有细分类型。若Type取值preload，则该参数为无效参数
+        :type PathPrefix: String
+        :param PageSize: 分页大小，取值为1-50，最大50，默认20
+        :type PathPrefix: Long
+        :param PageNumber: 取得第几页，取值为：1-100000，最大100000，默认1
+        :type PathPrefix: Long
+        """
+        self.StartTime = None
+        self.EndTime = None
+        self.TaskId = None
+        self.DomainName = None
+        self.Urls = None
+        self.Type = None
+        self.SubType = None
+        self.PageSize = None
+        self.PageNumber = None
+
+    def _deserialize(self, params):
+        if params.get("StartTime"):
+            self.StartTime = params.get("StartTime")
+        if params.get("EndTime"):
+            self.EndTime = params.get("EndTime")
+        if params.get("TaskId"):
+            self.TaskId = params.get("TaskId")
+        if params.get("DomainName"):
+            self.DomainName = params.get("DomainName")
+        if params.get("Urls"):
+            self.Urls = params.get("Urls")
+        if params.get("Type"):
+            self.Type = params.get("Type")
+        if params.get("SubType"):
+            self.SubType = params.get("SubType")
+        if params.get("PageSize"):
+            self.PageSize = params.get("PageSize")
+        if params.get("PageNumber"):
+            self.PageNumber = params.get("PageNumber")
+
+

ksyun/client/kce/v20180314/client.py

@@ -397,3 +397,5 @@ def DeleteRepoNamespace(self, request):
                 raise
             else:
                 raise KsyunSDKException(message=str(e))
+
+

ksyun/client/kce/v20190806/client.py

@@ -788,3 +788,28 @@ def UpgradeRelease(self, request):
                 raise
             else:
                 raise KsyunSDKException(message=str(e))
+
+
+    def CreateWebSocketPublicUri(self, request):
+        """创建WebSocket公网请求URI，使用该链接可以与集群pod远程交互
+        :param request: Request instance for CreateWebSocketPublicUri.
+        :type request: :class:`ksyun.client.kce.v20190806.models.CreateWebSocketPublicUriRequest`
+        """
+        try:
+            params = request._serialize()
+            body = self.call_judge("CreateWebSocketPublicUri", params, "application/x-www-form-urlencoded")
+            response = json.loads(body)
+            if "Error" not in response:
+                return body
+            else:
+                code = response["Error"]["Code"]
+                message = response["Error"]["Message"]
+                req_id = response["RequestId"]
+                raise KsyunSDKException(code, message, req_id)
+        except Exception as e:
+            if isinstance(e, KsyunSDKException):
+                raise
+            else:
+                raise KsyunSDKException(message=str(e))
+
+

ksyun/client/kce/v20190806/models.py

@@ -1097,3 +1097,44 @@ def _deserialize(self, params):
             self.Values = params.get("Values")
 
 
+class CreateWebSocketPublicUriRequest(AbstractModel):
+    """CreateWebSocketPublicUri请求参数结构体
+    """
+
+    def __init__(self):
+        r"""创建WebSocket公网请求URI，使用该链接可以与集群pod远程交互
+        :param ClusterId: 集群ID
+        :type PathPrefix: String
+        :param Namespace: k8s集群命名空间
+        :type PathPrefix: String
+        :param PodName: Pod名称
+        :type PathPrefix: String
+        :param ContainerName: 容器名
+        :type PathPrefix: String
+        :param Command: 启动命令
+        :type PathPrefix: String
+        :param Tty: 保持连接
+        :type PathPrefix: Boolean
+        """
+        self.ClusterId = None
+        self.Namespace = None
+        self.PodName = None
+        self.ContainerName = None
+        self.Command = None
+        self.Tty = None
+
+    def _deserialize(self, params):
+        if params.get("ClusterId"):
+            self.ClusterId = params.get("ClusterId")
+        if params.get("Namespace"):
+            self.Namespace = params.get("Namespace")
+        if params.get("PodName"):
+            self.PodName = params.get("PodName")
+        if params.get("ContainerName"):
+            self.ContainerName = params.get("ContainerName")
+        if params.get("Command"):
+            self.Command = params.get("Command")
+        if params.get("Tty"):
+            self.Tty = params.get("Tty")
+
+

ksyun/client/kce/v20201231/client.py

@@ -29,3 +29,5 @@ def CreateCluster(self, request):
                 raise
             else:
                 raise KsyunSDKException(message=str(e))
+
+

ksyun/client/kce/v20230101/client.py

@@ -213,3 +213,5 @@ def DescribeComponentList(self, request):
                 raise
             else:
                 raise KsyunSDKException(message=str(e))
+
+

ksyun/client/kce/v20230306/client.py

@@ -512,3 +512,5 @@ def DropMetrics(self, request):
                 raise
             else:
                 raise KsyunSDKException(message=str(e))
+
+

ksyun/client/kce/v20231115/client.py

@@ -52,3 +52,5 @@ def UpdateClusterDelProtection(self, request):
                 raise
             else:
                 raise KsyunSDKException(message=str(e))
+
+