Skip to content

Commit baf4485

Browse files
author
fengyikai
committed
文件存储KPFS(kpfs)：v2.5.0 分布式缓存
1 parent b6a3041 commit baf4485

3 files changed

Lines changed: 504 additions & 1 deletion

File tree

‎ksyun/__init__.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,4 +14,4 @@
1414
# limitations under the License.
1515

1616

17-
__version__ = '1.5.8.90'
17+
__version__ = '1.5.8.91'

‎ksyun/client/kpfs/v20240930/client.py‎

Lines changed: 161 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,29 @@ def GetInodeCount(self, request):
7777
raise KsyunSDKException(message=str(e))
7878

7979

80+
def DescribeFileSystemClientInfo(self, request):
81+
"""查询文件系统POSIX客户端信息
82+
:param request: Request instance for DescribeFileSystemClientInfo.
83+
:type request: :class:`ksyun.client.kpfs.v20240930.models.DescribeFileSystemClientInfoRequest`
84+
"""
85+
try:
86+
params = request._serialize()
87+
body = self.call_judge("DescribeFileSystemClientInfo", params, "application/x-www-form-urlencoded")
88+
response = json.loads(body)
89+
if "Error" not in response:
90+
return body
91+
else:
92+
code = response["Error"]["Code"]
93+
message = response["Error"]["Message"]
94+
req_id = response["RequestId"]
95+
raise KsyunSDKException(code, message, req_id)
96+
except Exception as e:
97+
if isinstance(e, KsyunSDKException):
98+
raise
99+
else:
100+
raise KsyunSDKException(message=str(e))
101+
102+
80103
def GetCapacityAvailable(self, request):
81104
"""文件系统可用容量
82105
:param request: Request instance for GetCapacityAvailable.
@@ -767,3 +790,141 @@ def SetFileSystemResourceProtect(self, request):
767790
raise KsyunSDKException(message=str(e))
768791

769792

793+
def GetRemoteCachePutLatency(self, request):
794+
"""分布式缓存组的分布式缓存发送数据延迟
795+
:param request: Request instance for GetRemoteCachePutLatency.
796+
:type request: :class:`ksyun.client.kpfs.v20240930.models.GetRemoteCachePutLatencyRequest`
797+
"""
798+
try:
799+
params = request._serialize()
800+
body = self.call_judge("GetRemoteCachePutLatency", params, "application/x-www-form-urlencoded")
801+
response = json.loads(body)
802+
if "Error" not in response:
803+
return body
804+
else:
805+
code = response["Error"]["Code"]
806+
message = response["Error"]["Message"]
807+
req_id = response["RequestId"]
808+
raise KsyunSDKException(code, message, req_id)
809+
except Exception as e:
810+
if isinstance(e, KsyunSDKException):
811+
raise
812+
else:
813+
raise KsyunSDKException(message=str(e))
814+
815+
816+
def GetRemoteCacheGetLatency(self, request):
817+
"""分布式缓存组的分布式缓存读数据延迟
818+
:param request: Request instance for GetRemoteCacheGetLatency.
819+
:type request: :class:`ksyun.client.kpfs.v20240930.models.GetRemoteCacheGetLatencyRequest`
820+
"""
821+
try:
822+
params = request._serialize()
823+
body = self.call_judge("GetRemoteCacheGetLatency", params, "application/x-www-form-urlencoded")
824+
response = json.loads(body)
825+
if "Error" not in response:
826+
return body
827+
else:
828+
code = response["Error"]["Code"]
829+
message = response["Error"]["Message"]
830+
req_id = response["RequestId"]
831+
raise KsyunSDKException(code, message, req_id)
832+
except Exception as e:
833+
if isinstance(e, KsyunSDKException):
834+
raise
835+
else:
836+
raise KsyunSDKException(message=str(e))
837+
838+
839+
def GetRemoteCachePutThroughput(self, request):
840+
"""分布式缓存组的分布式缓存发送数据吞吐
841+
:param request: Request instance for GetRemoteCachePutThroughput.
842+
:type request: :class:`ksyun.client.kpfs.v20240930.models.GetRemoteCachePutThroughputRequest`
843+
"""
844+
try:
845+
params = request._serialize()
846+
body = self.call_judge("GetRemoteCachePutThroughput", params, "application/x-www-form-urlencoded")
847+
response = json.loads(body)
848+
if "Error" not in response:
849+
return body
850+
else:
851+
code = response["Error"]["Code"]
852+
message = response["Error"]["Message"]
853+
req_id = response["RequestId"]
854+
raise KsyunSDKException(code, message, req_id)
855+
except Exception as e:
856+
if isinstance(e, KsyunSDKException):
857+
raise
858+
else:
859+
raise KsyunSDKException(message=str(e))
860+
861+
862+
def GetRemoteCacheGetThroughput(self, request):
863+
"""分布式缓存组的分布式缓存读数据吞吐量
864+
:param request: Request instance for GetRemoteCacheGetThroughput.
865+
:type request: :class:`ksyun.client.kpfs.v20240930.models.GetRemoteCacheGetThroughputRequest`
866+
"""
867+
try:
868+
params = request._serialize()
869+
body = self.call_judge("GetRemoteCacheGetThroughput", params, "application/x-www-form-urlencoded")
870+
response = json.loads(body)
871+
if "Error" not in response:
872+
return body
873+
else:
874+
code = response["Error"]["Code"]
875+
message = response["Error"]["Message"]
876+
req_id = response["RequestId"]
877+
raise KsyunSDKException(code, message, req_id)
878+
except Exception as e:
879+
if isinstance(e, KsyunSDKException):
880+
raise
881+
else:
882+
raise KsyunSDKException(message=str(e))
883+
884+
885+
def GetRemoteCacheIOPSSend(self, request):
886+
"""分布式缓存组的分布式缓存发送数据请求数
887+
:param request: Request instance for GetRemoteCacheIOPSSend.
888+
:type request: :class:`ksyun.client.kpfs.v20240930.models.GetRemoteCacheIOPSSendRequest`
889+
"""
890+
try:
891+
params = request._serialize()
892+
body = self.call_judge("GetRemoteCacheIOPSSend", params, "application/x-www-form-urlencoded")
893+
response = json.loads(body)
894+
if "Error" not in response:
895+
return body
896+
else:
897+
code = response["Error"]["Code"]
898+
message = response["Error"]["Message"]
899+
req_id = response["RequestId"]
900+
raise KsyunSDKException(code, message, req_id)
901+
except Exception as e:
902+
if isinstance(e, KsyunSDKException):
903+
raise
904+
else:
905+
raise KsyunSDKException(message=str(e))
906+
907+
908+
def GetRemoteCacheIOPSGet(self, request):
909+
"""分布式缓存组的分布式缓存读数据请求数
910+
:param request: Request instance for GetRemoteCacheIOPSGet.
911+
:type request: :class:`ksyun.client.kpfs.v20240930.models.GetRemoteCacheIOPSGetRequest`
912+
"""
913+
try:
914+
params = request._serialize()
915+
body = self.call_judge("GetRemoteCacheIOPSGet", params, "application/x-www-form-urlencoded")
916+
response = json.loads(body)
917+
if "Error" not in response:
918+
return body
919+
else:
920+
code = response["Error"]["Code"]
921+
message = response["Error"]["Message"]
922+
req_id = response["RequestId"]
923+
raise KsyunSDKException(code, message, req_id)
924+
except Exception as e:
925+
if isinstance(e, KsyunSDKException):
926+
raise
927+
else:
928+
raise KsyunSDKException(message=str(e))
929+
930+

0 commit comments

Comments
 (0)