Skip to content

Commit 29e7361

Browse files
author
gaoyuan7
committed
增加gettasklist接口参数
1 parent 40d4357 commit 29e7361

File tree

3 files changed

+32
-18
lines changed

3 files changed

+32
-18
lines changed

examples/kvs.py

Lines changed: 13 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
client = getKvsClient("kvs", "cn-beijing-6",use_ssl=False)
1515

1616
#创建模板接口调用示例 : preset
17-
presetname = 'testpreset'
17+
presetname = 'xxxx'
1818
description = 'just a demo'
1919
presetType = 'avop'
2020

@@ -26,16 +26,10 @@
2626
"Param": {
2727
"f": "mp4",
2828
"AUDIO": {
29-
"acodec": "aac",
30-
"ar":"44100",
31-
"ab":"64k"
29+
"acodec": "aac"
3230
},
3331
"VIDEO": {
34-
"vr": 25,
35-
"vb": "500k",
36-
"vcodec": "h264",
37-
"width": 640,
38-
"height": 360
32+
"vcodec": "h264"
3933
}
4034
}
4135
}
@@ -54,7 +48,7 @@
5448
# WithDetail:是否查询模板详情,1-是 0-否
5549
# PresetType:模板类型,多种模板类型以逗号隔开
5650
# Presets:模板名称,多个模板名称以逗号隔开
57-
res = client.GetPresetList(WithDetail=1,PresetType="avop")
51+
res = client.GetPresetList(WithDetail=1,PresetType="xxxx")
5852
print json.dumps(res)
5953

6054
#获取模板信息接口调用示例 : GetPresetDetail
@@ -89,19 +83,19 @@
8983
#具体参数请参考官方文档
9084
task = {
9185
"DstDir": "",
92-
"DstObjectKey": "4.mp4",
93-
"DstBucket": "autotestoffline",
86+
"DstObjectKey": "xxxx",
87+
"DstBucket": "xxxx",
9488
"DstAcl": "public-read",
9589
"Preset": presetname,
9690
"SrcInfo": [
9791
{
98-
"path": "/autotestoffline/11.mp4",
92+
"path": "/xxxxx/xxxxx",
9993
"type": "video",
10094
"index": 0
10195
}
10296
],
10397
"CbMethod": "POST",
104-
"CbUrl": "http://10.4.2.38:19090/"
98+
"CbUrl": "xxxxx"
10599
}
106100

107101
#该接口需要输入json格式数据
@@ -113,7 +107,7 @@
113107
print json.dumps(res)
114108

115109
#查看任务状态接口调用示例 : GetTaskByTaskID
116-
taskid = "40d309d3b2bf373cd3f08e5b5e1bddf720160816"
110+
taskid = "xxxxxx"
117111
# TaskID:任务ID
118112
res = client.GetTaskByTaskID(TaskID = taskid)
119113
print json.dumps(res)
@@ -124,6 +118,10 @@
124118
# EndDate:截止时间,默认为开始时间加30天;若大于当前时间,则默认为当前时间;格式:20160930
125119
# Marker:请求起始游标,默认为0
126120
# Limit:单次请求的记录数,默认为100,最大值为100
121+
# StartTime:起始时间戳
122+
# EndTime:结束时间戳
123+
# 错误码:ErrorCode
124+
# 任务状态:TaskStatus
127125
res = client.GetTaskList(StartDate=20170100,EndDate=20170112,Marker=0,Limit=50)
128126
print json.dumps(res)
129127

kscore/data/kvs/2017-01-01/service-2.yaml

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,14 @@ shapes:
173173
type: integer
174174
ProcessTaskId:
175175
type: string
176+
ErrorCode:
177+
type: string
178+
TaskStatus:
179+
type: string
180+
StartTime:
181+
type: integer
182+
EndTime:
183+
type: integer
176184
PresetInstance:
177185
type: structure
178186
members:
@@ -203,6 +211,14 @@ shapes:
203211
shape: Marker
204212
Limit:
205213
shape: Limit
214+
ErrorCode:
215+
shape: ErrorCode
216+
TaskStatus:
217+
shape: TaskStatus
218+
StartTime:
219+
shape: StartTime
220+
EndTime:
221+
shape: EndTime
206222
GetTaskByTaskIDInstance:
207223
type: structure
208224
members:

kscore/kvs.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,13 +37,13 @@ def FetchObjectMediaProcess(self,task):
3737
def GetTaskByTaskID(self,TaskID=''):
3838
return self.client.get_task_by_task_id(TaskID=TaskID)
3939

40-
def GetTaskList(self,StartDate=0,EndDate=0,Marker=0,Limit=100):
40+
def GetTaskList(self,StartDate=0,EndDate=0,Marker=0,Limit=100,StartTime=0,EndTime=0,ErrorCode='',TaskStatus=''):
4141
if StartDate == 0:
4242
StartDate = int(time.strftime('%Y%m',time.localtime(time.time()))+"01")
4343
if EndDate == 0:
44-
return self.client.get_task_list(StartDate=StartDate,Marker=Marker,Limit=Limit)
44+
return self.client.get_task_list(StartDate=StartDate,Marker=Marker,Limit=Limit,StartTime=StartTime,EndTime=EndTime,ErrorCode=ErrorCode,TaskStatus=TaskStatus)
4545
else:
46-
return self.client.get_task_list(StartDate=StartDate,EndDate=EndDate,Marker=Marker,Limit=Limit)
46+
return self.client.get_task_list(StartDate=StartDate,EndDate=EndDate,Marker=Marker,Limit=Limit,StartTime=StartTime,EndTime=EndTime,ErrorCode=ErrorCode,TaskStatus=TaskStatus)
4747

4848
def DelTaskByTaskID(self,TaskID = ''):
4949
return self.client.del_task_by_task_id(TaskID = TaskID)

0 commit comments

Comments
 (0)