client.rb in tencentcloud-sdk-wedata-3.0.677

- old
+ new

@@ -798,11 +798,11 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
-        #  创建用户自定义函数
+        # 创建用户自定义函数
 
         # @param request: Request instance for CreateCustomFunction.
         # @type request: :class:`Tencentcloud::wedata::V20210820::CreateCustomFunctionRequest`
         # @rtype: :class:`Tencentcloud::wedata::V20210820::CreateCustomFunctionResponse`
         def CreateCustomFunction(request)
@@ -847,10 +847,34 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 编排空间-创建文件夹
+
+        # @param request: Request instance for CreateDsFolder.
+        # @type request: :class:`Tencentcloud::wedata::V20210820::CreateDsFolderRequest`
+        # @rtype: :class:`Tencentcloud::wedata::V20210820::CreateDsFolderResponse`
+        def CreateDsFolder(request)
+          body = send_request('CreateDsFolder', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = CreateDsFolderResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # <p style="color:red;">[注意：该Beta版本只满足广州区部分白名单客户使用]</p>
         # 创建文件夹
 
         # @param request: Request instance for CreateFolder.
         # @type request: :class:`Tencentcloud::wedata::V20210820::CreateFolderRequest`
@@ -1307,10 +1331,34 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 编排空间-删除文件夹
+
+        # @param request: Request instance for DeleteDsFolder.
+        # @type request: :class:`Tencentcloud::wedata::V20210820::DeleteDsFolderRequest`
+        # @rtype: :class:`Tencentcloud::wedata::V20210820::DeleteDsFolderResponse`
+        def DeleteDsFolder(request)
+          body = send_request('DeleteDsFolder', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = DeleteDsFolderResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # 删除文件
 
         # @param request: Request instance for DeleteFile.
         # @type request: :class:`Tencentcloud::wedata::V20210820::DeleteFileRequest`
         # @rtype: :class:`Tencentcloud::wedata::V20210820::DeleteFileResponse`
@@ -2513,10 +2561,58 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 查询目录树
+
+        # @param request: Request instance for DescribeDsFolderTree.
+        # @type request: :class:`Tencentcloud::wedata::V20210820::DescribeDsFolderTreeRequest`
+        # @rtype: :class:`Tencentcloud::wedata::V20210820::DescribeDsFolderTreeResponse`
+        def DescribeDsFolderTree(request)
+          body = send_request('DescribeDsFolderTree', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = DescribeDsFolderTreeResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
+        # 查询父目录树，用于工作流、任务定位
+
+        # @param request: Request instance for DescribeDsParentFolderTree.
+        # @type request: :class:`Tencentcloud::wedata::V20210820::DescribeDsParentFolderTreeRequest`
+        # @rtype: :class:`Tencentcloud::wedata::V20210820::DescribeDsParentFolderTreeResponse`
+        def DescribeDsParentFolderTree(request)
+          body = send_request('DescribeDsParentFolderTree', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = DescribeDsParentFolderTreeResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # 根据项目ID和事件名称查看事件详情
 
         # @param request: Request instance for DescribeEvent.
         # @type request: :class:`Tencentcloud::wedata::V20210820::DescribeEventRequest`
         # @rtype: :class:`Tencentcloud::wedata::V20210820::DescribeEventResponse`
@@ -3428,10 +3524,12 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 没用到
+
         # 获取kafka的topic信息
 
         # @param request: Request instance for DescribeKafkaTopicInfo.
         # @type request: :class:`Tencentcloud::wedata::V20210820::DescribeKafkaTopicInfoRequest`
         # @rtype: :class:`Tencentcloud::wedata::V20210820::DescribeKafkaTopicInfoResponse`
@@ -5570,10 +5668,34 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 查找全部的文件夹
+
+        # @param request: Request instance for FindAllFolder.
+        # @type request: :class:`Tencentcloud::wedata::V20210820::FindAllFolderRequest`
+        # @rtype: :class:`Tencentcloud::wedata::V20210820::FindAllFolderResponse`
+        def FindAllFolder(request)
+          body = send_request('FindAllFolder', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = FindAllFolderResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # <p style="color:red;">[注意：该Beta版本只满足广州区部分白名单客户使用]</p>
         # 实例批量置成功
 
         # @param request: Request instance for ForceSucInstances.
         # @type request: :class:`Tencentcloud::wedata::V20210820::ForceSucInstancesRequest`
@@ -6107,10 +6229,34 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 数据开发模块-文件夹更新
+
+        # @param request: Request instance for ModifyDsFolder.
+        # @type request: :class:`Tencentcloud::wedata::V20210820::ModifyDsFolderRequest`
+        # @rtype: :class:`Tencentcloud::wedata::V20210820::ModifyDsFolderResponse`
+        def ModifyDsFolder(request)
+          body = send_request('ModifyDsFolder', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = ModifyDsFolderResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # 更新规则组执行策略
 
         # @param request: Request instance for ModifyExecStrategy.
         # @type request: :class:`Tencentcloud::wedata::V20210820::ModifyExecStrategyRequest`
         # @rtype: :class:`Tencentcloud::wedata::V20210820::ModifyExecStrategyResponse`
@@ -6678,9 +6824,57 @@
         def RobAndLockIntegrationTask(request)
           body = send_request('RobAndLockIntegrationTask', request.serialize)
           response = JSON.parse(body)
           if response['Response'].key?('Error') == false
             model = RobAndLockIntegrationTaskResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
+        # 实例强制成功
+
+        # @param request: Request instance for RunForceSucScheduleInstances.
+        # @type request: :class:`Tencentcloud::wedata::V20210820::RunForceSucScheduleInstancesRequest`
+        # @rtype: :class:`Tencentcloud::wedata::V20210820::RunForceSucScheduleInstancesResponse`
+        def RunForceSucScheduleInstances(request)
+          body = send_request('RunForceSucScheduleInstances', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = RunForceSucScheduleInstancesResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
+        # 实例批量重跑
+
+        # @param request: Request instance for RunRerunScheduleInstances.
+        # @type request: :class:`Tencentcloud::wedata::V20210820::RunRerunScheduleInstancesRequest`
+        # @rtype: :class:`Tencentcloud::wedata::V20210820::RunRerunScheduleInstancesResponse`
+        def RunRerunScheduleInstances(request)
+          body = send_request('RunRerunScheduleInstances', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = RunRerunScheduleInstancesResponse.new
             model.deserialize(response['Response'])
             model
           else
             code = response['Response']['Error']['Code']
             message = response['Response']['Error']['Message']
\ No newline at end of file