1 Star 8 Fork 0

tencentcloud/tencentcloud-sdk-ruby

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
client.rb 84.65 KB
一键复制 编辑 原始数据 按行查看 历史
tencentcloud 提交于 2025-09-23 04:33 +08:00 . release 3.0.1144
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884
# frozen_string_literal: true
# Copyright (c) 2017-2025 Tencent. 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.
require 'json'
module TencentCloud
module Wedata
module V20250806
class Client < TencentCloud::Common::AbstractClient
def initialize(credential, region, profile = nil)
api_version = '2025-08-06'
api_endpoint = 'wedata.tencentcloudapi.com'
sdk_version = 'WEDATA_' + File.read(File.expand_path('../VERSION', __dir__)).strip
super(credential, region, api_version, api_endpoint, sdk_version, profile)
end
# 新建代码文件
# @param request: Request instance for CreateCodeFile.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateCodeFileRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateCodeFileResponse`
def CreateCodeFile(request)
body = send_request('CreateCodeFile', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateCodeFileResponse.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 CreateCodeFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateCodeFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateCodeFolderResponse`
def CreateCodeFolder(request)
body = send_request('CreateCodeFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateCodeFolderResponse.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 CreateDataBackfillPlan.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateDataBackfillPlanRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateDataBackfillPlanResponse`
def CreateDataBackfillPlan(request)
body = send_request('CreateDataBackfillPlan', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateDataBackfillPlanResponse.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 CreateOpsAlarmRule.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateOpsAlarmRuleRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateOpsAlarmRuleResponse`
def CreateOpsAlarmRule(request)
body = send_request('CreateOpsAlarmRule', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateOpsAlarmRuleResponse.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 CreateResourceFile.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateResourceFileRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateResourceFileResponse`
def CreateResourceFile(request)
body = send_request('CreateResourceFile', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateResourceFileResponse.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 CreateResourceFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateResourceFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateResourceFolderResponse`
def CreateResourceFolder(request)
body = send_request('CreateResourceFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateResourceFolderResponse.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 CreateSQLFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateSQLFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateSQLFolderResponse`
def CreateSQLFolder(request)
body = send_request('CreateSQLFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateSQLFolderResponse.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
# 新增SQL脚本
# @param request: Request instance for CreateSQLScript.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateSQLScriptRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateSQLScriptResponse`
def CreateSQLScript(request)
body = send_request('CreateSQLScript', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateSQLScriptResponse.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 CreateTask.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateTaskRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateTaskResponse`
def CreateTask(request)
body = send_request('CreateTask', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateTaskResponse.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 CreateWorkflow.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateWorkflowRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateWorkflowResponse`
def CreateWorkflow(request)
body = send_request('CreateWorkflow', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateWorkflowResponse.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 CreateWorkflowFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::CreateWorkflowFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::CreateWorkflowFolderResponse`
def CreateWorkflowFolder(request)
body = send_request('CreateWorkflowFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = CreateWorkflowFolderResponse.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 DeleteCodeFile.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteCodeFileRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteCodeFileResponse`
def DeleteCodeFile(request)
body = send_request('DeleteCodeFile', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteCodeFileResponse.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 DeleteCodeFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteCodeFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteCodeFolderResponse`
def DeleteCodeFolder(request)
body = send_request('DeleteCodeFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteCodeFolderResponse.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 DeleteOpsAlarmRule.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteOpsAlarmRuleRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteOpsAlarmRuleResponse`
def DeleteOpsAlarmRule(request)
body = send_request('DeleteOpsAlarmRule', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteOpsAlarmRuleResponse.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 DeleteResourceFile.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteResourceFileRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteResourceFileResponse`
def DeleteResourceFile(request)
body = send_request('DeleteResourceFile', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteResourceFileResponse.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 DeleteResourceFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteResourceFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteResourceFolderResponse`
def DeleteResourceFolder(request)
body = send_request('DeleteResourceFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteResourceFolderResponse.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
# 删除SQL文件夹
# @param request: Request instance for DeleteSQLFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteSQLFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteSQLFolderResponse`
def DeleteSQLFolder(request)
body = send_request('DeleteSQLFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteSQLFolderResponse.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 DeleteSQLScript.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteSQLScriptRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteSQLScriptResponse`
def DeleteSQLScript(request)
body = send_request('DeleteSQLScript', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteSQLScriptResponse.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 DeleteTask.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteTaskRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteTaskResponse`
def DeleteTask(request)
body = send_request('DeleteTask', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteTaskResponse.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 DeleteWorkflow.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteWorkflowRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteWorkflowResponse`
def DeleteWorkflow(request)
body = send_request('DeleteWorkflow', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteWorkflowResponse.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 DeleteWorkflowFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::DeleteWorkflowFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::DeleteWorkflowFolderResponse`
def DeleteWorkflowFolder(request)
body = send_request('DeleteWorkflowFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = DeleteWorkflowFolderResponse.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 GetAlarmMessage.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetAlarmMessageRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetAlarmMessageResponse`
def GetAlarmMessage(request)
body = send_request('GetAlarmMessage', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetAlarmMessageResponse.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 GetCodeFile.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetCodeFileRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetCodeFileResponse`
def GetCodeFile(request)
body = send_request('GetCodeFile', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetCodeFileResponse.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 GetOpsAlarmRule.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetOpsAlarmRuleRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetOpsAlarmRuleResponse`
def GetOpsAlarmRule(request)
body = send_request('GetOpsAlarmRule', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetOpsAlarmRuleResponse.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 GetOpsAsyncJob.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetOpsAsyncJobRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetOpsAsyncJobResponse`
def GetOpsAsyncJob(request)
body = send_request('GetOpsAsyncJob', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetOpsAsyncJobResponse.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 GetOpsTask.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetOpsTaskRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetOpsTaskResponse`
def GetOpsTask(request)
body = send_request('GetOpsTask', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetOpsTaskResponse.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 GetOpsTaskCode.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetOpsTaskCodeRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetOpsTaskCodeResponse`
def GetOpsTaskCode(request)
body = send_request('GetOpsTaskCode', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetOpsTaskCodeResponse.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 GetOpsWorkflow.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetOpsWorkflowRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetOpsWorkflowResponse`
def GetOpsWorkflow(request)
body = send_request('GetOpsWorkflow', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetOpsWorkflowResponse.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 GetResourceFile.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetResourceFileRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetResourceFileResponse`
def GetResourceFile(request)
body = send_request('GetResourceFile', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetResourceFileResponse.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 GetSQLScript.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetSQLScriptRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetSQLScriptResponse`
def GetSQLScript(request)
body = send_request('GetSQLScript', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetSQLScriptResponse.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 GetTask.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetTaskRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetTaskResponse`
def GetTask(request)
body = send_request('GetTask', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetTaskResponse.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 GetTaskCode.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetTaskCodeRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetTaskCodeResponse`
def GetTaskCode(request)
body = send_request('GetTaskCode', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetTaskCodeResponse.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 GetTaskInstance.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetTaskInstanceRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetTaskInstanceResponse`
def GetTaskInstance(request)
body = send_request('GetTaskInstance', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetTaskInstanceResponse.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 GetTaskInstanceLog.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetTaskInstanceLogRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetTaskInstanceLogResponse`
def GetTaskInstanceLog(request)
body = send_request('GetTaskInstanceLog', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetTaskInstanceLogResponse.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 GetTaskVersion.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetTaskVersionRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetTaskVersionResponse`
def GetTaskVersion(request)
body = send_request('GetTaskVersion', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetTaskVersionResponse.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 GetWorkflow.
# @type request: :class:`Tencentcloud::wedata::V20250806::GetWorkflowRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::GetWorkflowResponse`
def GetWorkflow(request)
body = send_request('GetWorkflow', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = GetWorkflowResponse.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 KillTaskInstancesAsync.
# @type request: :class:`Tencentcloud::wedata::V20250806::KillTaskInstancesAsyncRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::KillTaskInstancesAsyncResponse`
def KillTaskInstancesAsync(request)
body = send_request('KillTaskInstancesAsync', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = KillTaskInstancesAsyncResponse.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 ListAlarmMessages.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListAlarmMessagesRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListAlarmMessagesResponse`
def ListAlarmMessages(request)
body = send_request('ListAlarmMessages', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListAlarmMessagesResponse.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 ListCodeFolderContents.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListCodeFolderContentsRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListCodeFolderContentsResponse`
def ListCodeFolderContents(request)
body = send_request('ListCodeFolderContents', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListCodeFolderContentsResponse.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 ListDataBackfillInstances.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListDataBackfillInstancesRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListDataBackfillInstancesResponse`
def ListDataBackfillInstances(request)
body = send_request('ListDataBackfillInstances', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListDataBackfillInstancesResponse.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 ListDownstreamOpsTasks.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListDownstreamOpsTasksRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListDownstreamOpsTasksResponse`
def ListDownstreamOpsTasks(request)
body = send_request('ListDownstreamOpsTasks', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListDownstreamOpsTasksResponse.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 ListDownstreamTaskInstances.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListDownstreamTaskInstancesRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListDownstreamTaskInstancesResponse`
def ListDownstreamTaskInstances(request)
body = send_request('ListDownstreamTaskInstances', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListDownstreamTaskInstancesResponse.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 ListDownstreamTasks.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListDownstreamTasksRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListDownstreamTasksResponse`
def ListDownstreamTasks(request)
body = send_request('ListDownstreamTasks', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListDownstreamTasksResponse.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 ListOpsAlarmRules.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListOpsAlarmRulesRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListOpsAlarmRulesResponse`
def ListOpsAlarmRules(request)
body = send_request('ListOpsAlarmRules', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListOpsAlarmRulesResponse.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 ListOpsTasks.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListOpsTasksRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListOpsTasksResponse`
def ListOpsTasks(request)
body = send_request('ListOpsTasks', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListOpsTasksResponse.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 ListOpsWorkflows.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListOpsWorkflowsRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListOpsWorkflowsResponse`
def ListOpsWorkflows(request)
body = send_request('ListOpsWorkflows', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListOpsWorkflowsResponse.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 ListResourceFiles.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListResourceFilesRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListResourceFilesResponse`
def ListResourceFiles(request)
body = send_request('ListResourceFiles', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListResourceFilesResponse.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 ListResourceFolders.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListResourceFoldersRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListResourceFoldersResponse`
def ListResourceFolders(request)
body = send_request('ListResourceFolders', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListResourceFoldersResponse.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 ListSQLFolderContents.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListSQLFolderContentsRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListSQLFolderContentsResponse`
def ListSQLFolderContents(request)
body = send_request('ListSQLFolderContents', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListSQLFolderContentsResponse.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
# 查询SQL运行记录
# @param request: Request instance for ListSQLScriptRuns.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListSQLScriptRunsRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListSQLScriptRunsResponse`
def ListSQLScriptRuns(request)
body = send_request('ListSQLScriptRuns', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListSQLScriptRunsResponse.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 ListTaskInstanceExecutions.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListTaskInstanceExecutionsRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListTaskInstanceExecutionsResponse`
def ListTaskInstanceExecutions(request)
body = send_request('ListTaskInstanceExecutions', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListTaskInstanceExecutionsResponse.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 ListTaskInstances.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListTaskInstancesRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListTaskInstancesResponse`
def ListTaskInstances(request)
body = send_request('ListTaskInstances', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListTaskInstancesResponse.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 ListTaskVersions.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListTaskVersionsRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListTaskVersionsResponse`
def ListTaskVersions(request)
body = send_request('ListTaskVersions', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListTaskVersionsResponse.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 ListTasks.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListTasksRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListTasksResponse`
def ListTasks(request)
body = send_request('ListTasks', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListTasksResponse.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 ListUpstreamOpsTasks.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListUpstreamOpsTasksRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListUpstreamOpsTasksResponse`
def ListUpstreamOpsTasks(request)
body = send_request('ListUpstreamOpsTasks', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListUpstreamOpsTasksResponse.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 ListUpstreamTaskInstances.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListUpstreamTaskInstancesRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListUpstreamTaskInstancesResponse`
def ListUpstreamTaskInstances(request)
body = send_request('ListUpstreamTaskInstances', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListUpstreamTaskInstancesResponse.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 ListUpstreamTasks.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListUpstreamTasksRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListUpstreamTasksResponse`
def ListUpstreamTasks(request)
body = send_request('ListUpstreamTasks', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListUpstreamTasksResponse.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 ListWorkflowFolders.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListWorkflowFoldersRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListWorkflowFoldersResponse`
def ListWorkflowFolders(request)
body = send_request('ListWorkflowFolders', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListWorkflowFoldersResponse.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 ListWorkflows.
# @type request: :class:`Tencentcloud::wedata::V20250806::ListWorkflowsRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::ListWorkflowsResponse`
def ListWorkflows(request)
body = send_request('ListWorkflows', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = ListWorkflowsResponse.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 PauseOpsTasksAsync.
# @type request: :class:`Tencentcloud::wedata::V20250806::PauseOpsTasksAsyncRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::PauseOpsTasksAsyncResponse`
def PauseOpsTasksAsync(request)
body = send_request('PauseOpsTasksAsync', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = PauseOpsTasksAsyncResponse.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 RerunTaskInstancesAsync.
# @type request: :class:`Tencentcloud::wedata::V20250806::RerunTaskInstancesAsyncRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::RerunTaskInstancesAsyncResponse`
def RerunTaskInstancesAsync(request)
body = send_request('RerunTaskInstancesAsync', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = RerunTaskInstancesAsyncResponse.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
# 运行SQL脚本
# @param request: Request instance for RunSQLScript.
# @type request: :class:`Tencentcloud::wedata::V20250806::RunSQLScriptRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::RunSQLScriptResponse`
def RunSQLScript(request)
body = send_request('RunSQLScript', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = RunSQLScriptResponse.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 SetSuccessTaskInstancesAsync.
# @type request: :class:`Tencentcloud::wedata::V20250806::SetSuccessTaskInstancesAsyncRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::SetSuccessTaskInstancesAsyncResponse`
def SetSuccessTaskInstancesAsync(request)
body = send_request('SetSuccessTaskInstancesAsync', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = SetSuccessTaskInstancesAsyncResponse.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 StopOpsTasksAsync.
# @type request: :class:`Tencentcloud::wedata::V20250806::StopOpsTasksAsyncRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::StopOpsTasksAsyncResponse`
def StopOpsTasksAsync(request)
body = send_request('StopOpsTasksAsync', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = StopOpsTasksAsyncResponse.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
# 停止运行SQL脚本
# @param request: Request instance for StopSQLScriptRun.
# @type request: :class:`Tencentcloud::wedata::V20250806::StopSQLScriptRunRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::StopSQLScriptRunResponse`
def StopSQLScriptRun(request)
body = send_request('StopSQLScriptRun', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = StopSQLScriptRunResponse.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 SubmitTask.
# @type request: :class:`Tencentcloud::wedata::V20250806::SubmitTaskRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::SubmitTaskResponse`
def SubmitTask(request)
body = send_request('SubmitTask', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = SubmitTaskResponse.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 UpdateCodeFile.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateCodeFileRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateCodeFileResponse`
def UpdateCodeFile(request)
body = send_request('UpdateCodeFile', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateCodeFileResponse.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 UpdateCodeFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateCodeFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateCodeFolderResponse`
def UpdateCodeFolder(request)
body = send_request('UpdateCodeFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateCodeFolderResponse.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 UpdateOpsAlarmRule.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateOpsAlarmRuleRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateOpsAlarmRuleResponse`
def UpdateOpsAlarmRule(request)
body = send_request('UpdateOpsAlarmRule', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateOpsAlarmRuleResponse.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 UpdateOpsTasksOwner.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateOpsTasksOwnerRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateOpsTasksOwnerResponse`
def UpdateOpsTasksOwner(request)
body = send_request('UpdateOpsTasksOwner', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateOpsTasksOwnerResponse.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 UpdateResourceFile.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateResourceFileRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateResourceFileResponse`
def UpdateResourceFile(request)
body = send_request('UpdateResourceFile', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateResourceFileResponse.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 UpdateResourceFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateResourceFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateResourceFolderResponse`
def UpdateResourceFolder(request)
body = send_request('UpdateResourceFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateResourceFolderResponse.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
# 重命名SQL文件夹
# @param request: Request instance for UpdateSQLFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateSQLFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateSQLFolderResponse`
def UpdateSQLFolder(request)
body = send_request('UpdateSQLFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateSQLFolderResponse.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 UpdateSQLScript.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateSQLScriptRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateSQLScriptResponse`
def UpdateSQLScript(request)
body = send_request('UpdateSQLScript', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateSQLScriptResponse.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 UpdateTask.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateTaskRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateTaskResponse`
def UpdateTask(request)
body = send_request('UpdateTask', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateTaskResponse.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 UpdateWorkflow.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateWorkflowRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateWorkflowResponse`
def UpdateWorkflow(request)
body = send_request('UpdateWorkflow', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateWorkflowResponse.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 UpdateWorkflowFolder.
# @type request: :class:`Tencentcloud::wedata::V20250806::UpdateWorkflowFolderRequest`
# @rtype: :class:`Tencentcloud::wedata::V20250806::UpdateWorkflowFolderResponse`
def UpdateWorkflowFolder(request)
body = send_request('UpdateWorkflowFolder', request.serialize)
response = JSON.parse(body)
if response['Response'].key?('Error') == false
model = UpdateWorkflowFolderResponse.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
end
end
end
end
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/tencentcloud/tencentcloud-sdk-ruby.git
git@gitee.com:tencentcloud/tencentcloud-sdk-ruby.git
tencentcloud
tencentcloud-sdk-ruby
tencentcloud-sdk-ruby
master

搜索帮助