4582 lines
178 KiB
Python
4582 lines
178 KiB
Python
# coding:utf-8
|
|
# Code generated by protoc-gen-volcengine-sdk
|
|
# source: VodService
|
|
# DO NOT EDIT!
|
|
from __future__ import print_function
|
|
from volcengine.Policy import *
|
|
from google.protobuf.json_format import *
|
|
from volcengine.vod.VodServiceConfig import VodServiceConfig
|
|
from retry import retry
|
|
from zlib import crc32
|
|
import os
|
|
import sys
|
|
import time
|
|
import datetime
|
|
import volcengine.vod
|
|
from volcengine.util.Util import Util
|
|
from volcengine.vod.helper.FileSectionReader import FileSectionReader
|
|
from volcengine.vod.models.request.request_vod_pb2 import *
|
|
from volcengine.vod.models.response.response_vod_pb2 import *
|
|
|
|
MinChunkSize = 1024 * 1024 * 20
|
|
LargeFileSize = 1024 * 1024 * 1024
|
|
|
|
|
|
#
|
|
# Generated from protobuf service <code>VodService</code>
|
|
#
|
|
class VodService(VodServiceConfig):
|
|
|
|
def get_private_drm_play_auth_token(self, request, expire):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
if expire > 0:
|
|
params['X-Expires'] = str(expire)
|
|
data = self.get_sign_url('GetPrivateDrmPlayAuth', params)
|
|
return data
|
|
except Exception as Argument:
|
|
raise Argument
|
|
|
|
def create_hls_drm_auth_token(self, auth_algorithm, expire_seconds):
|
|
try:
|
|
if expire_seconds == 0:
|
|
raise Exception("invalid expire")
|
|
deadline = int(time.mktime(datetime.datetime.now().timetuple())) + expire_seconds
|
|
deadTime = datetime.datetime.utcfromtimestamp(deadline).strftime("%Y%m%dT%H%M%SZ")
|
|
if sys.version_info[0] == 3:
|
|
kDate = Util.hmac_sha256(bytes(self.service_info.credentials.sk, encoding='utf-8'), deadTime)
|
|
else:
|
|
kDate = Util.hmac_sha256(bytes(self.service_info.credentials.sk.encode('utf-8')), deadTime)
|
|
kRegion = Util.hmac_sha256(kDate, self.service_info.credentials.region)
|
|
kService = Util.hmac_sha256(kRegion, 'vod')
|
|
kCredentials = Util.hmac_sha256(kService, 'request')
|
|
key = Util.to_hex(kCredentials)
|
|
signDataString = '&'.join([auth_algorithm, '2.0', str(deadline)])
|
|
if auth_algorithm == 'HMAC-SHA1':
|
|
if sys.version_info[0] == 3:
|
|
signBytes = Util.hmac_sha1(bytes(key, encoding='utf-8'), signDataString)
|
|
else:
|
|
signBytes = Util.hmac_sha1(bytes(key.encode('utf-8')), signDataString)
|
|
else:
|
|
raise Exception('invalid authAlgorithm')
|
|
sign = base64.b64encode(signBytes).decode('utf-8')
|
|
token = ':'.join([auth_algorithm, '2.0', str(deadline), self.service_info.credentials.ak, sign])
|
|
params = dict()
|
|
params['DrmAuthToken'] = token
|
|
params['X-Expires'] = str(expire_seconds)
|
|
getAuth = self.get_sign_url("GetHlsDecryptionKey", params)
|
|
return getAuth
|
|
except Exception as e:
|
|
raise e
|
|
|
|
def get_sha1_hls_drm_auth_token(self, expire_seconds):
|
|
try:
|
|
return self.create_hls_drm_auth_token('HMAC-SHA1', expire_seconds)
|
|
except Exception as Argument:
|
|
raise Argument
|
|
|
|
def get_play_auth_token(self, request, expire):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
if expire > 0:
|
|
params['X-Expires'] = str(expire)
|
|
token = self.get_sign_url('GetPlayInfo', params)
|
|
ret = {'TokenVersion': 'V2', 'GetPlayInfoToken': token}
|
|
data = json.dumps(ret)
|
|
except Exception as Argument:
|
|
raise Argument
|
|
else:
|
|
if sys.version_info[0] == 3:
|
|
return base64.b64encode(data.encode('utf-8')).decode('utf-8')
|
|
else:
|
|
return base64.b64encode(data.decode('utf-8'))
|
|
|
|
def get_subtitle_auth_token(self, request, expire):
|
|
try:
|
|
if request.Vid == "":
|
|
raise Exception("Vid is None")
|
|
params = {"Vid": request.Vid}
|
|
params["Status"] = "Published"
|
|
if expire > 0:
|
|
params['X-Expires'] = str(expire)
|
|
token = self.get_sign_url('GetSubtitleInfoList', params)
|
|
ret = {'GetSubtitleAuthToken': token}
|
|
data = json.dumps(ret)
|
|
except Exception as Argument:
|
|
raise Argument
|
|
else:
|
|
if sys.version_info[0] == 3:
|
|
return base64.b64encode(data.encode('utf-8')).decode('utf-8')
|
|
else:
|
|
return base64.b64encode(data.decode('utf-8'))
|
|
|
|
def upload_media(self, request):
|
|
oid, session_key, avg_speed = self.upload_tob(request.SpaceName, request.FilePath, "", request.FileName,
|
|
request.FileExtension, request.StorageClass, request.ClientNetWorkMode, request.ClientIDCMode, request.UploadHostPrefer, request.ChunkSize)
|
|
req = VodCommitUploadInfoRequest()
|
|
req.SpaceName = request.SpaceName
|
|
req.SessionKey = session_key
|
|
req.Functions = request.Functions
|
|
req.CallbackArgs = request.CallbackArgs
|
|
req.ExpireTime = request.ExpireTime
|
|
resp = self.commit_upload_info(req)
|
|
if resp.ResponseMetadata.Error.Code != '':
|
|
print(resp.ResponseMetadata.RequestId)
|
|
raise Exception(resp.ResponseMetadata.Error)
|
|
return resp
|
|
|
|
def upload_tob(self, space_name, file_path, file_type, file_name, file_extension, storage_class, client_network_mode, client_idc_mode, upload_host_prefer, chunk_size):
|
|
if not os.path.isfile(file_path):
|
|
raise Exception("no such file on file path")
|
|
if chunk_size < MinChunkSize:
|
|
chunk_size = MinChunkSize
|
|
file_size = os.path.getsize(file_path)
|
|
apply_req = VodApplyUploadInfoRequest()
|
|
apply_req.SpaceName = space_name
|
|
apply_req.FileSize = file_size
|
|
apply_req.FileType = file_type
|
|
apply_req.FileName = file_name
|
|
apply_req.FileExtension = file_extension
|
|
apply_req.StorageClass = storage_class
|
|
apply_req.ClientNetWorkMode = client_network_mode
|
|
apply_req.ClientIDCMode = client_idc_mode
|
|
apply_req.NeedFallback = True
|
|
apply_req.UploadHostPrefer = upload_host_prefer
|
|
resp = self.apply_upload_info(apply_req)
|
|
if resp.ResponseMetadata.Error.Code != '':
|
|
print(resp.ResponseMetadata.RequestId)
|
|
raise Exception(resp.ResponseMetadata.Error)
|
|
|
|
vpc_upload_address = resp.Result.Data.VpcTosUploadAddress
|
|
if vpc_upload_address:
|
|
upload_address = resp.Result.Data.UploadAddress
|
|
oid = upload_address.StoreInfos[0].StoreUri
|
|
session_key = upload_address.SessionKey
|
|
|
|
start = time.time()
|
|
if vpc_upload_address.UploadMode != "":
|
|
self.vpc_upload(vpc_upload_address, file_path, file_size)
|
|
cost = (time.time() - start) * 1000
|
|
avg_speed = float(file_size) / float(cost)
|
|
return oid, session_key, avg_speed
|
|
|
|
# using candidate address first
|
|
candidate_upload_address = resp.Result.Data.CandidateUploadAddresses
|
|
all_upload_address = []
|
|
if candidate_upload_address:
|
|
all_upload_address.extend(candidate_upload_address.MainUploadAddresses)
|
|
all_upload_address.extend(candidate_upload_address.BackupUploadAddresses)
|
|
all_upload_address.extend(candidate_upload_address.FallbackUploadAddresses)
|
|
|
|
if len(all_upload_address) > 0:
|
|
file_size = os.path.getsize(file_path)
|
|
for i, upload_address in enumerate(all_upload_address):
|
|
if len(upload_address.UploadHosts) == 0 or len(upload_address.StoreInfos) == 0 or not \
|
|
upload_address.StoreInfos[0]:
|
|
continue
|
|
tos_host = upload_address.UploadHosts[0]
|
|
oid = upload_address.StoreInfos[0].StoreUri
|
|
session_key = upload_address.SessionKey
|
|
auth = upload_address.StoreInfos[0].Auth
|
|
start = time.time()
|
|
try:
|
|
if file_size < chunk_size:
|
|
self.direct_upload(tos_host, oid, auth, file_path, storage_class)
|
|
else:
|
|
self.chunk_upload(file_path, tos_host, oid, auth, file_size, True, storage_class, chunk_size)
|
|
except Exception as e:
|
|
print("upload failed, switch host to retry.. reason: {}".format(e))
|
|
continue
|
|
else:
|
|
cost = (time.time() - start) * 1000
|
|
avg_speed = float(file_size) / float(cost)
|
|
return oid, session_key, avg_speed
|
|
raise Exception("upload failed")
|
|
else:
|
|
upload_address = resp.Result.Data.UploadAddress
|
|
oid = upload_address.StoreInfos[0].StoreUri
|
|
session_key = upload_address.SessionKey
|
|
auth = upload_address.StoreInfos[0].Auth
|
|
host = upload_address.UploadHosts[0]
|
|
start = time.time()
|
|
file_size = os.path.getsize(file_path)
|
|
if file_size < chunk_size:
|
|
self.direct_upload(host, oid, auth, file_path, storage_class)
|
|
else:
|
|
self.chunk_upload(file_path, host, oid, auth, file_size, True, storage_class, chunk_size)
|
|
cost = (time.time() - start) * 1000
|
|
file_size = os.path.getsize(file_path)
|
|
avg_speed = float(file_size) / float(cost)
|
|
return oid, session_key, avg_speed
|
|
|
|
def vpc_upload(self, vpc_upload_address, file_path, file_size):
|
|
if vpc_upload_address.QuickCompleteMode == "enable":
|
|
return
|
|
|
|
if vpc_upload_address.UploadMode == "direct":
|
|
self.vpc_put(vpc_upload_address, file_path)
|
|
elif vpc_upload_address.UploadMode == "part":
|
|
self.vpc_part_upload(vpc_upload_address.PartUploadInfo, file_path, file_size)
|
|
|
|
def vpc_put(self, vpc_upload_address, file_path):
|
|
put_url = vpc_upload_address.PutUrl
|
|
put_headers = vpc_upload_address.PutUrlHeaders
|
|
with open(file_path, 'rb') as f:
|
|
resp = self.session.put(put_url, headers=put_headers, data=f)
|
|
if resp.status_code != 200:
|
|
log_id = resp.headers.get("x-tos-request-id", "")
|
|
raise Exception("vpc put error, logId: {}".format(log_id))
|
|
|
|
def vpc_part_put(self, put_url, content):
|
|
resp = self.session.put(put_url, data=content)
|
|
if resp.status_code != 200:
|
|
log_id = resp.headers.get("x-tos-request-id", "")
|
|
raise Exception("vpc part put error, logId: {}".format(log_id))
|
|
|
|
etag = resp.headers.get("ETag", "")
|
|
return etag
|
|
|
|
def vpc_post(self, post_url, data, headers):
|
|
resp = self.session.post(post_url, data=data, headers=headers)
|
|
if resp.status_code != 200:
|
|
log_id = resp.headers.get("x-tos-request-id", "")
|
|
raise Exception("vpc post error, logId: {}".format(log_id))
|
|
|
|
def vpc_part_upload(self, part_upload_info, file_path, file_size):
|
|
chunk_size = part_upload_info.PartSize
|
|
total_num = file_size // chunk_size
|
|
if file_size % chunk_size == 0:
|
|
total_num -= 1
|
|
if len(part_upload_info.PartPutUrls) != total_num + 1:
|
|
raise Exception("mismatch part upload")
|
|
|
|
offset = 0
|
|
etag_list = []
|
|
with open(file_path, 'rb') as f:
|
|
for i in range(0, total_num):
|
|
put_url = part_upload_info.PartPutUrls[i]
|
|
sr = FileSectionReader(f, chunk_size, init_offset=offset, can_reset=True)
|
|
etag = self.vpc_part_put(put_url, sr)
|
|
etag_list.append(etag)
|
|
offset += chunk_size
|
|
|
|
last_chunk_size = file_size - offset
|
|
put_url = part_upload_info.PartPutUrls[total_num]
|
|
sr = FileSectionReader(f, last_chunk_size, init_offset=offset, can_reset=True)
|
|
etag = self.vpc_part_put(put_url, sr)
|
|
etag_list.append(etag)
|
|
|
|
post_data = self.vpc_generate_body(etag_list)
|
|
self.vpc_post(part_upload_info.CompletePartUrl, post_data, part_upload_info.CompleteUrlHeaders)
|
|
|
|
def vpc_generate_body(self, etag_list):
|
|
if len(etag_list) == 0:
|
|
raise Exception('etag list empty')
|
|
s = []
|
|
for i in range(len(etag_list)):
|
|
s.append("{" + '"PartNumber": {}, "ETag": {}'.format(i + 1, etag_list[i]) + "}")
|
|
comma = ','
|
|
|
|
return '{"Parts":[' + comma.join(s) + ']}'
|
|
|
|
@retry(tries=3, delay=1, backoff=2)
|
|
def direct_upload(self, host, oid, auth, file_path, storage_class):
|
|
with open(file_path, 'rb') as f:
|
|
data = f.read()
|
|
check_sum = crc32(data) & 0xFFFFFFFF
|
|
check_sum = "%08x" % check_sum
|
|
url = 'https://{}/{}'.format(host, oid)
|
|
headers = {'Content-CRC32': check_sum, 'Authorization': auth}
|
|
|
|
if storage_class == volcengine.vod.models.business.vod_upload_pb2.Archive:
|
|
headers['X-Upload-Storage-Class'] = 'archive'
|
|
if storage_class == volcengine.vod.models.business.vod_upload_pb2.IA:
|
|
headers['X-Upload-Storage-Class'] = 'ia'
|
|
|
|
upload_status, resp = self.put(url, file_path, headers)
|
|
resp_text = str(resp, encoding='utf8')
|
|
if not upload_status:
|
|
raise Exception("direct upload error: {}, logid: {}".format(resp_text, headers["X-Tt-Logid"]))
|
|
resp = json.loads(resp)
|
|
if resp.get('success') is None or resp['success'] != 0:
|
|
raise Exception("direct upload error: {}, logid: {}".format(resp_text, headers["X-Tt-Logid"]))
|
|
|
|
def chunk_upload(self, file_path, host, oid, auth, size, is_large_file, storage_class, chunk_size):
|
|
upload_id = self.init_upload_part(host, oid, auth, is_large_file, storage_class)
|
|
n = size // chunk_size
|
|
last_num = n - 1
|
|
parts = []
|
|
meta = {}
|
|
with open(file_path, 'rb') as f:
|
|
for i in range(0, last_num):
|
|
data = f.read(chunk_size)
|
|
part_number = i
|
|
if is_large_file:
|
|
part_number = i + 1
|
|
part, payload = self.upload_part(host, oid, auth, upload_id, part_number, data, is_large_file,
|
|
storage_class)
|
|
if part_number == 1:
|
|
meta = payload['meta']
|
|
parts.append(part)
|
|
data = f.read()
|
|
if is_large_file:
|
|
last_num = last_num + 1
|
|
part, payload = self.upload_part(host, oid, auth, upload_id, last_num, data, is_large_file, storage_class)
|
|
if last_num == 1:
|
|
meta = payload["meta"]
|
|
parts.append(part)
|
|
return self.upload_merge_part(host, oid, auth, upload_id, parts, is_large_file, storage_class, meta)
|
|
|
|
@retry(tries=3, delay=1, backoff=2)
|
|
def init_upload_part(self, host, oid, auth, is_large_file, storage_class):
|
|
url = 'https://{}/{}?uploads'.format(host, oid)
|
|
headers = {'Authorization': auth}
|
|
if is_large_file:
|
|
headers['X-Storage-Mode'] = 'gateway'
|
|
|
|
if storage_class == volcengine.vod.models.business.vod_upload_pb2.Archive:
|
|
headers['X-Upload-Storage-Class'] = 'archive'
|
|
if storage_class == volcengine.vod.models.business.vod_upload_pb2.IA:
|
|
headers['X-Upload-Storage-Class'] = 'ia'
|
|
|
|
upload_status, resp = self.put_data(url, None, headers)
|
|
resp_text = str(resp, encoding='utf8')
|
|
if not upload_status:
|
|
raise Exception("init upload error: {}, logid: {}".format(resp_text, headers["X-Tt-Logid"]))
|
|
resp = json.loads(resp)
|
|
if resp.get('success') is None or resp['success'] != 0:
|
|
raise Exception("init upload error: {}, logid: {}".format(resp_text, headers["X-Tt-Logid"]))
|
|
return resp['payload']['uploadID']
|
|
|
|
@retry(tries=3, delay=1, backoff=2)
|
|
def upload_part(self, host, oid, auth, upload_id, part_number, data, is_large_file, storage_class):
|
|
url = 'https://{}/{}?partNumber={}&uploadID={}'.format(host, oid,
|
|
part_number, upload_id)
|
|
check_sum = crc32(data) & 0xFFFFFFFF
|
|
check_sum = "%08x" % check_sum
|
|
headers = {'Content-CRC32': check_sum, 'Authorization': auth}
|
|
if is_large_file:
|
|
headers['X-Storage-Mode'] = 'gateway'
|
|
|
|
if storage_class == volcengine.vod.models.business.vod_upload_pb2.Archive:
|
|
headers['X-Upload-Storage-Class'] = 'archive'
|
|
if storage_class == volcengine.vod.models.business.vod_upload_pb2.IA:
|
|
headers['X-Upload-Storage-Class'] = 'ia'
|
|
|
|
upload_status, resp = self.put_data(url, data, headers)
|
|
resp_text = str(resp, encoding='utf8')
|
|
if not upload_status:
|
|
raise Exception("upload part error: {}, logid: {}".format(resp_text, headers["X-Tt-Logid"]))
|
|
resp = json.loads(resp)
|
|
if resp.get('success') is None or resp['success'] != 0:
|
|
raise Exception("upload part error: {}, logid: {}".format(resp_text, headers["X-Tt-Logid"]))
|
|
return check_sum, resp['payload']
|
|
|
|
@staticmethod
|
|
def generate_merge_body(check_sum_list):
|
|
if len(check_sum_list) == 0:
|
|
raise Exception('crc32 list empty')
|
|
s = []
|
|
for i in range(len(check_sum_list)):
|
|
s.append('{}:{}'.format(i, check_sum_list[i]))
|
|
comma = ','
|
|
return comma.join(s)
|
|
|
|
@retry(tries=3, delay=1, backoff=2)
|
|
def upload_merge_part(self, host, oid, auth, upload_id, check_sum_list, is_large_file, storage_class, meta):
|
|
object_content_type = ''
|
|
if (meta is not None) and (meta.get("ObjectContentType") is not None):
|
|
object_content_type = meta['ObjectContentType']
|
|
url = 'https://{}/{}?uploadID={}&ObjectContentType={}'.format(host, oid, upload_id, object_content_type)
|
|
data = self.generate_merge_body(check_sum_list)
|
|
headers = {'Authorization': auth}
|
|
if is_large_file:
|
|
headers['X-Storage-Mode'] = 'gateway'
|
|
|
|
if storage_class == volcengine.vod.models.business.vod_upload_pb2.Archive:
|
|
headers['X-Upload-Storage-Class'] = 'archive'
|
|
if storage_class == volcengine.vod.models.business.vod_upload_pb2.IA:
|
|
headers['X-Upload-Storage-Class'] = 'ia'
|
|
|
|
upload_status, resp = self.put_data(url, data, headers)
|
|
resp_text = str(resp, encoding='utf8')
|
|
if not upload_status:
|
|
raise Exception("commit upload part error: {}, logid: {}".format(resp_text, headers["X-Tt-Logid"]))
|
|
resp = json.loads(resp)
|
|
if resp.get('success') is None or resp['success'] != 0:
|
|
raise Exception("commit upload part error: {}, logid: {}".format(resp_text, headers["X-Tt-Logid"]))
|
|
|
|
def get_upload_sts2_with_expired_time(self, expired_time):
|
|
actions = ["vod:ApplyUploadInfo", "vod:CommitUploadInfo"]
|
|
resources = []
|
|
statement = Statement.new_allow_statement(actions, resources)
|
|
inline_policy = Policy([statement])
|
|
return self.sign_sts2(inline_policy, expired_time)
|
|
|
|
def get_upload_sts2(self):
|
|
return self.get_upload_sts2_with_expired_time(60 * 60)
|
|
|
|
def upload_material(self, request):
|
|
oid, session_key, avg_speed = self.upload_tob(request.SpaceName, request.FilePath, request.FileType,
|
|
request.FileName, request.FileExtension, 0, request.ClientNetWorkMode, request.ClientIDCMode, request.UploadHostPrefer, request.ChunkSize)
|
|
|
|
req = VodCommitUploadInfoRequest()
|
|
req.SpaceName = request.SpaceName
|
|
req.SessionKey = session_key
|
|
req.Functions = request.Functions
|
|
req.CallbackArgs = request.CallbackArgs
|
|
|
|
resp = self.commit_upload_info(req)
|
|
if resp.ResponseMetadata.Error.Code != '':
|
|
print(resp.ResponseMetadata.RequestId)
|
|
raise Exception(resp.ResponseMetadata.Error)
|
|
return resp
|
|
|
|
#
|
|
# SubmitDirectEditTaskAsync.
|
|
#
|
|
# @param request VodSubmitDirectEditTaskAsyncRequest
|
|
# @return VodSubmitDirectEditTaskAsyncResponse
|
|
# @raise Exception
|
|
def submit_direct_edit_task_async(self, request):
|
|
|
|
try:
|
|
params = MessageToDict(request, False, True)
|
|
params['EditParam'] = json.loads(request.EditParam)
|
|
res = self.json("SubmitDirectEditTaskAsync", {}, json.dumps(params))
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodSubmitDirectEditTaskAsyncResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return res
|
|
|
|
#
|
|
# SubmitDirectEditTaskSync.
|
|
#
|
|
# @param request VodSubmitDirectEditTaskSyncRequest
|
|
# @return VodSubmitDirectEditTaskSyncResponse
|
|
# @raise Exception
|
|
def submit_direct_edit_task_sync(self, request):
|
|
|
|
try:
|
|
params = MessageToDict(request, False, True)
|
|
params['EditParam'] = json.loads(request.EditParam)
|
|
res = self.json("SubmitDirectEditTaskSync", {}, json.dumps(params))
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodSubmitDirectEditTaskSyncResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return res
|
|
|
|
#
|
|
# GetDirectEditResult.
|
|
#
|
|
# @param request VodGetDirectEditResultRequest
|
|
# @return VodGetDirectEditResultResponse
|
|
# @raise Exception
|
|
def get_direct_edit_result(self, request):
|
|
try:
|
|
jsonData = MessageToJson(request, False, True)
|
|
res = self.json("GetDirectEditResult", {}, jsonData)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetDirectEditResultResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
|
|
return res
|
|
|
|
#
|
|
# GetDirectEditProgress.
|
|
#
|
|
# @param request VodGetDirectEditProgressRequest
|
|
# @return VodGetDirectEditProgressResponse
|
|
# @raise Exception
|
|
def get_direct_edit_progress(self, request):
|
|
|
|
try:
|
|
params = MessageToDict(request, False, True)
|
|
if sys.version_info[0] == 3:
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetDirectEditProgress", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetDirectEditProgressResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return res
|
|
|
|
#
|
|
# CancelDirectEditTask.
|
|
#
|
|
# @param request VodCancelDirectEditTaskRequest
|
|
# @return VodCancelDirectEditTaskResponse
|
|
# @raise Exception
|
|
def cancel_direct_edit_task(self, request):
|
|
try:
|
|
jsonData = MessageToJson(request, False, True)
|
|
res = self.json("CancelDirectEditTask", {}, jsonData)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCancelDirectEditTaskResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error)
|
|
else:
|
|
return res
|
|
|
|
|
|
#
|
|
# GetAllPlayInfo.
|
|
#
|
|
# @param request VodGetAllPlayInfoRequest
|
|
# @return VodGetAllPlayInfoResponse
|
|
# @raise Exception
|
|
def get_all_play_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetAllPlayInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetAllPlayInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetAllPlayInfoResponse(), True)
|
|
|
|
#
|
|
# GetPlayInfo.
|
|
#
|
|
# @param request VodGetPlayInfoRequest
|
|
# @return VodGetPlayInfoResponse
|
|
# @raise Exception
|
|
def get_play_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetPlayInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetPlayInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetPlayInfoResponse(), True)
|
|
|
|
#
|
|
# GetPrivateDrmPlayAuth.
|
|
#
|
|
# @param request VodGetPrivateDrmPlayAuthRequest
|
|
# @return VodGetPrivateDrmPlayAuthResponse
|
|
# @raise Exception
|
|
def get_private_drm_play_auth(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetPrivateDrmPlayAuth", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetPrivateDrmPlayAuthResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetPrivateDrmPlayAuthResponse(), True)
|
|
|
|
#
|
|
# GetHlsDecryptionKey.
|
|
#
|
|
# @param request VodGetHlsDecryptionKeyRequest
|
|
# @return VodGetHlsDecryptionKeyResponse
|
|
# @raise Exception
|
|
def get_hls_decryption_key(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetHlsDecryptionKey", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetHlsDecryptionKeyResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetHlsDecryptionKeyResponse(), True)
|
|
|
|
#
|
|
# CreateHlsDecryptionKey.
|
|
#
|
|
# @param request VodCreateHlsDecryptionKeyRequest
|
|
# @return VodCreateHlsDecryptionKeyResponse
|
|
# @raise Exception
|
|
def create_hls_decryption_key(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("CreateHlsDecryptionKey", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCreateHlsDecryptionKeyResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCreateHlsDecryptionKeyResponse(), True)
|
|
|
|
#
|
|
# GetPlayInfoWithLiveTimeShiftScene.
|
|
#
|
|
# @param request VodGetPlayInfoWithLiveTimeShiftSceneRequest
|
|
# @return VodGetPlayInfoWithLiveTimeShiftSceneResponse
|
|
# @raise Exception
|
|
def get_play_info_with_live_time_shift_scene(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetPlayInfoWithLiveTimeShiftScene", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetPlayInfoWithLiveTimeShiftSceneResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetPlayInfoWithLiveTimeShiftSceneResponse(), True)
|
|
|
|
#
|
|
# SubmitBlockObjectTasks.
|
|
#
|
|
# @param request VodSubmitBlockObjectTasksRequest
|
|
# @return VodSubmitBlockObjectTasksResponse
|
|
# @raise Exception
|
|
def submit_block_object_tasks(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("SubmitBlockObjectTasks",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodSubmitBlockObjectTasksResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodSubmitBlockObjectTasksResponse(), True)
|
|
|
|
|
|
#
|
|
# ListBlockObjectTasks.
|
|
#
|
|
# @param request VodListBlockObjectTasksRequest
|
|
# @return VodListBlockObjectTasksResponse
|
|
# @raise Exception
|
|
def list_block_object_tasks(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("ListBlockObjectTasks",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListBlockObjectTasksResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListBlockObjectTasksResponse(), True)
|
|
|
|
|
|
#
|
|
# UploadMediaByUrl.
|
|
#
|
|
# @param request VodUrlUploadRequest
|
|
# @return VodUrlUploadResponse
|
|
# @raise Exception
|
|
def upload_media_by_url(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UploadMediaByUrl", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUrlUploadResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUrlUploadResponse(), True)
|
|
|
|
#
|
|
# QueryUploadTaskInfo.
|
|
#
|
|
# @param request VodQueryUploadTaskInfoRequest
|
|
# @return VodQueryUploadTaskInfoResponse
|
|
# @raise Exception
|
|
def query_upload_task_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("QueryUploadTaskInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodQueryUploadTaskInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodQueryUploadTaskInfoResponse(), True)
|
|
|
|
#
|
|
# ApplyUploadInfo.
|
|
#
|
|
# @param request VodApplyUploadInfoRequest
|
|
# @return VodApplyUploadInfoResponse
|
|
# @raise Exception
|
|
def apply_upload_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ApplyUploadInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodApplyUploadInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodApplyUploadInfoResponse(), True)
|
|
|
|
#
|
|
# CommitUploadInfo.
|
|
#
|
|
# @param request VodCommitUploadInfoRequest
|
|
# @return VodCommitUploadInfoResponse
|
|
# @raise Exception
|
|
def commit_upload_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("CommitUploadInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCommitUploadInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCommitUploadInfoResponse(), True)
|
|
|
|
#
|
|
# ListFileMetaInfosByFileNames.
|
|
#
|
|
# @param request VodListFileMetaInfosByFileNamesRequest
|
|
# @return VodListFileMetaInfosByFileNamesResponse
|
|
# @raise Exception
|
|
def list_file_meta_infos_by_file_names(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("ListFileMetaInfosByFileNames",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListFileMetaInfosByFileNamesResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListFileMetaInfosByFileNamesResponse(), True)
|
|
|
|
|
|
#
|
|
# UpdateMediaInfo.
|
|
#
|
|
# @param request VodUpdateMediaInfoRequest
|
|
# @return VodUpdateMediaInfoResponse
|
|
# @raise Exception
|
|
def update_media_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateMediaInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateMediaInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateMediaInfoResponse(), True)
|
|
|
|
#
|
|
# UpdateMediaPublishStatus.
|
|
#
|
|
# @param request VodUpdateMediaPublishStatusRequest
|
|
# @return VodUpdateMediaPublishStatusResponse
|
|
# @raise Exception
|
|
def update_media_publish_status(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateMediaPublishStatus", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateMediaPublishStatusResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateMediaPublishStatusResponse(), True)
|
|
|
|
#
|
|
# UpdateMediaStorageClass.
|
|
#
|
|
# @param request VodUpdateMediaStorageClassRequest
|
|
# @return VodUpdateMediaStorageClassResponse
|
|
# @raise Exception
|
|
def update_media_storage_class(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateMediaStorageClass", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateMediaStorageClassResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateMediaStorageClassResponse(), True)
|
|
|
|
#
|
|
# GetMediaInfos.
|
|
#
|
|
# @param request VodGetMediaInfosRequest
|
|
# @return VodGetMediaInfosResponse
|
|
# @raise Exception
|
|
def get_media_infos(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetMediaInfos", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetMediaInfosResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetMediaInfosResponse(), True)
|
|
|
|
#
|
|
# GetMediaInfos20230701.
|
|
#
|
|
# @param request VodGetMediaInfosRequest
|
|
# @return VodGetMediaInfosResponse
|
|
# @raise Exception
|
|
def get_media_infos20230701(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetMediaInfos20230701", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetMediaInfosResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetMediaInfosResponse(), True)
|
|
|
|
#
|
|
# GetRecommendedPoster.
|
|
#
|
|
# @param request VodGetRecommendedPosterRequest
|
|
# @return VodGetRecommendedPosterResponse
|
|
# @raise Exception
|
|
def get_recommended_poster(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetRecommendedPoster", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetRecommendedPosterResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetRecommendedPosterResponse(), True)
|
|
|
|
#
|
|
# DeleteMedia.
|
|
#
|
|
# @param request VodDeleteMediaRequest
|
|
# @return VodDeleteMediaResponse
|
|
# @raise Exception
|
|
def delete_media(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DeleteMedia", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteMediaResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteMediaResponse(), True)
|
|
|
|
#
|
|
# DeleteTranscodes.
|
|
#
|
|
# @param request VodDeleteTranscodesRequest
|
|
# @return VodDeleteTranscodesResponse
|
|
# @raise Exception
|
|
def delete_transcodes(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DeleteTranscodes", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteTranscodesResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteTranscodesResponse(), True)
|
|
|
|
#
|
|
# GetFileInfos.
|
|
#
|
|
# @param request VodGetFileInfosRequest
|
|
# @return VodGetFileInfosResponse
|
|
# @raise Exception
|
|
def get_file_infos(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetFileInfos", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetFileInfosResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetFileInfosResponse(), True)
|
|
|
|
#
|
|
# UpdateFileStorageClass.
|
|
#
|
|
# @param request VodUpdateFileStorageClassRequest
|
|
# @return VodUpdateFileStorageClassResponse
|
|
# @raise Exception
|
|
def update_file_storage_class(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("UpdateFileStorageClass",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateFileStorageClassResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateFileStorageClassResponse(), True)
|
|
|
|
|
|
#
|
|
# GetInnerAuditURLs.
|
|
#
|
|
# @param request VodGetInnerAuditURLsRequest
|
|
# @return VodGetInnerAuditURLsResponse
|
|
# @raise Exception
|
|
def get_inner_audit_u_r_ls(self, request):
|
|
try:
|
|
jsonData = MessageToJson(request, False, True)
|
|
res = self.json("GetInnerAuditURLs",{},jsonData)
|
|
except Exception as Argument:
|
|
try:
|
|
ArgumentStr = Argument.args[0].decode("utf-8")
|
|
resp = Parse(ArgumentStr, VodGetInnerAuditURLsResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetInnerAuditURLsResponse(), True)
|
|
|
|
|
|
#
|
|
# GetAdAuditResultByVid.
|
|
#
|
|
# @param request VodGetAdAuditResultByVidRequest
|
|
# @return VodGetAdAuditResultByVidResponse
|
|
# @raise Exception
|
|
def get_ad_audit_result_by_vid(self, request):
|
|
try:
|
|
jsonData = MessageToJson(request, False, True)
|
|
res = self.json("GetAdAuditResultByVid",{},jsonData)
|
|
except Exception as Argument:
|
|
try:
|
|
ArgumentStr = Argument.args[0].decode("utf-8")
|
|
resp = Parse(ArgumentStr, VodGetAdAuditResultByVidResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetAdAuditResultByVidResponse(), True)
|
|
|
|
|
|
#
|
|
# DeleteMediaTosFile.
|
|
#
|
|
# @param request VodDeleteMediaTosFileRequest
|
|
# @return VodDeleteMediaTosFileResponse
|
|
# @raise Exception
|
|
def delete_media_tos_file(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("DeleteMediaTosFile",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteMediaTosFileResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteMediaTosFileResponse(), True)
|
|
|
|
|
|
#
|
|
# GetMediaList.
|
|
#
|
|
# @param request VodGetMediaListRequest
|
|
# @return VodGetMediaListResponse
|
|
# @raise Exception
|
|
def get_media_list(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetMediaList", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetMediaListResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetMediaListResponse(), True)
|
|
|
|
#
|
|
# DeleteMaterial.
|
|
#
|
|
# @param request VodDeleteMaterialRequest
|
|
# @return VodDeleteMaterialResponse
|
|
# @raise Exception
|
|
def delete_material(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DeleteMaterial", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteMaterialResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteMaterialResponse(), True)
|
|
|
|
#
|
|
# GetSubtitleInfoList.
|
|
#
|
|
# @param request VodGetSubtitleInfoListRequest
|
|
# @return VodGetSubtitleInfoListResponse
|
|
# @raise Exception
|
|
def get_subtitle_info_list(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetSubtitleInfoList", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetSubtitleInfoListResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetSubtitleInfoListResponse(), True)
|
|
|
|
#
|
|
# UpdateSubtitleStatus.
|
|
#
|
|
# @param request VodUpdateSubtitleStatusRequest
|
|
# @return VodUpdateSubtitleStatusResponse
|
|
# @raise Exception
|
|
def update_subtitle_status(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateSubtitleStatus", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateSubtitleStatusResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateSubtitleStatusResponse(), True)
|
|
|
|
#
|
|
# UpdateSubtitleInfo.
|
|
#
|
|
# @param request VodUpdateSubtitleInfoRequest
|
|
# @return VodUpdateSubtitleInfoResponse
|
|
# @raise Exception
|
|
def update_subtitle_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateSubtitleInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateSubtitleInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateSubtitleInfoResponse(), True)
|
|
|
|
#
|
|
# GetAuditFramesForAudit.
|
|
#
|
|
# @param request VodGetAuditFramesForAuditRequest
|
|
# @return VodGetAuditFramesForAuditResponse
|
|
# @raise Exception
|
|
def get_audit_frames_for_audit(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetAuditFramesForAudit", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetAuditFramesForAuditResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetAuditFramesForAuditResponse(), True)
|
|
|
|
#
|
|
# GetMLFramesForAudit.
|
|
#
|
|
# @param request VodGetMLFramesForAuditRequest
|
|
# @return VodGetMLFramesForAuditResponse
|
|
# @raise Exception
|
|
def get_m_l_frames_for_audit(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetMLFramesForAudit", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetMLFramesForAuditResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetMLFramesForAuditResponse(), True)
|
|
|
|
#
|
|
# GetBetterFramesForAudit.
|
|
#
|
|
# @param request VodGetBetterFramesForAuditRequest
|
|
# @return VodGetBetterFramesForAuditResponse
|
|
# @raise Exception
|
|
def get_better_frames_for_audit(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetBetterFramesForAudit", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetBetterFramesForAuditResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetBetterFramesForAuditResponse(), True)
|
|
|
|
#
|
|
# GetAudioInfoForAudit.
|
|
#
|
|
# @param request VodGetAudioInfoForAuditRequest
|
|
# @return VodGetAudioInfoForAuditResponse
|
|
# @raise Exception
|
|
def get_audio_info_for_audit(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetAudioInfoForAudit", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetAudioInfoForAuditResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetAudioInfoForAuditResponse(), True)
|
|
|
|
#
|
|
# GetAutomaticSpeechRecognitionForAudit.
|
|
#
|
|
# @param request VodGetAutomaticSpeechRecognitionForAuditRequest
|
|
# @return VodGetAutomaticSpeechRecognitionForAuditResponse
|
|
# @raise Exception
|
|
def get_automatic_speech_recognition_for_audit(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetAutomaticSpeechRecognitionForAudit", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetAutomaticSpeechRecognitionForAuditResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetAutomaticSpeechRecognitionForAuditResponse(), True)
|
|
|
|
#
|
|
# GetAudioEventDetectionForAudit.
|
|
#
|
|
# @param request VodGetAudioEventDetectionForAuditRequest
|
|
# @return VodGetAudioEventDetectionForAuditResponse
|
|
# @raise Exception
|
|
def get_audio_event_detection_for_audit(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetAudioEventDetectionForAudit", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetAudioEventDetectionForAuditResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetAudioEventDetectionForAuditResponse(), True)
|
|
|
|
#
|
|
# CreateVideoClassification.
|
|
#
|
|
# @param request VodCreateVideoClassificationRequest
|
|
# @return VodCreateVideoClassificationResponse
|
|
# @raise Exception
|
|
def create_video_classification(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("CreateVideoClassification", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCreateVideoClassificationResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCreateVideoClassificationResponse(), True)
|
|
|
|
#
|
|
# UpdateVideoClassification.
|
|
#
|
|
# @param request VodUpdateVideoClassificationRequest
|
|
# @return VodUpdateVideoClassificationResponse
|
|
# @raise Exception
|
|
def update_video_classification(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateVideoClassification", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateVideoClassificationResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateVideoClassificationResponse(), True)
|
|
|
|
#
|
|
# DeleteVideoClassification.
|
|
#
|
|
# @param request VodDeleteVideoClassificationRequest
|
|
# @return VodDeleteVideoClassificationResponse
|
|
# @raise Exception
|
|
def delete_video_classification(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DeleteVideoClassification", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteVideoClassificationResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteVideoClassificationResponse(), True)
|
|
|
|
#
|
|
# ListVideoClassifications.
|
|
#
|
|
# @param request VodListVideoClassificationsRequest
|
|
# @return VodListVideoClassificationsResponse
|
|
# @raise Exception
|
|
def list_video_classifications(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListVideoClassifications", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListVideoClassificationsResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListVideoClassificationsResponse(), True)
|
|
|
|
#
|
|
# ListSnapshots.
|
|
#
|
|
# @param request VodListSnapshotsRequest
|
|
# @return VodListSnapshotsResponse
|
|
# @raise Exception
|
|
def list_snapshots(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListSnapshots", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListSnapshotsResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListSnapshotsResponse(), True)
|
|
|
|
#
|
|
# ExtractMediaMetaTask.
|
|
#
|
|
# @param request VodExtractMediaMetaTaskRequest
|
|
# @return VodExtractMediaMetaTaskResponse
|
|
# @raise Exception
|
|
def extract_media_meta_task(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ExtractMediaMetaTask", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodExtractMediaMetaTaskResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodExtractMediaMetaTaskResponse(), True)
|
|
|
|
#
|
|
# StartWorkflow.
|
|
#
|
|
# @param request VodStartWorkflowRequest
|
|
# @return VodStartWorkflowResponse
|
|
# @raise Exception
|
|
def start_workflow(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("StartWorkflow", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodStartWorkflowResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodStartWorkflowResponse(), True)
|
|
|
|
#
|
|
# RetrieveTranscodeResult.
|
|
#
|
|
# @param request VodRetrieveTranscodeResultRequest
|
|
# @return VodRetrieveTranscodeResultResponse
|
|
# @raise Exception
|
|
def retrieve_transcode_result(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("RetrieveTranscodeResult", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodRetrieveTranscodeResultResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodRetrieveTranscodeResultResponse(), True)
|
|
|
|
#
|
|
# GetWorkflowExecution.
|
|
#
|
|
# @param request VodGetWorkflowExecutionStatusRequest
|
|
# @return VodGetWorkflowExecutionStatusResponse
|
|
# @raise Exception
|
|
def get_workflow_execution(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetWorkflowExecution", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetWorkflowExecutionStatusResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetWorkflowExecutionStatusResponse(), True)
|
|
|
|
#
|
|
# GetWorkflowExecutionResult.
|
|
#
|
|
# @param request VodGetWorkflowResultRequest
|
|
# @return VodGetWorkflowResultResponse
|
|
# @raise Exception
|
|
def get_workflow_execution_result(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetWorkflowExecutionResult", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetWorkflowResultResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetWorkflowResultResponse(), True)
|
|
|
|
#
|
|
# CreateTaskTemplate.
|
|
#
|
|
# @param request VodCreateTaskTemplateRequest
|
|
# @return VodCreateTaskTemplateResponse
|
|
# @raise Exception
|
|
def create_task_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("CreateTaskTemplate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCreateTaskTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCreateTaskTemplateResponse(), True)
|
|
|
|
|
|
#
|
|
# UpdateTaskTemplate.
|
|
#
|
|
# @param request VodUpdateTaskTemplateRequest
|
|
# @return VodUpdateTaskTemplateResponse
|
|
# @raise Exception
|
|
def update_task_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("UpdateTaskTemplate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateTaskTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateTaskTemplateResponse(), True)
|
|
|
|
|
|
#
|
|
# GetTaskTemplate.
|
|
#
|
|
# @param request VodGetTaskTemplateRequest
|
|
# @return VodGetTaskTemplateResponse
|
|
# @raise Exception
|
|
def get_task_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetTaskTemplate", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetTaskTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetTaskTemplateResponse(), True)
|
|
|
|
#
|
|
# ListTaskTemplate.
|
|
#
|
|
# @param request VodListTaskTemplateRequest
|
|
# @return VodListTaskTemplateResponse
|
|
# @raise Exception
|
|
def list_task_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListTaskTemplate", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListTaskTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListTaskTemplateResponse(), True)
|
|
|
|
#
|
|
# DeleteTaskTemplate.
|
|
#
|
|
# @param request VodDeleteTaskTemplateRequest
|
|
# @return VodDeleteTaskTemplateResponse
|
|
# @raise Exception
|
|
def delete_task_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("DeleteTaskTemplate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteTaskTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteTaskTemplateResponse(), True)
|
|
|
|
|
|
#
|
|
# CreateWorkflowTemplate.
|
|
#
|
|
# @param request VodCreateWorkflowTemplateRequest
|
|
# @return VodCreateWorkflowTemplateResponse
|
|
# @raise Exception
|
|
def create_workflow_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("CreateWorkflowTemplate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCreateWorkflowTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCreateWorkflowTemplateResponse(), True)
|
|
|
|
|
|
#
|
|
# UpdateWorkflowTemplate.
|
|
#
|
|
# @param request VodUpdateWorkflowTemplateRequest
|
|
# @return VodUpdateWorkflowTemplateResponse
|
|
# @raise Exception
|
|
def update_workflow_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("UpdateWorkflowTemplate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateWorkflowTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateWorkflowTemplateResponse(), True)
|
|
|
|
|
|
#
|
|
# GetWorkflowTemplate.
|
|
#
|
|
# @param request VodGetWorkflowTemplateRequest
|
|
# @return VodGetWorkflowTemplateResponse
|
|
# @raise Exception
|
|
def get_workflow_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetWorkflowTemplate", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetWorkflowTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetWorkflowTemplateResponse(), True)
|
|
|
|
#
|
|
# ListWorkflowTemplate.
|
|
#
|
|
# @param request VodListWorkflowTemplateRequest
|
|
# @return VodListWorkflowTemplateResponse
|
|
# @raise Exception
|
|
def list_workflow_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListWorkflowTemplate", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListWorkflowTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListWorkflowTemplateResponse(), True)
|
|
|
|
#
|
|
# DeleteWorkflowTemplate.
|
|
#
|
|
# @param request VodDeleteWorkflowTemplateRequest
|
|
# @return VodDeleteWorkflowTemplateResponse
|
|
# @raise Exception
|
|
def delete_workflow_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("DeleteWorkflowTemplate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteWorkflowTemplateResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteWorkflowTemplateResponse(), True)
|
|
|
|
|
|
#
|
|
# CreateWatermarkTemplate.
|
|
#
|
|
# @param request VodCreateWatermarkRequest
|
|
# @return VodCreateWatermarkResponse
|
|
# @raise Exception
|
|
def create_watermark_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("CreateWatermarkTemplate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCreateWatermarkResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCreateWatermarkResponse(), True)
|
|
|
|
|
|
#
|
|
# UpdateWatermarkTemplate.
|
|
#
|
|
# @param request VodUpdateWatermarkRequest
|
|
# @return VodUpdateWatermarkResponse
|
|
# @raise Exception
|
|
def update_watermark_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("UpdateWatermarkTemplate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateWatermarkResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateWatermarkResponse(), True)
|
|
|
|
|
|
#
|
|
# GetWatermarkTemplate.
|
|
#
|
|
# @param request VodGetWatermarkRequest
|
|
# @return VodGetWatermarkResponse
|
|
# @raise Exception
|
|
def get_watermark_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetWatermarkTemplate", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetWatermarkResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetWatermarkResponse(), True)
|
|
|
|
#
|
|
# ListWatermarkTemplate.
|
|
#
|
|
# @param request VodListWatermarkRequest
|
|
# @return VodListWatermarkResponse
|
|
# @raise Exception
|
|
def list_watermark_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListWatermarkTemplate", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListWatermarkResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListWatermarkResponse(), True)
|
|
|
|
#
|
|
# DeleteWatermarkTemplate.
|
|
#
|
|
# @param request VodDeleteWatermarkRequest
|
|
# @return VodDeleteWatermarkResponse
|
|
# @raise Exception
|
|
def delete_watermark_template(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("DeleteWatermarkTemplate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteWatermarkResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteWatermarkResponse(), True)
|
|
|
|
|
|
#
|
|
# DeleteSpace.
|
|
#
|
|
# @param request VodDeleteSpaceRequest
|
|
# @return VodDeleteSpaceResponse
|
|
# @raise Exception
|
|
def delete_space(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DeleteSpace", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteSpaceResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteSpaceResponse(), True)
|
|
|
|
#
|
|
# CreateSpace.
|
|
#
|
|
# @param request VodCreateSpaceRequest
|
|
# @return VodCreateSpaceResponse
|
|
# @raise Exception
|
|
def create_space(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("CreateSpace", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCreateSpaceResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCreateSpaceResponse(), True)
|
|
|
|
#
|
|
# ListSpace.
|
|
#
|
|
# @param request VodListSpaceRequest
|
|
# @return VodListSpaceResponse
|
|
# @raise Exception
|
|
def list_space(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListSpace", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListSpaceResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListSpaceResponse(), True)
|
|
|
|
#
|
|
# GetSpaceDetail.
|
|
#
|
|
# @param request VodGetSpaceDetailRequest
|
|
# @return VodGetSpaceDetailResponse
|
|
# @raise Exception
|
|
def get_space_detail(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetSpaceDetail", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetSpaceDetailResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetSpaceDetailResponse(), True)
|
|
|
|
#
|
|
# UpdateSpace.
|
|
#
|
|
# @param request VodUpdateSpaceRequest
|
|
# @return VodUpdateSpaceResponse
|
|
# @raise Exception
|
|
def update_space(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateSpace", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateSpaceResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateSpaceResponse(), True)
|
|
|
|
#
|
|
# UpdateSpaceUploadConfig.
|
|
#
|
|
# @param request VodUpdateSpaceUploadConfigRequest
|
|
# @return VodUpdateSpaceUploadConfigResponse
|
|
# @raise Exception
|
|
def update_space_upload_config(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateSpaceUploadConfig", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateSpaceUploadConfigResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateSpaceUploadConfigResponse(), True)
|
|
|
|
#
|
|
# DescribeUploadSpaceConfig.
|
|
#
|
|
# @param request VodDescribeUploadSpaceConfigRequest
|
|
# @return VodDescribeUploadSpaceConfigResponse
|
|
# @raise Exception
|
|
def describe_upload_space_config(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeUploadSpaceConfig", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDescribeUploadSpaceConfigResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDescribeUploadSpaceConfigResponse(), True)
|
|
|
|
#
|
|
# UpdateUploadSpaceConfig.
|
|
#
|
|
# @param request VodUpdateUploadSpaceConfigRequest
|
|
# @return VodUpdateUploadSpaceConfigResponse
|
|
# @raise Exception
|
|
def update_upload_space_config(self, request):
|
|
try:
|
|
jsonData = MessageToJson(request, False, True)
|
|
res = self.json("UpdateUploadSpaceConfig",{},jsonData)
|
|
except Exception as Argument:
|
|
try:
|
|
ArgumentStr = Argument.args[0].decode("utf-8")
|
|
resp = Parse(ArgumentStr, VodUpdateUploadSpaceConfigResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateUploadSpaceConfigResponse(), True)
|
|
|
|
|
|
#
|
|
# AddDomainToScheduler.
|
|
#
|
|
# @param request VodAddDomainToSchedulerRequest
|
|
# @return VodAddDomainToSchedulerResponse
|
|
# @raise Exception
|
|
def add_domain_to_scheduler(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("AddDomainToScheduler", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodAddDomainToSchedulerResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodAddDomainToSchedulerResponse(), True)
|
|
|
|
#
|
|
# RemoveDomainFromScheduler.
|
|
#
|
|
# @param request VodRemoveDomainFromSchedulerRequest
|
|
# @return VodRemoveDomainFromSchedulerResponse
|
|
# @raise Exception
|
|
def remove_domain_from_scheduler(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("RemoveDomainFromScheduler", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodRemoveDomainFromSchedulerResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodRemoveDomainFromSchedulerResponse(), True)
|
|
|
|
#
|
|
# UpdateDomainPlayRule.
|
|
#
|
|
# @param request VodUpdateDomainPlayRuleRequest
|
|
# @return VodUpdateDomainPlayRuleResponse
|
|
# @raise Exception
|
|
def update_domain_play_rule(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateDomainPlayRule", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateDomainPlayRuleResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateDomainPlayRuleResponse(), True)
|
|
|
|
#
|
|
# StartDomain.
|
|
#
|
|
# @param request VodStartDomainRequest
|
|
# @return VodStartDomainResponse
|
|
# @raise Exception
|
|
def start_domain(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("StartDomain", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodStartDomainResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodStartDomainResponse(), True)
|
|
|
|
#
|
|
# StopDomain.
|
|
#
|
|
# @param request VodStopDomainRequest
|
|
# @return VodStopDomainResponse
|
|
# @raise Exception
|
|
def stop_domain(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("StopDomain", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodStopDomainResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodStopDomainResponse(), True)
|
|
|
|
#
|
|
# DeleteDomain.
|
|
#
|
|
# @param request VodDeleteDomainRequest
|
|
# @return VodDeleteDomainResponse
|
|
# @raise Exception
|
|
def delete_domain(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DeleteDomain", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDeleteDomainResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDeleteDomainResponse(), True)
|
|
|
|
#
|
|
# ListDomain.
|
|
#
|
|
# @param request VodListDomainRequest
|
|
# @return VodListDomainResponse
|
|
# @raise Exception
|
|
def list_domain(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListDomain", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListDomainResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListDomainResponse(), True)
|
|
|
|
#
|
|
# CreateCdnRefreshTask.
|
|
#
|
|
# @param request VodCreateCdnRefreshTaskRequest
|
|
# @return VodCreateCdnRefreshTaskResponse
|
|
# @raise Exception
|
|
def create_cdn_refresh_task(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("CreateCdnRefreshTask", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCreateCdnRefreshTaskResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCreateCdnRefreshTaskResponse(), True)
|
|
|
|
#
|
|
# CreateCdnPreloadTask.
|
|
#
|
|
# @param request VodCreateCdnPreloadTaskRequest
|
|
# @return VodCreateCdnPreloadTaskResponse
|
|
# @raise Exception
|
|
def create_cdn_preload_task(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("CreateCdnPreloadTask", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCreateCdnPreloadTaskResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCreateCdnPreloadTaskResponse(), True)
|
|
|
|
#
|
|
# ListCdnTasks.
|
|
#
|
|
# @param request VodListCdnTasksRequest
|
|
# @return VodListCdnTasksResponse
|
|
# @raise Exception
|
|
def list_cdn_tasks(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListCdnTasks", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListCdnTasksResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListCdnTasksResponse(), True)
|
|
|
|
#
|
|
# ListCdnAccessLog.
|
|
#
|
|
# @param request VodListCdnAccessLogRequest
|
|
# @return VodListCdnAccessLogResponse
|
|
# @raise Exception
|
|
def list_cdn_access_log(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListCdnAccessLog", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListCdnAccessLogResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListCdnAccessLogResponse(), True)
|
|
|
|
#
|
|
# ListCdnTopAccessUrl.
|
|
#
|
|
# @param request VodListCdnTopAccessUrlRequest
|
|
# @return VodListCdnTopAccessUrlResponse
|
|
# @raise Exception
|
|
def list_cdn_top_access_url(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListCdnTopAccessUrl", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListCdnTopAccessUrlResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListCdnTopAccessUrlResponse(), True)
|
|
|
|
#
|
|
# ListCdnTopAccess.
|
|
#
|
|
# @param request VodListCdnTopAccessRequest
|
|
# @return VodListCdnTopAccessResponse
|
|
# @raise Exception
|
|
def list_cdn_top_access(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListCdnTopAccess", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodListCdnTopAccessResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodListCdnTopAccessResponse(), True)
|
|
|
|
#
|
|
# ListCdnUsageData.
|
|
#
|
|
# @param request VodListCdnUsageDataRequest
|
|
# @return VodCdnStatisticsCommonResponse
|
|
# @raise Exception
|
|
def list_cdn_usage_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListCdnUsageData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCdnStatisticsCommonResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCdnStatisticsCommonResponse(), True)
|
|
|
|
#
|
|
# ListCdnStatusData.
|
|
#
|
|
# @param request VodListCdnStatusDataRequest
|
|
# @return VodCdnStatisticsCommonResponse
|
|
# @raise Exception
|
|
def list_cdn_status_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListCdnStatusData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCdnStatisticsCommonResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCdnStatisticsCommonResponse(), True)
|
|
|
|
#
|
|
# DescribeIpInfo.
|
|
#
|
|
# @param request VodDescribeIPInfoRequest
|
|
# @return VodDescribeIPInfoResponse
|
|
# @raise Exception
|
|
def describe_ip_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeIpInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDescribeIPInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDescribeIPInfoResponse(), True)
|
|
|
|
#
|
|
# ListCdnPvData.
|
|
#
|
|
# @param request VodListCdnPvDataRequest
|
|
# @return VodCdnStatisticsCommonResponse
|
|
# @raise Exception
|
|
def list_cdn_pv_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("ListCdnPvData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodCdnStatisticsCommonResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCdnStatisticsCommonResponse(), True)
|
|
|
|
#
|
|
# SubmitBlockTasks.
|
|
#
|
|
# @param request VodSubmitBlockTasksRequest
|
|
# @return VodSubmitBlockTasksResponse
|
|
# @raise Exception
|
|
def submit_block_tasks(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("SubmitBlockTasks",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodSubmitBlockTasksResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodSubmitBlockTasksResponse(), True)
|
|
|
|
|
|
#
|
|
# GetContentBlockTasks.
|
|
#
|
|
# @param request VodGetContentBlockTasksRequest
|
|
# @return VodGetContentBlockTasksResponse
|
|
# @raise Exception
|
|
def get_content_block_tasks(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("GetContentBlockTasks",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetContentBlockTasksResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetContentBlockTasksResponse(), True)
|
|
|
|
#
|
|
# CreateDomain.
|
|
#
|
|
# @param request VodCreateDomainV2Request
|
|
# @return VodCreateDomainV2Response
|
|
# @raise Exception
|
|
def create_domain(self, request):
|
|
try:
|
|
jsonData = MessageToJson(request, False, True)
|
|
res = self.json("CreateDomain", {}, jsonData)
|
|
except Exception as Argument:
|
|
try:
|
|
ArgumentStr = Argument.args[0].decode("utf-8")
|
|
resp = Parse(ArgumentStr, VodCreateDomainV2Response(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodCreateDomainV2Response(), True)
|
|
|
|
#
|
|
# UpdateDomainExpire.
|
|
#
|
|
# @param request VodUpdateDomainExpireV2Request
|
|
# @return VodUpdateDomainExpireV2Response
|
|
# @raise Exception
|
|
def update_domain_expire(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateDomainExpire", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateDomainExpireV2Response(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateDomainExpireV2Response(), True)
|
|
|
|
#
|
|
# UpdateDomainAuthConfig.
|
|
#
|
|
# @param request VodUpdateDomainAuthConfigV2Request
|
|
# @return VodUpdateDomainAuthConfigV2Response
|
|
# @raise Exception
|
|
def update_domain_auth_config(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateDomainAuthConfig", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateDomainAuthConfigV2Response(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateDomainAuthConfigV2Response(), True)
|
|
|
|
#
|
|
# AddOrUpdateCertificate.
|
|
#
|
|
# @param request AddOrUpdateCertificateV2Request
|
|
# @return AddOrUpdateCertificateV2Response
|
|
# @raise Exception
|
|
def add_or_update_certificate(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.post("AddOrUpdateCertificate",{},params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), AddOrUpdateCertificateV2Response(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, AddOrUpdateCertificateV2Response(), True)
|
|
|
|
|
|
#
|
|
# UpdateDomainUrlAuthConfig.
|
|
#
|
|
# @param request VodUpdateDomainUrlAuthConfigV2Request
|
|
# @return VodUpdateDomainUrlAuthConfigV2Response
|
|
# @raise Exception
|
|
def update_domain_url_auth_config(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("UpdateDomainUrlAuthConfig", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodUpdateDomainUrlAuthConfigV2Response(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateDomainUrlAuthConfigV2Response(), True)
|
|
|
|
#
|
|
# VerifyDomainOwner.
|
|
#
|
|
# @param request VodVerifyDomainOwnerRequest
|
|
# @return VodVerifyDomainOwnerResponse
|
|
# @raise Exception
|
|
def verify_domain_owner(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("VerifyDomainOwner", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodVerifyDomainOwnerResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodVerifyDomainOwnerResponse(), True)
|
|
|
|
#
|
|
# DescribeDomainVerifyContent.
|
|
#
|
|
# @param request VodDescribeDomainVerifyContentRequest
|
|
# @return VodDescribeDomainVerifyContentResponse
|
|
# @raise Exception
|
|
def describe_domain_verify_content(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeDomainVerifyContent", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDescribeDomainVerifyContentResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDescribeDomainVerifyContentResponse(), True)
|
|
|
|
#
|
|
# UpdateDomainConfig.
|
|
#
|
|
# @param request VodUpdateDomainConfigRequest
|
|
# @return VodUpdateDomainConfigResponse
|
|
# @raise Exception
|
|
def update_domain_config(self, request):
|
|
try:
|
|
jsonData = MessageToJson(request, False, True)
|
|
res = self.json("UpdateDomainConfig",{},jsonData)
|
|
except Exception as Argument:
|
|
try:
|
|
ArgumentStr = Argument.args[0].decode("utf-8")
|
|
resp = Parse(ArgumentStr, VodUpdateDomainConfigResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodUpdateDomainConfigResponse(), True)
|
|
|
|
#
|
|
# DescribeDomainConfig.
|
|
#
|
|
# @param request VodDescribeDomainConfigRequest
|
|
# @return VodDescribeDomainConfigResponse
|
|
# @raise Exception
|
|
def describe_domain_config(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeDomainConfig", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDescribeDomainConfigResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDescribeDomainConfigResponse(), True)
|
|
|
|
#
|
|
# AddCallbackSubscription.
|
|
#
|
|
# @param request VodAddCallbackSubscriptionRequest
|
|
# @return VodAddCallbackSubscriptionResponse
|
|
# @raise Exception
|
|
def add_callback_subscription(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("AddCallbackSubscription", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodAddCallbackSubscriptionResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodAddCallbackSubscriptionResponse(), True)
|
|
|
|
#
|
|
# SetCallbackEvent.
|
|
#
|
|
# @param request VodSetCallbackEventRequest
|
|
# @return VodSetCallbackEventResponse
|
|
# @raise Exception
|
|
def set_callback_event(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("SetCallbackEvent", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodSetCallbackEventResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodSetCallbackEventResponse(), True)
|
|
|
|
#
|
|
# GetSmartStrategyLitePlayInfo.
|
|
#
|
|
# @param request VodGetSmartStrategyLitePlayInfoRequest
|
|
# @return VodGetSmartStrategyLitePlayInfoResponse
|
|
# @raise Exception
|
|
def get_smart_strategy_lite_play_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetSmartStrategyLitePlayInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetSmartStrategyLitePlayInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetSmartStrategyLitePlayInfoResponse(), True)
|
|
|
|
#
|
|
# GetAppInfo.
|
|
#
|
|
# @param request VodGetAppInfoRequest
|
|
# @return VodGetAppInfoResponse
|
|
# @raise Exception
|
|
def get_app_info(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("GetAppInfo", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodGetAppInfoResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodGetAppInfoResponse(), True)
|
|
|
|
#
|
|
# DescribeVodSpaceTranscodeData.
|
|
#
|
|
# @param request DescribeVodSpaceTranscodeDataRequest
|
|
# @return DescribeVodSpaceTranscodeDataResponse
|
|
# @raise Exception
|
|
def describe_vod_space_transcode_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodSpaceTranscodeData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodSpaceTranscodeDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodSpaceTranscodeDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodSpaceAIStatisData.
|
|
#
|
|
# @param request DescribeVodSpaceAIStatisDataRequest
|
|
# @return DescribeVodSpaceAIStatisDataResponse
|
|
# @raise Exception
|
|
def describe_vod_space_a_i_statis_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodSpaceAIStatisData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodSpaceAIStatisDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodSpaceAIStatisDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodSpaceSubtitleStatisData.
|
|
#
|
|
# @param request DescribeVodSpaceSubtitleStatisDataRequest
|
|
# @return DescribeVodSpaceSubtitleStatisDataResponse
|
|
# @raise Exception
|
|
def describe_vod_space_subtitle_statis_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodSpaceSubtitleStatisData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodSpaceSubtitleStatisDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodSpaceSubtitleStatisDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodSpaceDetectStatisData.
|
|
#
|
|
# @param request DescribeVodSpaceDetectStatisDataRequest
|
|
# @return DescribeVodSpaceDetectStatisDataResponse
|
|
# @raise Exception
|
|
def describe_vod_space_detect_statis_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodSpaceDetectStatisData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodSpaceDetectStatisDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodSpaceDetectStatisDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodSpaceWorkflowDetailData.
|
|
#
|
|
# @param request DescribeVodSpaceWorkflowDetailDataRequest
|
|
# @return DescribeVodSpaceWorkflowDetailDataResponse
|
|
# @raise Exception
|
|
def describe_vod_space_workflow_detail_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodSpaceWorkflowDetailData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodSpaceWorkflowDetailDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodSpaceWorkflowDetailDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodSpaceEditDetailData.
|
|
#
|
|
# @param request DescribeVodSpaceEditDetailDataRequest
|
|
# @return DescribeVodSpaceEditDetailDataResponse
|
|
# @raise Exception
|
|
def describe_vod_space_edit_detail_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodSpaceEditDetailData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodSpaceEditDetailDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodSpaceEditDetailDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodSnapshotData.
|
|
#
|
|
# @param request DescribeVodSnapshotDataRequest
|
|
# @return DescribeVodSnapshotDataResponse
|
|
# @raise Exception
|
|
def describe_vod_snapshot_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodSnapshotData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodSnapshotDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodSnapshotDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodSpaceStorageData.
|
|
#
|
|
# @param request VodDescribeVodSpaceStorageDataRequest
|
|
# @return VodDescribeVodSpaceStorageDataResponse
|
|
# @raise Exception
|
|
def describe_vod_space_storage_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodSpaceStorageData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDescribeVodSpaceStorageDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDescribeVodSpaceStorageDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodDomainTrafficData.
|
|
#
|
|
# @param request VodDescribeVodDomainTrafficDataRequest
|
|
# @return VodDescribeVodDomainTrafficDataResponse
|
|
# @raise Exception
|
|
def describe_vod_domain_traffic_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodDomainTrafficData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDescribeVodDomainTrafficDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDescribeVodDomainTrafficDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodDomainBandwidthData.
|
|
#
|
|
# @param request VodDescribeVodDomainBandwidthDataRequest
|
|
# @return VodDescribeVodDomainBandwidthDataResponse
|
|
# @raise Exception
|
|
def describe_vod_domain_bandwidth_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodDomainBandwidthData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), VodDescribeVodDomainBandwidthDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, VodDescribeVodDomainBandwidthDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodEnhanceImageData.
|
|
#
|
|
# @param request DescribeVodEnhanceImageDataRequest
|
|
# @return DescribeVodEnhanceImageDataResponse
|
|
# @raise Exception
|
|
def describe_vod_enhance_image_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodEnhanceImageData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodEnhanceImageDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodEnhanceImageDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodSpaceEditStatisData.
|
|
#
|
|
# @param request DescribeVodSpaceEditStatisDataRequest
|
|
# @return DescribeVodSpaceEditStatisDataResponse
|
|
# @raise Exception
|
|
def describe_vod_space_edit_statis_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodSpaceEditStatisData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodSpaceEditStatisDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodSpaceEditStatisDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodPlayedStatisData.
|
|
#
|
|
# @param request DescribeVodPlayedStatisDataRequest
|
|
# @return DescribeVodPlayedStatisDataResponse
|
|
# @raise Exception
|
|
def describe_vod_played_statis_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodPlayedStatisData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodPlayedStatisDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodPlayedStatisDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodMostPlayedStatisData.
|
|
#
|
|
# @param request DescribeVodMostPlayedStatisDataRequest
|
|
# @return DescribeVodMostPlayedStatisDataResponse
|
|
# @raise Exception
|
|
def describe_vod_most_played_statis_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodMostPlayedStatisData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodMostPlayedStatisDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodMostPlayedStatisDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodRealtimeMediaData.
|
|
#
|
|
# @param request DescribeVodRealtimeMediaDataRequest
|
|
# @return DescribeVodRealtimeMediaDataResponse
|
|
# @raise Exception
|
|
def describe_vod_realtime_media_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodRealtimeMediaData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodRealtimeMediaDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodRealtimeMediaDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodRealtimeMediaDetailData.
|
|
#
|
|
# @param request DescribeVodRealtimeMediaDetailDataRequest
|
|
# @return DescribeVodRealtimeMediaDetailDataResponse
|
|
# @raise Exception
|
|
def describe_vod_realtime_media_detail_data(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodRealtimeMediaDetailData", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodRealtimeMediaDetailDataResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodRealtimeMediaDetailDataResponse(), True)
|
|
|
|
#
|
|
# DescribeVodVidTrafficFileLog.
|
|
#
|
|
# @param request DescribeVodVidTrafficFileLogRequest
|
|
# @return DescribeVodVidTrafficFileLogResponse
|
|
# @raise Exception
|
|
def describe_vod_vid_traffic_file_log(self, request):
|
|
try:
|
|
if sys.version_info[0] == 3:
|
|
jsonData = MessageToJson(request, False, True)
|
|
params = json.loads(jsonData)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
else:
|
|
params = MessageToDict(request, False, True)
|
|
for k, v in params.items():
|
|
if isinstance(v, (int, float, bool, str, unicode)) is True:
|
|
continue
|
|
else:
|
|
params[k] = json.dumps(v)
|
|
res = self.get("DescribeVodVidTrafficFileLog", params)
|
|
except Exception as Argument:
|
|
try:
|
|
resp = Parse(Argument.__str__(), DescribeVodVidTrafficFileLogResponse(), True)
|
|
except Exception:
|
|
raise Argument
|
|
else:
|
|
raise Exception(resp.ResponseMetadata.Error.Code)
|
|
else:
|
|
return Parse(res, DescribeVodVidTrafficFileLogResponse(), True)
|
|
|