kvs增加流式任务接口

gaoyuan7 · gaoyuan7 · commit 40d43577319f · 2017-10-10T20:15:17.000+08:00
diff --git a/examples/kvs.py b/examples/kvs.py
@@ -7,7 +7,7 @@
 #ks_access_key_id='xxxxxxxxxxxxxxxxxxxx'
 #ks_secret_access_key='xxxxxxxxxxxxxxxxxxxxxxx'
 # 参数：服务service_name,大区region_name 
-#client = getOfflineClient("offline", "cn-beijing-6",use_ssl=False,ks_access_key_id=ks_access_key_id,ks_secret_access_key=ks_secret_access_key)
+#client = getKvsClient("offline", "cn-beijing-6",use_ssl=False,ks_access_key_id=ks_access_key_id,ks_secret_access_key=ks_secret_access_key)
 
 #配置kscore.cfg调用方式
 
@@ -108,6 +108,10 @@
 res = client.CreateTask(task)
 print json.dumps(res)
 
+#该接口需要输入json格式数据
+res = client.CreateFlowTask(task)
+print json.dumps(res)
+
 #查看任务状态接口调用示例 : GetTaskByTaskID
 taskid = "40d309d3b2bf373cd3f08e5b5e1bddf720160816"
 # TaskID:任务ID
@@ -167,3 +171,16 @@
 
 res = client.GetScreenshotNumber(StartUnixTime, EndUnixTime, Granularity, ResultType)
 print json.dumps(res)
+
+#控制台专用
+#发起媒体转码
+res = client.FetchObjectMediaProcess(task)
+print json.dumps(res)
+
+#查询任务列表
+res = client.ListFetchObjectMediaProcess(StartUnixTime=StartUnixTime,EndUnixTime=EndUnixTime)
+print json.dumps(res)
+
+#查询单个任务详情
+res = client.GetFetchObjectMediaProcess(ProcessTaskId="12121212")
+print json.dumps(res)
diff --git a/kscore/data/kvs/2017-01-01/service-2.yaml b/kscore/data/kvs/2017-01-01/service-2.yaml
@@ -44,11 +44,21 @@ operations:
     input:
       shape: PresetInstance
 
+  CreateFlowTask:
+    name: CreateFlowTask
+    http:
+      method: POST
+
   CreateTask:
     name: CreateTask
     http:
       method: POST
 
+  FetchObjectMediaProcess:
+    name: FetchObjectMediaProcess
+    http:
+      method: POST
+
   DelTaskByTaskID:
     name: DelTaskByTaskID
     http:
@@ -114,6 +124,22 @@ operations:
     http:
       method: GET
 
+  ListFetchObjectMediaProcess:
+    name: ListFetchObjectMediaProcess
+    http:
+      method: GET
+      requestUri: /
+    input:
+      shape: ListFetchObjectMediaProcessInstance
+
+  GetFetchObjectMediaProcess:
+    name: GetFetchObjectMediaProcess
+    http:
+      method: GET
+      requestUri: /
+    input:
+      shape: GetFetchObjectMediaProcessInstance
+
 shapes:  
   Preset:
     type: string
@@ -131,6 +157,8 @@ shapes:
     type: integer
   Marker:
     type: integer
+  Marker1:
+    type: string
   Limit:
     type: integer
   PipelineName:
@@ -143,6 +171,8 @@ shapes:
     type: integer
   ResultType:
     type: integer
+  ProcessTaskId:
+    type: string
   PresetInstance:
     type: structure
     members:
@@ -198,4 +228,20 @@ shapes:
         shape: Granularity
       ResultType:
         shape: ResultType
+  ListFetchObjectMediaProcessInstance:
+    type: structure
+    members:
+      StartUnixTime:
+        shape: StartUnixTime
+      EndUnixTime:
+        shape: EndUnixTime
+      Marker:
+        shape: Marker1
+      Limit:
+        shape: Limit
 
+  GetFetchObjectMediaProcessInstance:
+    type: structure
+    members:
+      ProcessTaskId:
+        shape: ProcessTaskId
diff --git a/kscore/kvs.py b/kscore/kvs.py
@@ -28,6 +28,12 @@ def GetPresetDetail(self,Preset=''):
 	def CreateTask(self,task):
 		return self.client.create_task(**task)
 
+	def CreateFlowTask(self,task):
+		return self.client.create_flow_task(**task)
+
+	def FetchObjectMediaProcess(self,task):
+		return self.client.fetch_object_media_process(**task)
+
 	def GetTaskByTaskID(self,TaskID=''):
 		return self.client.get_task_by_task_id(TaskID=TaskID)
 
