2 Star 23 Fork 2

tencentcloud/tencentcloud-sdk-python

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
wedata_client.py 67.13 KB
一键复制 编辑 原始数据 按行查看 历史
tencentcloud 提交于 2025-09-23 04:49 +08:00 . release 3.0.1464
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797
# -*- coding: utf8 -*-
# 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.
import json
from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException
from tencentcloud.common.abstract_client import AbstractClient
from tencentcloud.wedata.v20250806 import models
class WedataClient(AbstractClient):
_apiVersion = '2025-08-06'
_endpoint = 'wedata.tencentcloudapi.com'
_service = 'wedata'
def CreateCodeFile(self, request):
r"""新建代码文件
:param request: Request instance for CreateCodeFile.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateCodeFileRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateCodeFileResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateCodeFile", params, headers=headers)
response = json.loads(body)
model = models.CreateCodeFileResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateCodeFolder(self, request):
r"""新建代码文件夹
:param request: Request instance for CreateCodeFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateCodeFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateCodeFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateCodeFolder", params, headers=headers)
response = json.loads(body)
model = models.CreateCodeFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateDataBackfillPlan(self, request):
r"""创建数据补录计划
:param request: Request instance for CreateDataBackfillPlan.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateDataBackfillPlanRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateDataBackfillPlanResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateDataBackfillPlan", params, headers=headers)
response = json.loads(body)
model = models.CreateDataBackfillPlanResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateOpsAlarmRule(self, request):
r"""设置告警规则
:param request: Request instance for CreateOpsAlarmRule.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateOpsAlarmRuleRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateOpsAlarmRuleResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateOpsAlarmRule", params, headers=headers)
response = json.loads(body)
model = models.CreateOpsAlarmRuleResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateResourceFile(self, request):
r"""创建资源文件
:param request: Request instance for CreateResourceFile.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateResourceFileRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateResourceFileResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateResourceFile", params, headers=headers)
response = json.loads(body)
model = models.CreateResourceFileResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateResourceFolder(self, request):
r"""创建资源文件文件夹
:param request: Request instance for CreateResourceFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateResourceFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateResourceFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateResourceFolder", params, headers=headers)
response = json.loads(body)
model = models.CreateResourceFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateSQLFolder(self, request):
r"""创建数据探索脚本文件夹
:param request: Request instance for CreateSQLFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateSQLFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateSQLFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateSQLFolder", params, headers=headers)
response = json.loads(body)
model = models.CreateSQLFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateSQLScript(self, request):
r"""新增SQL脚本
:param request: Request instance for CreateSQLScript.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateSQLScriptRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateSQLScriptResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateSQLScript", params, headers=headers)
response = json.loads(body)
model = models.CreateSQLScriptResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateTask(self, request):
r"""创建任务接口
:param request: Request instance for CreateTask.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateTaskRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateTaskResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateTask", params, headers=headers)
response = json.loads(body)
model = models.CreateTaskResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateWorkflow(self, request):
r"""创建工作流
:param request: Request instance for CreateWorkflow.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateWorkflowRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateWorkflowResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateWorkflow", params, headers=headers)
response = json.loads(body)
model = models.CreateWorkflowResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def CreateWorkflowFolder(self, request):
r"""创建文件夹
:param request: Request instance for CreateWorkflowFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.CreateWorkflowFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.CreateWorkflowFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("CreateWorkflowFolder", params, headers=headers)
response = json.loads(body)
model = models.CreateWorkflowFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteCodeFile(self, request):
r"""删除代码文件
:param request: Request instance for DeleteCodeFile.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteCodeFileRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteCodeFileResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteCodeFile", params, headers=headers)
response = json.loads(body)
model = models.DeleteCodeFileResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteCodeFolder(self, request):
r"""数据探索删除文件夹
:param request: Request instance for DeleteCodeFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteCodeFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteCodeFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteCodeFolder", params, headers=headers)
response = json.loads(body)
model = models.DeleteCodeFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteOpsAlarmRule(self, request):
r"""删除告警规则
:param request: Request instance for DeleteOpsAlarmRule.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteOpsAlarmRuleRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteOpsAlarmRuleResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteOpsAlarmRule", params, headers=headers)
response = json.loads(body)
model = models.DeleteOpsAlarmRuleResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteResourceFile(self, request):
r"""资源管理-删除资源文件
:param request: Request instance for DeleteResourceFile.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteResourceFileRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteResourceFileResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteResourceFile", params, headers=headers)
response = json.loads(body)
model = models.DeleteResourceFileResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteResourceFolder(self, request):
r"""删除资源文件文件夹
:param request: Request instance for DeleteResourceFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteResourceFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteResourceFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteResourceFolder", params, headers=headers)
response = json.loads(body)
model = models.DeleteResourceFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteSQLFolder(self, request):
r"""删除SQL文件夹
:param request: Request instance for DeleteSQLFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteSQLFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteSQLFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteSQLFolder", params, headers=headers)
response = json.loads(body)
model = models.DeleteSQLFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteSQLScript(self, request):
r"""删除探索脚本
:param request: Request instance for DeleteSQLScript.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteSQLScriptRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteSQLScriptResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteSQLScript", params, headers=headers)
response = json.loads(body)
model = models.DeleteSQLScriptResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteTask(self, request):
r"""删除编排空间任务
:param request: Request instance for DeleteTask.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteTaskRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteTaskResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteTask", params, headers=headers)
response = json.loads(body)
model = models.DeleteTaskResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteWorkflow(self, request):
r"""删除工作流
:param request: Request instance for DeleteWorkflow.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteWorkflowRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteWorkflowResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteWorkflow", params, headers=headers)
response = json.loads(body)
model = models.DeleteWorkflowResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def DeleteWorkflowFolder(self, request):
r"""删除数据开发文件夹
:param request: Request instance for DeleteWorkflowFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.DeleteWorkflowFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.DeleteWorkflowFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("DeleteWorkflowFolder", params, headers=headers)
response = json.loads(body)
model = models.DeleteWorkflowFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetAlarmMessage(self, request):
r"""查询告警信息详情
:param request: Request instance for GetAlarmMessage.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetAlarmMessageRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetAlarmMessageResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetAlarmMessage", params, headers=headers)
response = json.loads(body)
model = models.GetAlarmMessageResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetCodeFile(self, request):
r"""查看代码文件详情
:param request: Request instance for GetCodeFile.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetCodeFileRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetCodeFileResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetCodeFile", params, headers=headers)
response = json.loads(body)
model = models.GetCodeFileResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetOpsAlarmRule(self, request):
r"""根据告警规则id/名称查询单个告警规则信息
:param request: Request instance for GetOpsAlarmRule.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetOpsAlarmRuleRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetOpsAlarmRuleResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetOpsAlarmRule", params, headers=headers)
response = json.loads(body)
model = models.GetOpsAlarmRuleResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetOpsAsyncJob(self, request):
r"""查询运维中心异步操作详情
:param request: Request instance for GetOpsAsyncJob.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetOpsAsyncJobRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetOpsAsyncJobResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetOpsAsyncJob", params, headers=headers)
response = json.loads(body)
model = models.GetOpsAsyncJobResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetOpsTask(self, request):
r"""获取任务详情
:param request: Request instance for GetOpsTask.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetOpsTaskRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetOpsTaskResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetOpsTask", params, headers=headers)
response = json.loads(body)
model = models.GetOpsTaskResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetOpsTaskCode(self, request):
r"""获取任务代码
:param request: Request instance for GetOpsTaskCode.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetOpsTaskCodeRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetOpsTaskCodeResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetOpsTaskCode", params, headers=headers)
response = json.loads(body)
model = models.GetOpsTaskCodeResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetOpsWorkflow(self, request):
r"""根据工作流id,获取工作流调度详情。
:param request: Request instance for GetOpsWorkflow.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetOpsWorkflowRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetOpsWorkflowResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetOpsWorkflow", params, headers=headers)
response = json.loads(body)
model = models.GetOpsWorkflowResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetResourceFile(self, request):
r"""获取资源文件详情
:param request: Request instance for GetResourceFile.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetResourceFileRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetResourceFileResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetResourceFile", params, headers=headers)
response = json.loads(body)
model = models.GetResourceFileResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetSQLScript(self, request):
r"""查询脚本详情
:param request: Request instance for GetSQLScript.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetSQLScriptRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetSQLScriptResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetSQLScript", params, headers=headers)
response = json.loads(body)
model = models.GetSQLScriptResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetTask(self, request):
r"""创建任务接口
:param request: Request instance for GetTask.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetTaskRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetTaskResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetTask", params, headers=headers)
response = json.loads(body)
model = models.GetTaskResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetTaskCode(self, request):
r"""获取任务代码
:param request: Request instance for GetTaskCode.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetTaskCodeRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetTaskCodeResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetTaskCode", params, headers=headers)
response = json.loads(body)
model = models.GetTaskCodeResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetTaskInstance(self, request):
r"""调度实例详情
:param request: Request instance for GetTaskInstance.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetTaskInstanceRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetTaskInstanceResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetTaskInstance", params, headers=headers)
response = json.loads(body)
model = models.GetTaskInstanceResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetTaskInstanceLog(self, request):
r"""获取实例列表
:param request: Request instance for GetTaskInstanceLog.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetTaskInstanceLogRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetTaskInstanceLogResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetTaskInstanceLog", params, headers=headers)
response = json.loads(body)
model = models.GetTaskInstanceLogResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetTaskVersion(self, request):
r"""拉取任务版本列表
:param request: Request instance for GetTaskVersion.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetTaskVersionRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetTaskVersionResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetTaskVersion", params, headers=headers)
response = json.loads(body)
model = models.GetTaskVersionResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def GetWorkflow(self, request):
r"""获取工作流信息
:param request: Request instance for GetWorkflow.
:type request: :class:`tencentcloud.wedata.v20250806.models.GetWorkflowRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.GetWorkflowResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("GetWorkflow", params, headers=headers)
response = json.loads(body)
model = models.GetWorkflowResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def KillTaskInstancesAsync(self, request):
r"""实例批量终止操作-异步操作
:param request: Request instance for KillTaskInstancesAsync.
:type request: :class:`tencentcloud.wedata.v20250806.models.KillTaskInstancesAsyncRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.KillTaskInstancesAsyncResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("KillTaskInstancesAsync", params, headers=headers)
response = json.loads(body)
model = models.KillTaskInstancesAsyncResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListAlarmMessages(self, request):
r"""获取告警信息列表
:param request: Request instance for ListAlarmMessages.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListAlarmMessagesRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListAlarmMessagesResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListAlarmMessages", params, headers=headers)
response = json.loads(body)
model = models.ListAlarmMessagesResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListCodeFolderContents(self, request):
r"""获取文件夹内容
:param request: Request instance for ListCodeFolderContents.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListCodeFolderContentsRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListCodeFolderContentsResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListCodeFolderContents", params, headers=headers)
response = json.loads(body)
model = models.ListCodeFolderContentsResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListDataBackfillInstances(self, request):
r"""获取单次补录的所有实例详情
:param request: Request instance for ListDataBackfillInstances.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListDataBackfillInstancesRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListDataBackfillInstancesResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListDataBackfillInstances", params, headers=headers)
response = json.loads(body)
model = models.ListDataBackfillInstancesResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListDownstreamOpsTasks(self, request):
r"""获取任务直接下游详情
:param request: Request instance for ListDownstreamOpsTasks.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListDownstreamOpsTasksRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListDownstreamOpsTasksResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListDownstreamOpsTasks", params, headers=headers)
response = json.loads(body)
model = models.ListDownstreamOpsTasksResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListDownstreamTaskInstances(self, request):
r"""获取实例直接上游
:param request: Request instance for ListDownstreamTaskInstances.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListDownstreamTaskInstancesRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListDownstreamTaskInstancesResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListDownstreamTaskInstances", params, headers=headers)
response = json.loads(body)
model = models.ListDownstreamTaskInstancesResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListDownstreamTasks(self, request):
r"""获取任务直接下游详情
:param request: Request instance for ListDownstreamTasks.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListDownstreamTasksRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListDownstreamTasksResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListDownstreamTasks", params, headers=headers)
response = json.loads(body)
model = models.ListDownstreamTasksResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListOpsAlarmRules(self, request):
r"""查询告警规则列表
:param request: Request instance for ListOpsAlarmRules.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListOpsAlarmRulesRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListOpsAlarmRulesResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListOpsAlarmRules", params, headers=headers)
response = json.loads(body)
model = models.ListOpsAlarmRulesResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListOpsTasks(self, request):
r"""根据项目id获取任务列表
:param request: Request instance for ListOpsTasks.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListOpsTasksRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListOpsTasksResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListOpsTasks", params, headers=headers)
response = json.loads(body)
model = models.ListOpsTasksResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListOpsWorkflows(self, request):
r"""根据项目ID获取项目下工作流
:param request: Request instance for ListOpsWorkflows.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListOpsWorkflowsRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListOpsWorkflowsResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListOpsWorkflows", params, headers=headers)
response = json.loads(body)
model = models.ListOpsWorkflowsResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListResourceFiles(self, request):
r"""获取资源文件列表
:param request: Request instance for ListResourceFiles.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListResourceFilesRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListResourceFilesResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListResourceFiles", params, headers=headers)
response = json.loads(body)
model = models.ListResourceFilesResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListResourceFolders(self, request):
r"""查询资源文件文件夹列表
:param request: Request instance for ListResourceFolders.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListResourceFoldersRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListResourceFoldersResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListResourceFolders", params, headers=headers)
response = json.loads(body)
model = models.ListResourceFoldersResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListSQLFolderContents(self, request):
r"""查询数据探索文件夹树,包括文件夹下的脚本
:param request: Request instance for ListSQLFolderContents.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListSQLFolderContentsRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListSQLFolderContentsResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListSQLFolderContents", params, headers=headers)
response = json.loads(body)
model = models.ListSQLFolderContentsResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListSQLScriptRuns(self, request):
r"""查询SQL运行记录
:param request: Request instance for ListSQLScriptRuns.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListSQLScriptRunsRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListSQLScriptRunsResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListSQLScriptRuns", params, headers=headers)
response = json.loads(body)
model = models.ListSQLScriptRunsResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListTaskInstanceExecutions(self, request):
r"""调度实例详情
:param request: Request instance for ListTaskInstanceExecutions.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListTaskInstanceExecutionsRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListTaskInstanceExecutionsResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListTaskInstanceExecutions", params, headers=headers)
response = json.loads(body)
model = models.ListTaskInstanceExecutionsResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListTaskInstances(self, request):
r"""获取实例列表
:param request: Request instance for ListTaskInstances.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListTaskInstancesRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListTaskInstancesResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListTaskInstances", params, headers=headers)
response = json.loads(body)
model = models.ListTaskInstancesResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListTaskVersions(self, request):
r"""任务保存版本列表
:param request: Request instance for ListTaskVersions.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListTaskVersionsRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListTaskVersionsResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListTaskVersions", params, headers=headers)
response = json.loads(body)
model = models.ListTaskVersionsResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListTasks(self, request):
r"""查询任务分页信息
:param request: Request instance for ListTasks.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListTasksRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListTasksResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListTasks", params, headers=headers)
response = json.loads(body)
model = models.ListTasksResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListUpstreamOpsTasks(self, request):
r"""获取任务直接上游
:param request: Request instance for ListUpstreamOpsTasks.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListUpstreamOpsTasksRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListUpstreamOpsTasksResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListUpstreamOpsTasks", params, headers=headers)
response = json.loads(body)
model = models.ListUpstreamOpsTasksResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListUpstreamTaskInstances(self, request):
r"""获取实例直接上游
:param request: Request instance for ListUpstreamTaskInstances.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListUpstreamTaskInstancesRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListUpstreamTaskInstancesResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListUpstreamTaskInstances", params, headers=headers)
response = json.loads(body)
model = models.ListUpstreamTaskInstancesResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListUpstreamTasks(self, request):
r"""获取任务直接上游
:param request: Request instance for ListUpstreamTasks.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListUpstreamTasksRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListUpstreamTasksResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListUpstreamTasks", params, headers=headers)
response = json.loads(body)
model = models.ListUpstreamTasksResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListWorkflowFolders(self, request):
r"""查询文件夹列表
:param request: Request instance for ListWorkflowFolders.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListWorkflowFoldersRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListWorkflowFoldersResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListWorkflowFolders", params, headers=headers)
response = json.loads(body)
model = models.ListWorkflowFoldersResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def ListWorkflows(self, request):
r"""查询工作流列表
:param request: Request instance for ListWorkflows.
:type request: :class:`tencentcloud.wedata.v20250806.models.ListWorkflowsRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.ListWorkflowsResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("ListWorkflows", params, headers=headers)
response = json.loads(body)
model = models.ListWorkflowsResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def PauseOpsTasksAsync(self, request):
r"""异步批量暂停任务
:param request: Request instance for PauseOpsTasksAsync.
:type request: :class:`tencentcloud.wedata.v20250806.models.PauseOpsTasksAsyncRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.PauseOpsTasksAsyncResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("PauseOpsTasksAsync", params, headers=headers)
response = json.loads(body)
model = models.PauseOpsTasksAsyncResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def RerunTaskInstancesAsync(self, request):
r"""实例批量重跑-异步
:param request: Request instance for RerunTaskInstancesAsync.
:type request: :class:`tencentcloud.wedata.v20250806.models.RerunTaskInstancesAsyncRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.RerunTaskInstancesAsyncResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("RerunTaskInstancesAsync", params, headers=headers)
response = json.loads(body)
model = models.RerunTaskInstancesAsyncResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def RunSQLScript(self, request):
r"""运行SQL脚本
:param request: Request instance for RunSQLScript.
:type request: :class:`tencentcloud.wedata.v20250806.models.RunSQLScriptRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.RunSQLScriptResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("RunSQLScript", params, headers=headers)
response = json.loads(body)
model = models.RunSQLScriptResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def SetSuccessTaskInstancesAsync(self, request):
r"""实例批量置成功-异步
:param request: Request instance for SetSuccessTaskInstancesAsync.
:type request: :class:`tencentcloud.wedata.v20250806.models.SetSuccessTaskInstancesAsyncRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.SetSuccessTaskInstancesAsyncResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("SetSuccessTaskInstancesAsync", params, headers=headers)
response = json.loads(body)
model = models.SetSuccessTaskInstancesAsyncResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def StopOpsTasksAsync(self, request):
r"""异步批量下线任务
:param request: Request instance for StopOpsTasksAsync.
:type request: :class:`tencentcloud.wedata.v20250806.models.StopOpsTasksAsyncRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.StopOpsTasksAsyncResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("StopOpsTasksAsync", params, headers=headers)
response = json.loads(body)
model = models.StopOpsTasksAsyncResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def StopSQLScriptRun(self, request):
r"""停止运行SQL脚本
:param request: Request instance for StopSQLScriptRun.
:type request: :class:`tencentcloud.wedata.v20250806.models.StopSQLScriptRunRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.StopSQLScriptRunResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("StopSQLScriptRun", params, headers=headers)
response = json.loads(body)
model = models.StopSQLScriptRunResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def SubmitTask(self, request):
r"""提交任务。
:param request: Request instance for SubmitTask.
:type request: :class:`tencentcloud.wedata.v20250806.models.SubmitTaskRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.SubmitTaskResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("SubmitTask", params, headers=headers)
response = json.loads(body)
model = models.SubmitTaskResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateCodeFile(self, request):
r"""更新代码文件
:param request: Request instance for UpdateCodeFile.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateCodeFileRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateCodeFileResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateCodeFile", params, headers=headers)
response = json.loads(body)
model = models.UpdateCodeFileResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateCodeFolder(self, request):
r"""重命名代码文件夹
:param request: Request instance for UpdateCodeFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateCodeFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateCodeFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateCodeFolder", params, headers=headers)
response = json.loads(body)
model = models.UpdateCodeFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateOpsAlarmRule(self, request):
r"""修改告警规则
:param request: Request instance for UpdateOpsAlarmRule.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateOpsAlarmRuleRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateOpsAlarmRuleResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateOpsAlarmRule", params, headers=headers)
response = json.loads(body)
model = models.UpdateOpsAlarmRuleResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateOpsTasksOwner(self, request):
r"""修改任务负责人
:param request: Request instance for UpdateOpsTasksOwner.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateOpsTasksOwnerRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateOpsTasksOwnerResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateOpsTasksOwner", params, headers=headers)
response = json.loads(body)
model = models.UpdateOpsTasksOwnerResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateResourceFile(self, request):
r"""更新资源文件
:param request: Request instance for UpdateResourceFile.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateResourceFileRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateResourceFileResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateResourceFile", params, headers=headers)
response = json.loads(body)
model = models.UpdateResourceFileResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateResourceFolder(self, request):
r"""创建资源文件文件夹
:param request: Request instance for UpdateResourceFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateResourceFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateResourceFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateResourceFolder", params, headers=headers)
response = json.loads(body)
model = models.UpdateResourceFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateSQLFolder(self, request):
r"""重命名SQL文件夹
:param request: Request instance for UpdateSQLFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateSQLFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateSQLFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateSQLFolder", params, headers=headers)
response = json.loads(body)
model = models.UpdateSQLFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateSQLScript(self, request):
r"""保存探索脚本内容
:param request: Request instance for UpdateSQLScript.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateSQLScriptRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateSQLScriptResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateSQLScript", params, headers=headers)
response = json.loads(body)
model = models.UpdateSQLScriptResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateTask(self, request):
r"""创建任务接口
:param request: Request instance for UpdateTask.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateTaskRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateTaskResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateTask", params, headers=headers)
response = json.loads(body)
model = models.UpdateTaskResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateWorkflow(self, request):
r"""更新工作流(包括工作流基本信息与工作流参数)
:param request: Request instance for UpdateWorkflow.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateWorkflowRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateWorkflowResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateWorkflow", params, headers=headers)
response = json.loads(body)
model = models.UpdateWorkflowResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
def UpdateWorkflowFolder(self, request):
r"""创建文件夹
:param request: Request instance for UpdateWorkflowFolder.
:type request: :class:`tencentcloud.wedata.v20250806.models.UpdateWorkflowFolderRequest`
:rtype: :class:`tencentcloud.wedata.v20250806.models.UpdateWorkflowFolderResponse`
"""
try:
params = request._serialize()
headers = request.headers
body = self.call("UpdateWorkflowFolder", params, headers=headers)
response = json.loads(body)
model = models.UpdateWorkflowFolderResponse()
model._deserialize(response["Response"])
return model
except Exception as e:
if isinstance(e, TencentCloudSDKException):
raise
else:
raise TencentCloudSDKException(type(e).__name__, str(e))
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/tencentcloud/tencentcloud-sdk-python.git
git@gitee.com:tencentcloud/tencentcloud-sdk-python.git
tencentcloud
tencentcloud-sdk-python
tencentcloud-sdk-python
master

搜索帮助