Skip to content

Commit fed05d4

Browse files
author
金山云SDK
authored
Merge pull request KscSDK#33 from KscSDK/trunk
Trunk
2 parents eaf35d0 + ee12e6a commit fed05d4

File tree

7 files changed

+507
-34
lines changed

7 files changed

+507
-34
lines changed

‎examples/kvs.py

Lines changed: 126 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,126 @@
1+
# -*- encoding:utf-8 -*-
2+
from kscore.kvs import getKvsClient
3+
import json
4+
5+
#没有配置kscore.cfg调用方式
6+
#ks_access_key_id='xxxxxxxxxxxxxxxxxxxx'
7+
#ks_secret_access_key='xxxxxxxxxxxxxxxxxxxxxxx'
8+
# 参数：服务service_name,大区region_name
9+
#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)
10+
11+
#配置kscore.cfg调用方式
12+
13+
client = getKvsClient("kvs", "cn-beijing-6",use_ssl=False)
14+
15+
#创建模板接口调用示例 : preset
16+
presetname = 'testpreset'
17+
description = 'just a demo'
18+
presetType = 'avop'
19+
20+
#具体的格式请参考官网说明
21+
param = {
22+
"Preset": presetname,
23+
"Description": description,
24+
"PresetType": presetType,
25+
"Param": {
26+
"f": "mp4",
27+
"AUDIO": {
28+
"acodec": "aac",
29+
"ar":"44100",
30+
"ab":"64k"
31+
},
32+
"VIDEO": {
33+
"vr": 25,
34+
"vb": "500k",
35+
"vcodec": "h264",
36+
"width": 640,
37+
"height": 360
38+
}
39+
}
40+
}
41+
42+
#该接口需要输入json格式数据
43+
res = client.Preset(param)
44+
print json.dumps(res)
45+
46+
#更新模板接口调用示例 : UpdatePreset
47+
#该接口需要输入json格式数据
48+
res = client.UpdatePreset(param)
49+
print json.dumps(res)
50+
51+
#获取模板列表接口调用示例 : GetPresetList
52+
#参数
53+
# WithDetail:是否查询模板详情，1-是 0-否
54+
# PresetType:模板类型，多种模板类型以逗号隔开
55+
# Presets:模板名称，多个模板名称以逗号隔开
56+
res = client.GetPresetList(WithDetail=1,PresetType="avop")
57+
print json.dumps(res)
58+
59+
#获取模板信息接口调用示例 : GetPresetDetail
60+
# Preset:模板名称
61+
res = client.GetPresetDetail(Preset=presetname)
62+
print json.dumps(res)
63+
64+
#删除模板接口调用示例 : DelPreset
65+
# Preset:模板名称
66+
res = client.DelPreset(Preset=presetname)
67+
print json.dumps(res)
68+
69+
70+
#创建任务接口调用示例 : CreateTask
71+
#具体参数请参考官方文档
72+
task = {
73+
"DstDir": "",
74+
"DstObjectKey": "4.mp4",
75+
"DstBucket": "autotestoffline",
76+
"DstAcl": "public-read",
77+
"Preset": presetname,
78+
"SrcInfo": [
79+
{
80+
"path": "/autotestoffline/11.mp4",
81+
"type": "video",
82+
"index": 0
83+
}
84+
],
85+
"CbMethod": "POST",
86+
"CbUrl": "http://10.4.2.38:19090/"
87+
}
88+
89+
#该接口需要输入json格式数据
90+
res = client.CreateTask(task)
91+
print json.dumps(res)
92+
93+
#查看任务状态接口调用示例 : GetTaskByTaskID
94+
taskid = "40d309d3b2bf373cd3f08e5b5e1bddf720160816"
95+
# TaskID:任务ID
96+
res = client.GetTaskByTaskID(TaskID = taskid)
97+
print json.dumps(res)
98+
99+
#获取任务列表接口调用示例 : GetTaskList
100+
#参数
101+
# StartDate:开始时间，默认为当前月的第一天；格式：20160919
102+
# EndDate:截止时间，默认为开始时间加30天；若大于当前时间，则默认为当前时间；格式：20160930
103+
# Marker:请求起始游标，默认为0
104+
# Limit:单次请求的记录数，默认为100，最大值为100
105+
res = client.GetTaskList(StartDate=20170100,EndDate=20170112,Marker=0,Limit=50)
106+
print json.dumps(res)
107+
108+
#删除任务接口调用示例 : DelTaskByTaskID
109+
# TaskID:任务ID
110+
res = client.DelTaskByTaskID(TaskID = taskid)
111+
print json.dumps(res)
112+
113+
#任务置顶接口调用示例 : TopTaskByTaskID
114+
# TaskID:任务ID
115+
res = client.TopTaskByTaskID(TaskID = taskid)
116+
print json.dumps(res)
117+
118+
#查询任务META列表接口调用示例 : GetTaskMetaInfo
119+
#参数
120+
# TaskID:任务ID
121+
# StartDate:开始时间，默认为当前月的第一天；格式：20160919
122+
# EndDate:截止时间，默认为开始时间加30天；若大于当前时间，则默认为当前时间；格式：20160930
123+
# Marker:请求起始游标，默认为0
124+
# Limit:单次请求的记录数，默认为100，最大值为100
125+
res = client.GetTaskMetaInfo(StartDate=20170100,EndDate=20170112,Marker=0,Limit=50)
126+
print json.dumps(res)

‎examples/offline.py

Lines changed: 51 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,16 @@
11
# -*- encoding:utf-8 -*-
2-
from kscore.session import get_session
2+
from kscore.offline import getOfflineClient
33
import json
44

5-
#初始化
6-
s = get_session()
7-
#注：参数不能改变
8-
client = s.create_client("offline", "cn-beijing-6", use_ssl=False)
5+
#没有配置kscore.cfg调用方式
6+
#ks_access_key_id='xxxxxxxxxxxxxxxxxxxx'
7+
#ks_secret_access_key='xxxxxxxxxxxxxxxxxxxxxxx'
8+
# 参数：服务service_name,大区region_name
9+
#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)
10+
11+
#配置kscore.cfg调用方式
12+
13+
client = getOfflineClient("offline", "cn-beijing-6",use_ssl=False)
914

1015
#创建模板接口调用示例 : preset
1116
presetname = 'testpreset'
@@ -34,30 +39,33 @@
3439
}
3540
}
3641

37-
#该接口需要输入json格式数据，并且在参数前面加上"**"
38-
res = client.preset(**param)
42+
#该接口需要输入json格式数据
43+
res = client.Preset(param)
3944
print json.dumps(res)
4045

41-
42-
#更新模板接口调用示例 : update_preset
43-
#该接口需要输入json格式数据，并且在参数前面加上"**"
44-
res = client.update_preset(**param)
46+
#更新模板接口调用示例 : UpdatePreset
47+
#该接口需要输入json格式数据
48+
res = client.UpdatePreset(param)
4549
print json.dumps(res)
4650

47-
#获取模板列表接口调用示例 : get_preset_list
48-
res = client.get_preset_list()
51+
#获取模板列表接口调用示例 : GetPresetList
52+
#参数
53+
# withDetail:是否查询模板详情，1-是 0-否
54+
# presettype:模板类型，多种模板类型以逗号隔开
55+
# presets:模板名称，多个模板名称以逗号隔开
56+
res = client.GetPresetList(withDetail=0,presettype="avop")
4957
print json.dumps(res)
5058

51-
#获取模板信息接口调用示例 : get_preset_detail
52-
res = client.get_preset_detail(preset = presetname)
59+
#获取模板信息接口调用示例 : GetPresetDetail
60+
res = client.GetPresetDetail(presetname)
5361
print json.dumps(res)
5462

55-
#删除模板接口调用示例 : del_preset
56-
res = client.del_preset(preset = presetname)
63+
#删除模板接口调用示例 : DelPreset
64+
res = client.DelPreset(presetname)
5765
print json.dumps(res)
5866

5967

60-
#创建任务接口调用示例 : create_task
68+
#创建任务接口调用示例 : CreateTask
6169
#具体参数请参考官方文档
6270
task = {
6371
"dstDir": "",
@@ -76,27 +84,39 @@
7684
"cbUrl": "http://10.4.2.38:19090/"
7785
}
7886

79-
#该接口需要输入json格式数据，并且在参数前面加上"**"
80-
res = client.create_task(**task)
87+
#该接口需要输入json格式数据
88+
res = client.CreateTask(task)
8189
print json.dumps(res)
8290

83-
#查看任务状态接口调用示例 : get_task_by_task_id
91+
#查看任务状态接口调用示例 : GetTaskByTaskID
8492
taskid = "40d309d3b2bf373cd3f08e5b5e1bddf720160816"
85-
res = client.get_task_by_task_id(taskid = taskid)
93+
res = client.GetTaskByTaskID(taskid)
8694
print json.dumps(res)
8795

88-
#获取任务列表接口调用示例 : get_task_list
89-
res = client.get_task_list()
96+
#获取任务列表接口调用示例 : GetTaskList
97+
#参数
98+
# startdate:开始时间，默认为当前月的第一天；格式：20160919
99+
# enddate:截止时间，默认为开始时间加30天；若大于当前时间，则默认为当前时间；格式：20160930
100+
# marker:请求起始游标，默认为0
101+
# limit:单次请求的记录数，默认为100，最大值为100
102+
res = client.GetTaskList(startdate=20161101,enddate=20161118,marker=0,limit=50)
90103
print json.dumps(res)
91104

92-
#删除任务接口调用示例 : del_task_by_task_id
93-
res = client.del_task_by_task_id(taskid = taskid)
105+
#删除任务接口调用示例 : DelTaskByTaskID
106+
res = client.DelTaskByTaskID(taskid)
94107
print json.dumps(res)
95108

96-
#任务置顶接口调用示例 : top_task_by_task_id
97-
res = client.top_task_by_task_id(taskid = taskid)
109+
#任务置顶接口调用示例 : TopTaskByTaskID
110+
res = client.TopTaskByTaskID(taskid)
98111
print json.dumps(res)
99112

100-
#查询任务META列表接口调用示例 : get_task_meta_info
101-
res = client.get_task_meta_info(taskid = taskid)
102-
print json.dumps(res)
113+
#查询任务META列表接口调用示例 : GetTaskMetaInfo
114+
#参数
115+
# taskid:任务ID
116+
# startdate:开始时间，默认为当前月的第一天；格式：20160919
117+
# enddate:截止时间，默认为开始时间加30天；若大于当前时间，则默认为当前时间；格式：20160930
118+
# marker:请求起始游标，默认为0
119+
# limit:单次请求的记录数，默认为100，最大值为100
120+
121+
#res = client.GetTaskMetaInfo(startdate=20161101,enddate=20161118,marker=0,limit=50)
122+
#print json.dumps(res)

‎kscore/data/endpoints.yaml

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -108,6 +108,15 @@ partitions:
108108
cn-beijing-6:
109109
protocols:
110110
- http
111+
livetran:
112+
defaults:
113+
credentialScope:
114+
service: livetran
115+
EndpointRegion: cn-beijing-6
116+
endpoints:
117+
cn-beijing-6:
118+
protocols:
119+
- http
111120

112121
kcs:
113122
defaults:

0 commit comments

Comments
 (0)