add livetran loop api

lijing · lijing · commit e12bdc04ddc1 · 2017-05-04T21:24:19.000+08:00
diff --git a/examples/ket.py b/examples/ket.py
@@ -15,6 +15,10 @@
     outpull = 1
     srcurl = "rtmp://qa-ws.test-rtmplive.ks-cdn.com/live/20160819"
 
+    # 删除模板
+    res = client.DelPreset(App=appname, UniqName=uniqname, Preset=presetname)
+    print json.dumps(res)
+
     # 创建模板
     param = {
        "UniqName": uniqname,
@@ -48,10 +52,6 @@
     res = client.GetPresetList(App=appname, UniqName=uniqname)
     print json.dumps(res)
 
-    # 删除模板
-    res = client.DelPreset(App=appname, UniqName=uniqname, Preset=presetname)
-    print json.dumps(res)
-
     # 启动外网拉流
     param1 = {
        "UniqName": uniqname,
@@ -79,3 +79,45 @@
     # 获取用户已占用配额
     res = client.GetQuotaUsed(UniqName=uniqname)
     print json.dumps(res)
+    
+    # 发起轮播任务
+    param3 = {
+       "UniqName": uniqname,
+       "App": appname,
+       "StreamID": streamid,
+       "Preset": presetname,
+       "PubDomain": "test.uplive.ksyun.com",
+       "DurationHour":168,
+       "SrcInfo": [
+         {
+            "Path": "http://wangshuai9.ks3-cn-beijing.ksyun.com/ksyun.flv",
+            "Index": 0
+         }
+       ]
+    }
+    res = client.StartLoop(param3)
+    print json.dumps(res)
+    
+    # 更新轮播时长
+    param5 = {
+       "UniqName": uniqname,
+       "App": appname,
+       "StreamID": streamid,
+       "DurationHour":100,
+    }
+    res = client.UpdateLoop(param5)
+    print json.dumps(res)
+    
+    # 查询轮播列表
+    res = client.GetLoopList(App=appname, UniqName=uniqname, StreamID=streamid)
+    print json.dumps(res)
+    
+    # 停止轮播任务
+    param4 = {
+       "UniqName": uniqname,
+       "App": appname,
+       "StreamID": streamid,
+    }
+    res = client.StopLoop(param4)
+    print json.dumps(res)
+    
diff --git a/kscore/data/ket/2017-01-01/service-2.yaml b/kscore/data/ket/2017-01-01/service-2.yaml
@@ -70,6 +70,26 @@ operations:
     input:
       shape: UniqNameInstance
 
+  StartLoop:
+    name: StartLoop
+    http:
+      method: POST
+
+  StopLoop:
+    name: StopLoop
+    http:
+      method: POST
+
+  UpdateLoop:
+    name: UpdateLoop
+    http:
+      method: POST
+
+  GetLoopList:
+    name: GetLoopList
+    http:
+      method: GET
+
 shapes:  
   App:
     type: string
diff --git a/kscore/ket.py b/kscore/ket.py
@@ -37,5 +37,17 @@ def GetStreamTranList(self,App='live',UniqName='',StreamID='',OutPull=-1):
 	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 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)
