oceanus_client.py

# -*- coding: utf8 -*-
# Copyright (c) 2017-2021 THL A29 Limited, a Tencent company. All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import json

from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException
from tencentcloud.common.abstract_client import AbstractClient
from tencentcloud.oceanus.v20190422 import models


class OceanusClient(AbstractClient):
    _apiVersion = '2019-04-22'
    _endpoint = 'oceanus.tencentcloudapi.com'
    _service = 'oceanus'


    def CheckSavepoint(self, request):
        """检查快照是否可用

        :param request: Request instance for CheckSavepoint.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.CheckSavepointRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.CheckSavepointResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("CheckSavepoint", params, headers=headers)
            response = json.loads(body)
            model = models.CheckSavepointResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def CopyJobs(self, request):
        """单条和批量复制作业

        :param request: Request instance for CopyJobs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.CopyJobsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.CopyJobsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("CopyJobs", params, headers=headers)
            response = json.loads(body)
            model = models.CopyJobsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def CreateFolder(self, request):
        """作业列表页面新建文件夹请求

        :param request: Request instance for CreateFolder.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.CreateFolderRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.CreateFolderResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("CreateFolder", params, headers=headers)
            response = json.loads(body)
            model = models.CreateFolderResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def CreateJob(self, request):
        """新建作业接口，一个 AppId 最多允许创建1000个作业

        :param request: Request instance for CreateJob.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.CreateJobRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.CreateJobResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("CreateJob", params, headers=headers)
            response = json.loads(body)
            model = models.CreateJobResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def CreateJobConfig(self, request):
        """创建作业配置，一个作业最多有100个配置版本

        :param request: Request instance for CreateJobConfig.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.CreateJobConfigRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.CreateJobConfigResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("CreateJobConfig", params, headers=headers)
            response = json.loads(body)
            model = models.CreateJobConfigResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def CreateResource(self, request):
        """创建资源接口

        :param request: Request instance for CreateResource.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.CreateResourceRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.CreateResourceResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("CreateResource", params, headers=headers)
            response = json.loads(body)
            model = models.CreateResourceResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def CreateResourceConfig(self, request):
        """创建资源配置接口

        :param request: Request instance for CreateResourceConfig.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.CreateResourceConfigRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.CreateResourceConfigResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("CreateResourceConfig", params, headers=headers)
            response = json.loads(body)
            model = models.CreateResourceConfigResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def CreateWorkSpace(self, request):
        """创建工作空间

        :param request: Request instance for CreateWorkSpace.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.CreateWorkSpaceRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.CreateWorkSpaceResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("CreateWorkSpace", params, headers=headers)
            response = json.loads(body)
            model = models.CreateWorkSpaceResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DeleteFolders(self, request):
        """作业列表删除文件夹

        :param request: Request instance for DeleteFolders.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DeleteFoldersRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DeleteFoldersResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DeleteFolders", params, headers=headers)
            response = json.loads(body)
            model = models.DeleteFoldersResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DeleteJobConfigs(self, request):
        """删除作业配置

        :param request: Request instance for DeleteJobConfigs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DeleteJobConfigsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DeleteJobConfigsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DeleteJobConfigs", params, headers=headers)
            response = json.loads(body)
            model = models.DeleteJobConfigsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DeleteJobs(self, request):
        """批量删除作业接口，批量操作数量上限20

        :param request: Request instance for DeleteJobs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DeleteJobsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DeleteJobsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DeleteJobs", params, headers=headers)
            response = json.loads(body)
            model = models.DeleteJobsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DeleteResourceConfigs(self, request):
        """删除资源版本

        :param request: Request instance for DeleteResourceConfigs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DeleteResourceConfigsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DeleteResourceConfigsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DeleteResourceConfigs", params, headers=headers)
            response = json.loads(body)
            model = models.DeleteResourceConfigsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DeleteResources(self, request):
        """删除资源接口

        :param request: Request instance for DeleteResources.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DeleteResourcesRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DeleteResourcesResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DeleteResources", params, headers=headers)
            response = json.loads(body)
            model = models.DeleteResourcesResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DeleteTableConfig(self, request):
        """删除作业表配置

        :param request: Request instance for DeleteTableConfig.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DeleteTableConfigRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DeleteTableConfigResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DeleteTableConfig", params, headers=headers)
            response = json.loads(body)
            model = models.DeleteTableConfigResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DeleteWorkSpace(self, request):
        """删除工作空间

        :param request: Request instance for DeleteWorkSpace.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DeleteWorkSpaceRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DeleteWorkSpaceResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DeleteWorkSpace", params, headers=headers)
            response = json.loads(body)
            model = models.DeleteWorkSpaceResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeClusters(self, request):
        """查询集群

        :param request: Request instance for DescribeClusters.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeClustersRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeClustersResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeClusters", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeClustersResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeFolder(self, request):
        """查询指定文件夹及其相应的子文件夹信息

        :param request: Request instance for DescribeFolder.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeFolderRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeFolderResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeFolder", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeFolderResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeJobConfigs(self, request):
        """查询作业配置列表，一次最多查询100个

        :param request: Request instance for DescribeJobConfigs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobConfigsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobConfigsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeJobConfigs", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeJobConfigsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeJobEvents(self, request):
        """获取指定作业的事件，包括作业启动停止、运行失败、快照失败、作业异常等各种事件类型

        :param request: Request instance for DescribeJobEvents.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobEventsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobEventsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeJobEvents", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeJobEventsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeJobSavepoint(self, request):
        """查找Savepoint列表

        :param request: Request instance for DescribeJobSavepoint.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobSavepointRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobSavepointResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeJobSavepoint", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeJobSavepointResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeJobSubmissionLog(self, request):
        """查询作业实例启动日志

        :param request: Request instance for DescribeJobSubmissionLog.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobSubmissionLogRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobSubmissionLogResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeJobSubmissionLog", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeJobSubmissionLogResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeJobs(self, request):
        """查询作业

        :param request: Request instance for DescribeJobs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeJobsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeJobs", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeJobsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeResourceConfigs(self, request):
        """描述资源配置接口

        :param request: Request instance for DescribeResourceConfigs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeResourceConfigsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeResourceConfigsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeResourceConfigs", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeResourceConfigsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeResourceRelatedJobs(self, request):
        """获取资源关联作业信息

        :param request: Request instance for DescribeResourceRelatedJobs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeResourceRelatedJobsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeResourceRelatedJobsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeResourceRelatedJobs", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeResourceRelatedJobsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeResources(self, request):
        """描述资源接口

        :param request: Request instance for DescribeResources.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeResourcesRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeResourcesResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeResources", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeResourcesResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeSystemResources(self, request):
        """描述系统资源接口

        :param request: Request instance for DescribeSystemResources.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeSystemResourcesRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeSystemResourcesResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeSystemResources", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeSystemResourcesResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeTreeJobs(self, request):
        """生成树状作业显示结构

        :param request: Request instance for DescribeTreeJobs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeTreeJobsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeTreeJobsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeTreeJobs", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeTreeJobsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeTreeResources(self, request):
        """查询树状结构资源列表

        :param request: Request instance for DescribeTreeResources.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeTreeResourcesRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeTreeResourcesResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeTreeResources", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeTreeResourcesResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def DescribeWorkSpaces(self, request):
        """授权工作空间列表

        :param request: Request instance for DescribeWorkSpaces.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.DescribeWorkSpacesRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.DescribeWorkSpacesResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("DescribeWorkSpaces", params, headers=headers)
            response = json.loads(body)
            model = models.DescribeWorkSpacesResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def FetchSqlGatewayStatementResult(self, request):
        """查询Sql Gateway的Statement执行结果

        :param request: Request instance for FetchSqlGatewayStatementResult.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.FetchSqlGatewayStatementResultRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.FetchSqlGatewayStatementResultResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("FetchSqlGatewayStatementResult", params, headers=headers)
            response = json.loads(body)
            model = models.FetchSqlGatewayStatementResultResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def GetMetaTable(self, request):
        """查询元数据表

        :param request: Request instance for GetMetaTable.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.GetMetaTableRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.GetMetaTableResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("GetMetaTable", params, headers=headers)
            response = json.loads(body)
            model = models.GetMetaTableResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def ModifyFolder(self, request):
        """自定义树状结构页面拖拽文件夹

        :param request: Request instance for ModifyFolder.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.ModifyFolderRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.ModifyFolderResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("ModifyFolder", params, headers=headers)
            response = json.loads(body)
            model = models.ModifyFolderResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def ModifyJob(self, request):
        """更新作业属性，仅允许以下3种操作，不支持组合操作：
        (1)	更新作业名称
        (2)	更新作业备注
        (3)	更新作业最大并行度
        变更前提：WorkerCuNum<=MaxParallelism
        如果MaxParallelism变小，不重启作业，待下一次重启生效
        如果MaxParallelism变大，则要求入参RestartAllowed必须为True
        假设作业运行状态，则先停止作业，再启动作业，中间状态丢失
        假设作业暂停状态，则将作业更改为停止状态，中间状态丢失

        :param request: Request instance for ModifyJob.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.ModifyJobRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.ModifyJobResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("ModifyJob", params, headers=headers)
            response = json.loads(body)
            model = models.ModifyJobResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def ModifyWorkSpace(self, request):
        """修改工作空间

        :param request: Request instance for ModifyWorkSpace.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.ModifyWorkSpaceRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.ModifyWorkSpaceResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("ModifyWorkSpace", params, headers=headers)
            response = json.loads(body)
            model = models.ModifyWorkSpaceResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def RunJobs(self, request):
        """批量启动或者恢复作业，批量操作数量上限20

        :param request: Request instance for RunJobs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.RunJobsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.RunJobsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("RunJobs", params, headers=headers)
            response = json.loads(body)
            model = models.RunJobsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def RunSqlGatewayStatement(self, request):
        """通过Sql gateway执行satement

        :param request: Request instance for RunSqlGatewayStatement.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.RunSqlGatewayStatementRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.RunSqlGatewayStatementResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("RunSqlGatewayStatement", params, headers=headers)
            response = json.loads(body)
            model = models.RunSqlGatewayStatementResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def StopJobs(self, request):
        """批量停止作业，批量操作数量上限为20

        :param request: Request instance for StopJobs.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.StopJobsRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.StopJobsResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("StopJobs", params, headers=headers)
            response = json.loads(body)
            model = models.StopJobsResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))


    def TriggerJobSavepoint(self, request):
        """触发Savepoint

        :param request: Request instance for TriggerJobSavepoint.
        :type request: :class:`tencentcloud.oceanus.v20190422.models.TriggerJobSavepointRequest`
        :rtype: :class:`tencentcloud.oceanus.v20190422.models.TriggerJobSavepointResponse`

        """
        try:
            params = request._serialize()
            headers = request.headers
            body = self.call("TriggerJobSavepoint", params, headers=headers)
            response = json.loads(body)
            model = models.TriggerJobSavepointResponse()
            model._deserialize(response["Response"])
            return model
        except Exception as e:
            if isinstance(e, TencentCloudSDKException):
                raise
            else:
                raise TencentCloudSDKException(type(e).__name__, str(e))