| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768 |
- # -*- encoding:utf-8 -*-
- from kscore.session import get_session
- import time
- class KetClient:
- def __init__(self,service_name,region_name,use_ssl,ks_access_key_id,ks_secret_access_key):
- s = get_session()
- if ks_access_key_id != None and ks_secret_access_key != None:
- self.client = s.create_client(service_name, region_name, use_ssl = use_ssl,
- ks_access_key_id=ks_access_key_id, ks_secret_access_key=ks_secret_access_key)
- else:
- self.client = s.create_client(service_name, region_name, use_ssl = use_ssl)
- def Preset(self,param):
- return self.client.preset(**param)
- def UpdatePreset(self,param):
- return self.client.update_preset(**param)
- def GetPresetList(self,App='live',UniqName=''):
- return self.client.get_preset_list(App=App,UniqName=UniqName)
- def GetPresetDetail(self,App='live',UniqName='',Preset=''):
- return self.client.get_preset_detail(App=App,UniqName=UniqName,Preset=Preset)
- def DelPreset(self,App='live',UniqName='',Preset=''):
- return self.client.del_preset(App=App,UniqName=UniqName,Preset=Preset)
- def StartStreamPull(self,param):
- return self.client.start_stream_pull(**param)
- def StopStreamPull(self,param):
- return self.client.stop_stream_pull(**param)
- def GetStreamTranList(self,App='live',UniqName='',StreamID='',OutPull=-1):
- return self.client.get_stream_tran_list(App=App,UniqName=UniqName,StreamID=StreamID,OutPull=OutPull)
- def GetQuotaUsed(self,UniqName=''):
- return self.client.get_quota_used(UniqName=UniqName)
- def StartLoop(self,param):
- return self.client.start_loop(**param)
- def StopLoop(self,param):
- return self.client.stop_loop(**param)
- def UpdateLoop(self,param):
- return self.client.update_loop(**param)
- def GetLoopList(self,App='live',UniqName='',StreamID=''):
- return self.client.get_loop_list(App=App,UniqName=UniqName,StreamID=StreamID)
- def GetLiveTransDuration(self,StartUnixTime,EndUnixTime,UniqName='',Granularity=5,ResultType=1):
- return self.client.get_live_trans_duration(UniqName=UniqName,StartUnixTime=StartUnixTime,EndUnixTime=EndUnixTime,Granularity=Granularity,ResultType=ResultType)
- def CreateDirectorTask(self,param):
- return self.client.create_director_task(**param)
- def UpdateDirectorTask(self,param):
- return self.client.update_director_task(**param)
- def QueryDirectorTask(self,App='live',UniqName='',TaskID=''):
- return self.client.query_director_task(App=App, UniqName=UniqName, TaskID=TaskID)
- def DelDirectorTask(self,App='live',UniqName='',TaskID=''):
- return self.client.del_director_task(App=App, UniqName=UniqName, TaskID=TaskID)
- def getKetClient(service_name,region_name,use_ssl=False,ks_access_key_id=None, ks_secret_access_key=None):
- return KetClient(service_name,region_name,use_ssl,ks_access_key_id, ks_secret_access_key)
|
