Skip to content

Commit d867943

Browse files
author
fengyikai
committed
文件存储KPFS(kpfs)：kfps 接入nfs api
1 parent 49f6579 commit d867943

3 files changed

Lines changed: 280 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.56'
17+
__version__ = '1.5.8.57'

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

Lines changed: 138 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -238,3 +238,141 @@ def DescribeDirQuota(self, request):
238238
raise KsyunSDKException(message=str(e))
239239

240240

241+
def UpdatePerformanceNfsAclIp(self, request):
242+
"""编辑NFS访问授权客户端
243+
:param request: Request instance for UpdatePerformanceNfsAclIp.
244+
:type request: :class:`ksyun.client.kpfs.v20240930.models.UpdatePerformanceNfsAclIpRequest`
245+
"""
246+
try:
247+
params = request._serialize()
248+
body = self.call_judge("UpdatePerformanceNfsAclIp", params, "application/json")
249+
response = json.loads(body)
250+
if "Error" not in response:
251+
return body
252+
else:
253+
code = response["Error"]["Code"]
254+
message = response["Error"]["Message"]
255+
req_id = response["RequestId"]
256+
raise KsyunSDKException(code, message, req_id)
257+
except Exception as e:
258+
if isinstance(e, KsyunSDKException):
259+
raise
260+
else:
261+
raise KsyunSDKException(message=str(e))
262+
263+
264+
def RemovePerformanceNfsAclClient(self, request):
265+
"""删除NFS访问授权客户端
266+
:param request: Request instance for RemovePerformanceNfsAclClient.
267+
:type request: :class:`ksyun.client.kpfs.v20240930.models.RemovePerformanceNfsAclClientRequest`
268+
"""
269+
try:
270+
params = request._serialize()
271+
body = self.call_judge("RemovePerformanceNfsAclClient", params, "application/json")
272+
response = json.loads(body)
273+
if "Error" not in response:
274+
return body
275+
else:
276+
code = response["Error"]["Code"]
277+
message = response["Error"]["Message"]
278+
req_id = response["RequestId"]
279+
raise KsyunSDKException(code, message, req_id)
280+
except Exception as e:
281+
if isinstance(e, KsyunSDKException):
282+
raise
283+
else:
284+
raise KsyunSDKException(message=str(e))
285+
286+
287+
def AddPerformanceNfsAclClient(self, request):
288+
"""添加NFS访问授权客户端
289+
:param request: Request instance for AddPerformanceNfsAclClient.
290+
:type request: :class:`ksyun.client.kpfs.v20240930.models.AddPerformanceNfsAclClientRequest`
291+
"""
292+
try:
293+
params = request._serialize()
294+
body = self.call_judge("AddPerformanceNfsAclClient", params, "application/json")
295+
response = json.loads(body)
296+
if "Error" not in response:
297+
return body
298+
else:
299+
code = response["Error"]["Code"]
300+
message = response["Error"]["Message"]
301+
req_id = response["RequestId"]
302+
raise KsyunSDKException(code, message, req_id)
303+
except Exception as e:
304+
if isinstance(e, KsyunSDKException):
305+
raise
306+
else:
307+
raise KsyunSDKException(message=str(e))
308+
309+
310+
def DeletePerformanceOneNfsAcl(self, request):
311+
"""删除NFS协议访问授权
312+
:param request: Request instance for DeletePerformanceOneNfsAcl.
313+
:type request: :class:`ksyun.client.kpfs.v20240930.models.DeletePerformanceOneNfsAclRequest`
314+
"""
315+
try:
316+
params = request._serialize()
317+
body = self.call_judge("DeletePerformanceOneNfsAcl", params, "application/json")
318+
response = json.loads(body)
319+
if "Error" not in response:
320+
return body
321+
else:
322+
code = response["Error"]["Code"]
323+
message = response["Error"]["Message"]
324+
req_id = response["RequestId"]
325+
raise KsyunSDKException(code, message, req_id)
326+
except Exception as e:
327+
if isinstance(e, KsyunSDKException):
328+
raise
329+
else:
330+
raise KsyunSDKException(message=str(e))
331+
332+
333+
def SetPerformanceOneNfsAcl(self, request):
334+
"""新建NFS协议访问授权
335+
:param request: Request instance for SetPerformanceOneNfsAcl.
336+
:type request: :class:`ksyun.client.kpfs.v20240930.models.SetPerformanceOneNfsAclRequest`
337+
"""
338+
try:
339+
params = request._serialize()
340+
body = self.call_judge("SetPerformanceOneNfsAcl", params, "application/json")
341+
response = json.loads(body)
342+
if "Error" not in response:
343+
return body
344+
else:
345+
code = response["Error"]["Code"]
346+
message = response["Error"]["Message"]
347+
req_id = response["RequestId"]
348+
raise KsyunSDKException(code, message, req_id)
349+
except Exception as e:
350+
if isinstance(e, KsyunSDKException):
351+
raise
352+
else:
353+
raise KsyunSDKException(message=str(e))
354+
355+
356+
def DescribePerformanceOneNfsAclList(self, request):
357+
"""查询NFS协议访问授权
358+
:param request: Request instance for DescribePerformanceOneNfsAclList.
359+
:type request: :class:`ksyun.client.kpfs.v20240930.models.DescribePerformanceOneNfsAclListRequest`
360+
"""
361+
try:
362+
params = request._serialize()
363+
body = self.call_judge("DescribePerformanceOneNfsAclList", params, "application/json")
364+
response = json.loads(body)
365+
if "Error" not in response:
366+
return body
367+
else:
368+
code = response["Error"]["Code"]
369+
message = response["Error"]["Message"]
370+
req_id = response["RequestId"]
371+
raise KsyunSDKException(code, message, req_id)
372+
except Exception as e:
373+
if isinstance(e, KsyunSDKException):
374+
raise
375+
else:
376+
raise KsyunSDKException(message=str(e))
377+
378+

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

Lines changed: 141 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -440,3 +440,144 @@ def _deserialize(self, params):
440440
self.DirPath = params.get("DirPath")
441441

442442

443+
class UpdatePerformanceNfsAclIpRequest(AbstractModel):
444+
"""UpdatePerformanceNfsAclIp请求参数结构体
445+
"""
446+
447+
def __init__(self):
448+
r"""编辑NFS访问授权客户端
449+
:param NfsAclId: 访问授权ID。
450+
:type PathPrefix: String
451+
:param Ips: 授权IP配置列表，单次最多编辑20个。
452+
:type PathPrefix: Array
453+
"""
454+
self.NfsAclId = None
455+
self.Ips = None
456+
457+
def _deserialize(self, params):
458+
if params.get("NfsAclId"):
459+
self.NfsAclId = params.get("NfsAclId")
460+
if params.get("Ips"):
461+
self.Ips = params.get("Ips")
462+
463+
464+
class RemovePerformanceNfsAclClientRequest(AbstractModel):
465+
"""RemovePerformanceNfsAclClient请求参数结构体
466+
"""
467+
468+
def __init__(self):
469+
r"""删除NFS访问授权客户端
470+
:param NfsAclId: 访问授权ID。
471+
:type PathPrefix: String
472+
:param Ips: 授权IP列表，为计算节点的私网IP，单次最多删除100个。支持IP（示例：10.0.0.1,10.0.0.2）和网段（示例：10.0.0.1/24）
473+
:type PathPrefix: Array
474+
"""
475+
self.NfsAclId = None
476+
self.Ips = None
477+
478+
def _deserialize(self, params):
479+
if params.get("NfsAclId"):
480+
self.NfsAclId = params.get("NfsAclId")
481+
if params.get("Ips"):
482+
self.Ips = params.get("Ips")
483+
484+
485+
class AddPerformanceNfsAclClientRequest(AbstractModel):
486+
"""AddPerformanceNfsAclClient请求参数结构体
487+
"""
488+
489+
def __init__(self):
490+
r"""添加NFS访问授权客户端
491+
:param NfsAclId: 访问授权ID。
492+
:type PathPrefix: String
493+
:param Ips: 授权IP列表，为计算节点的私网IP，单次最多添加100个。
494+
:type PathPrefix: Array
495+
"""
496+
self.NfsAclId = None
497+
self.Ips = None
498+
499+
def _deserialize(self, params):
500+
if params.get("NfsAclId"):
501+
self.NfsAclId = params.get("NfsAclId")
502+
if params.get("Ips"):
503+
self.Ips = params.get("Ips")
504+
505+
506+
class DeletePerformanceOneNfsAclRequest(AbstractModel):
507+
"""DeletePerformanceOneNfsAcl请求参数结构体
508+
"""
509+
510+
def __init__(self):
511+
r"""删除NFS协议访问授权
512+
:param NfsAclId: 规则ID。
513+
:type PathPrefix: String
514+
"""
515+
self.NfsAclId = None
516+
517+
def _deserialize(self, params):
518+
if params.get("NfsAclId"):
519+
self.NfsAclId = params.get("NfsAclId")
520+
521+
522+
class SetPerformanceOneNfsAclRequest(AbstractModel):
523+
"""SetPerformanceOneNfsAcl请求参数结构体
524+
"""
525+
526+
def __init__(self):
527+
r"""新建NFS协议访问授权
528+
:param FileSystemId: 文件系统的实例ID。
529+
:type PathPrefix: String
530+
:param ExportPath: 共享目录路径。格式：整个文件系统：不传或传/；子目录：支持格式 dir/xxx 或 /dir/xxx 或 dir/xxx/ 或 /dir/xxx/。
531+
:type PathPrefix: String
532+
:param Ips: 授权IP列表，为计算节点的私网IP，单次最多添加100个。
533+
:type PathPrefix: Array
534+
:param Desc: 规则描述信息。0-63字符。
535+
:type PathPrefix: String
536+
"""
537+
self.FileSystemId = None
538+
self.ExportPath = None
539+
self.Ips = None
540+
self.Desc = None
541+
542+
def _deserialize(self, params):
543+
if params.get("FileSystemId"):
544+
self.FileSystemId = params.get("FileSystemId")
545+
if params.get("ExportPath"):
546+
self.ExportPath = params.get("ExportPath")
547+
if params.get("Ips"):
548+
self.Ips = params.get("Ips")
549+
if params.get("Desc"):
550+
self.Desc = params.get("Desc")
551+
552+
553+
class DescribePerformanceOneNfsAclListRequest(AbstractModel):
554+
"""DescribePerformanceOneNfsAclList请求参数结构体
555+
"""
556+
557+
def __init__(self):
558+
r"""查询NFS协议访问授权
559+
:param FileSystemName: 文件系统名称。
560+
:type PathPrefix: String
561+
:param NfsAclId: 规则ID。
562+
:type PathPrefix: String
563+
:param PageNum: 页码。默认为1。
564+
:type PathPrefix: Int
565+
:param PageSize: 分页大小。默认为10。
566+
:type PathPrefix: Int
567+
"""
568+
self.FileSystemName = None
569+
self.NfsAclId = None
570+
self.PageNum = None
571+
self.PageSize = None
572+
573+
def _deserialize(self, params):
574+
if params.get("FileSystemName"):
575+
self.FileSystemName = params.get("FileSystemName")
576+
if params.get("NfsAclId"):
577+
self.NfsAclId = params.get("NfsAclId")
578+
if params.get("PageNum"):
579+
self.PageNum = params.get("PageNum")
580+
if params.get("PageSize"):
581+
self.PageSize = params.get("PageSize")
582+
583+

0 commit comments

Comments
 (0)