Skip to content

Commit 7f68fc3

Browse files
author
fengyikai
committed
文件存储KPFS(kpfs)：kpfs接入目录配额管理、目录管理api
1 parent 54cb4c2 commit 7f68fc3

5 files changed

Lines changed: 614 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.48'
17+
__version__ = '1.5.8.49'

‎ksyun/client/kpfs/__init__.py‎

Whitespace-only changes.

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

Whitespace-only changes.

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

Lines changed: 217 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,217 @@
1+
import json
2+
3+
from ksyun.common.exception.ksyun_sdk_exception import KsyunSDKException
4+
from ksyun.common.abstract_client import AbstractClient
5+
6+
7+
class KpfsClient(AbstractClient):
8+
_apiVersion = '2024-09-30'
9+
_endpoint = 'kpfs.api.ksyun.com'
10+
_service = 'kpfs'
11+
def DescribeDirQuotaList(self, request):
12+
"""查询目录配额列表
13+
:param request: Request instance for DescribeDirQuotaList.
14+
:type request: :class:`ksyun.client.kpfs.v20240930.models.DescribeDirQuotaListRequest`
15+
"""
16+
try:
17+
params = request._serialize()
18+
body = self.call_judge("DescribeDirQuotaList", params, "application/x-www-form-urlencoded")
19+
response = json.loads(body)
20+
if "Error" not in response:
21+
return body
22+
else:
23+
code = response["Error"]["Code"]
24+
message = response["Error"]["Message"]
25+
req_id = response["RequestId"]
26+
raise KsyunSDKException(code, message, req_id)
27+
except Exception as e:
28+
if isinstance(e, KsyunSDKException):
29+
raise
30+
else:
31+
raise KsyunSDKException(message=str(e))
32+
33+
34+
def DeleteDirQuota(self, request):
35+
"""删除目录配额
36+
:param request: Request instance for DeleteDirQuota.
37+
:type request: :class:`ksyun.client.kpfs.v20240930.models.DeleteDirQuotaRequest`
38+
"""
39+
try:
40+
params = request._serialize()
41+
body = self.call_judge("DeleteDirQuota", params, "application/json")
42+
response = json.loads(body)
43+
if "Error" not in response:
44+
return body
45+
else:
46+
code = response["Error"]["Code"]
47+
message = response["Error"]["Message"]
48+
req_id = response["RequestId"]
49+
raise KsyunSDKException(code, message, req_id)
50+
except Exception as e:
51+
if isinstance(e, KsyunSDKException):
52+
raise
53+
else:
54+
raise KsyunSDKException(message=str(e))
55+
56+
57+
def UpdateDirQuota(self, request):
58+
"""修改目录配额
59+
:param request: Request instance for UpdateDirQuota.
60+
:type request: :class:`ksyun.client.kpfs.v20240930.models.UpdateDirQuotaRequest`
61+
"""
62+
try:
63+
params = request._serialize()
64+
body = self.call_judge("UpdateDirQuota", params, "application/json")
65+
response = json.loads(body)
66+
if "Error" not in response:
67+
return body
68+
else:
69+
code = response["Error"]["Code"]
70+
message = response["Error"]["Message"]
71+
req_id = response["RequestId"]
72+
raise KsyunSDKException(code, message, req_id)
73+
except Exception as e:
74+
if isinstance(e, KsyunSDKException):
75+
raise
76+
else:
77+
raise KsyunSDKException(message=str(e))
78+
79+
80+
def CreateDirQuota(self, request):
81+
"""新建目录配额
82+
:param request: Request instance for CreateDirQuota.
83+
:type request: :class:`ksyun.client.kpfs.v20240930.models.CreateDirQuotaRequest`
84+
"""
85+
try:
86+
params = request._serialize()
87+
body = self.call_judge("CreateDirQuota", params, "application/json")
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+
103+
def DescribeSubDirList(self, request):
104+
"""查询文件系统或特定目录的子目录列表
105+
:param request: Request instance for DescribeSubDirList.
106+
:type request: :class:`ksyun.client.kpfs.v20240930.models.DescribeSubDirListRequest`
107+
"""
108+
try:
109+
params = request._serialize()
110+
body = self.call_judge("DescribeSubDirList", params, "application/x-www-form-urlencoded")
111+
response = json.loads(body)
112+
if "Error" not in response:
113+
return body
114+
else:
115+
code = response["Error"]["Code"]
116+
message = response["Error"]["Message"]
117+
req_id = response["RequestId"]
118+
raise KsyunSDKException(code, message, req_id)
119+
except Exception as e:
120+
if isinstance(e, KsyunSDKException):
121+
raise
122+
else:
123+
raise KsyunSDKException(message=str(e))
124+
125+
126+
def DeleteDir(self, request):
127+
"""删除文件系统目录
128+
:param request: Request instance for DeleteDir.
129+
:type request: :class:`ksyun.client.kpfs.v20240930.models.DeleteDirRequest`
130+
"""
131+
try:
132+
params = request._serialize()
133+
body = self.call_judge("DeleteDir", params, "application/json")
134+
response = json.loads(body)
135+
if "Error" not in response:
136+
return body
137+
else:
138+
code = response["Error"]["Code"]
139+
message = response["Error"]["Message"]
140+
req_id = response["RequestId"]
141+
raise KsyunSDKException(code, message, req_id)
142+
except Exception as e:
143+
if isinstance(e, KsyunSDKException):
144+
raise
145+
else:
146+
raise KsyunSDKException(message=str(e))
147+
148+
149+
def UpdateDir(self, request):
150+
"""修改文件系统目录
151+
:param request: Request instance for UpdateDir.
152+
:type request: :class:`ksyun.client.kpfs.v20240930.models.UpdateDirRequest`
153+
"""
154+
try:
155+
params = request._serialize()
156+
body = self.call_judge("UpdateDir", params, "application/json")
157+
response = json.loads(body)
158+
if "Error" not in response:
159+
return body
160+
else:
161+
code = response["Error"]["Code"]
162+
message = response["Error"]["Message"]
163+
req_id = response["RequestId"]
164+
raise KsyunSDKException(code, message, req_id)
165+
except Exception as e:
166+
if isinstance(e, KsyunSDKException):
167+
raise
168+
else:
169+
raise KsyunSDKException(message=str(e))
170+
171+
172+
def CreateDir(self, request):
173+
"""新建文件系统目录
174+
:param request: Request instance for CreateDir.
175+
:type request: :class:`ksyun.client.kpfs.v20240930.models.CreateDirRequest`
176+
"""
177+
try:
178+
params = request._serialize()
179+
body = self.call_judge("CreateDir", params, "application/json")
180+
response = json.loads(body)
181+
if "Error" not in response:
182+
return body
183+
else:
184+
code = response["Error"]["Code"]
185+
message = response["Error"]["Message"]
186+
req_id = response["RequestId"]
187+
raise KsyunSDKException(code, message, req_id)
188+
except Exception as e:
189+
if isinstance(e, KsyunSDKException):
190+
raise
191+
else:
192+
raise KsyunSDKException(message=str(e))
193+
194+
195+
def DescribeDirQuota(self, request):
196+
"""查询指定目录配额
197+
:param request: Request instance for DescribeDirQuota.
198+
:type request: :class:`ksyun.client.kpfs.v20240930.models.DescribeDirQuotaRequest`
199+
"""
200+
try:
201+
params = request._serialize()
202+
body = self.call_judge("DescribeDirQuota", params, "application/x-www-form-urlencoded")
203+
response = json.loads(body)
204+
if "Error" not in response:
205+
return body
206+
else:
207+
code = response["Error"]["Code"]
208+
message = response["Error"]["Message"]
209+
req_id = response["RequestId"]
210+
raise KsyunSDKException(code, message, req_id)
211+
except Exception as e:
212+
if isinstance(e, KsyunSDKException):
213+
raise
214+
else:
215+
raise KsyunSDKException(message=str(e))
216+
217+

0 commit comments

Comments
 (0)