Skip to content

Commit b839896

Browse files
liuyichenliuyichen
authored
Merge pull request KscSDK#8 from KscSDK/master
compare from master
2 parents d55807c + fed05d4 commit b839896

File tree

16 files changed

+2052
-234
lines changed

16 files changed

+2052
-234
lines changed

‎examples/cdn.py

Lines changed: 339 additions & 12 deletions
Large diffs are not rendered by default.

‎examples/eip.py

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
#!/usr/bin/python
2+
3+
# -*- encoding:utf-8 -*-
4+
5+
import json,pprint
6+
from prettyprinter import prettyPrinter
7+
from kscore.session import get_session
8+
9+
if __name__ == "__main__":
10+
s = get_session()
11+
12+
region='cn-beijing-6'
13+
#region='cn-shanghai-2'
14+
eipClient = s.create_client("eip", region, use_ssl=True)
15+
16+
#allInstances=kecClient.describe_instances()
17+
#allNics=vpcClient.describe_network_interfaces()
18+
#allEips=eipClient.describe_addresses(MaxResults=7,NextToken='OA==')
19+
allEips=eipClient.describe_addresses(MaxResults=7)
20+
#allEips=eipClient.describe_addresses(**{'Filter.1.Name':'instance-type','Filter.1.Value.1':'Ipfwd'})
21+
#allEips=eipClient.describe_addresses(**{'Filter.1.Name':'instance-type','Filter.1.Value.1':'Slb'})
22+
23+
#pprint.pprint(allEips)
24+
25+
#prettyPrinter().pprint(allEips)
26+
#prettyPrinter().pprint(allNics)
27+
#prettyPrinter().pprint(allInstances)
28+
for item in allEips['AddressesSet']:
29+
print item['PublicIp']
30+
print item['AllocationId']
31+
#eipClient.associate_address(**{'AllocationId':'1cd0da05-8a3e-4c8e-8230-e6d39b85331e','InstanceType':'Ipfwd','InstanceId':'bede9a1c-d3a7-4b31-82e6-6699790ad1a3', 'NetworkInterfaceId':'fec81567-a4c7-4460-a998-54f407e77c0a'})
32+
#eipClient.disassociate_address(**{'AllocationId':'1cd0da05-8a3e-4c8e-8230-e6d39b85331e'})
33+
#eipClient.modify_address(**{'AllocationId':'c054f87a-4508-4db2-bc10-f594b34a2ef3','BandWidth':1})
34+
#eipClient.modify_address(**{'AllocationId':'070a4af5-90ff-4953-a388-01a694ebdae5','BandWidth':1})

‎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/network.py

Lines changed: 25 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -9,31 +9,42 @@
99
if __name__ == "__main__":
1010
s = get_session()
1111

12-
vpcClient = s.create_client("vpc", "cn-shanghai-2", use_ssl=False)
13-
#eipClient = s.create_client("eip", "cn-beijing-6", use_ssl=False)
14-
eipClient = s.create_client("eip", "cn-shanghai-2", use_ssl=False)
15-
slbClient = s.create_client("slb", "cn-shanghai-2", use_ssl=False)
16-
kecClient = s.create_client("kec", "cn-shanghai-2", use_ssl=False)
12+
region='cn-beijing-6'
13+
#region='cn-shanghai-2'
14+
#vpcClient = s.create_client("vpc", region, use_ssl=True)
15+
#vpcClient = s.create_client("vpc", region, use_ssl=True)
16+
#vpcClient = s.create_client("vpc", region, use_ssl=True,verify=False)
17+
#eipClient = s.create_client("eip", region, use_ssl=True)
18+
slbClient = s.create_client("slb", region, use_ssl=True)
19+
#kecClient = s.create_client("kec", region, use_ssl=True)
1720

1821
#allVpcs=vpcClient.describe_vpcs()
22+
#allInstances=kecClient.describe_instances()
1923
#allNics=vpcClient.describe_network_interfaces()
2024
#allEips=eipClient.describe_addresses(MaxResults=7,NextToken='OA==')
2125
#allEips=eipClient.describe_addresses(MaxResults=7)
2226
#allEips=eipClient.describe_addresses(**{'Filter.1.Name':'instance-type','Filter.1.Value.1':'Ipfwd'})
23-
allInstances=kecClient.describe_instances()
24-
allEips=eipClient.describe_addresses(**{'Filter.1.Name':'instance-type','Filter.1.Value.1':'Slb'})
25-
allListeners=slbClient.describe_listeners(**{'Filter.1.Name':'load-balancer-id','Filter.1.Value.1':'5acac037-531c-414e-bb6f-c639c8948a57'})
27+
#allEips=eipClient.describe_addresses(**{'Filter.1.Name':'instance-type','Filter.1.Value.1':'Slb'})
28+
#allListeners=slbClient.describe_listeners(**{'Filter.1.Name':'load-balancer-id','Filter.1.Value.1':'89befb57-095a-4329-ae2a-fdfe81959f8c'})
29+
#allListeners=slbClient.describe_listeners()
2630
#slbClient.register_instances_with_listener(**{'ListenerId':'9b465945-5214-4038-8436-c1764b8298f5','RealServerIp':'10.0.0.2','RealServerPort':'80','RealServerType':'host'})
27-
givenListeners=slbClient.describe_listeners(**{'ListenerId.1':'9b465945-5214-4038-8436-c1764b8298f5'})
28-
prettyPrinter().pprint(givenListeners)
31+
#slbClient.register_instances_with_listener(**{'ListenerId':'c1b03c98-9252-44fe-94e8-ece92767f76e','RealServerIp':'120.92.44.206','RealServerPort':'80','RealServerType':'Ipfwd'})
32+
slbClient.register_instances_with_listener(**{'ListenerId':'9156f303-65fb-4f90-86cb-52dc25721031','RealServerIp':'120.92.33.46','RealServerPort':'4431','RealServerType':'Ipfwd','Weight':10})
33+
slbClient.register_instances_with_listener(**{'ListenerId':'9156f303-65fb-4f90-86cb-52dc25721031','RealServerIp':'120.92.42.4','RealServerPort':'4431','RealServerType':'Ipfwd','Weight':10})
34+
slbClient.register_instances_with_listener(**{'ListenerId':'9156f303-65fb-4f90-86cb-52dc25721031','RealServerIp':'120.92.9.75','RealServerPort':'4431','RealServerType':'Ipfwd','Weight':10})
35+
#givenListeners=slbClient.describe_listeners(**{'ListenerId.1':'d94b6af0-61bd-4b15-ab2c-c6758a3367bc'})
36+
#prettyPrinter().pprint(givenListeners)
2937
#slbClient.deregister_instances_from_listener(**{'RegisterId':'cf0245b2-b847-462a-a777-7f680f6e48b8'})
38+
#slbClient.delete_load_balancer(**{'LoadBalancerId':'b5a2fac6-7cd0-40ee-abb5-dbcc59cbb4b7'})
3039

3140
#pprint.pprint(allEips)
41+
#pprint.pprint(allVpcs)
3242

3343
#prettyPrinter().pprint(allVpcs)
3444
#prettyPrinter().pprint(allEips)
3545
#prettyPrinter().pprint(allNics)
3646
#prettyPrinter().pprint(allInstances)
47+
'''
3748
for item in allEips['AddressesSet']:
3849
print item['PublicIp']
3950
print item['AllocationId']
@@ -42,5 +53,8 @@
4253
for item in allListeners['ListenerSet']:
4354
print item['ListenerName']
4455
print item['ListenerId']
45-
#availableIps=vpcClient.describe_subnet_available_addresses()
4656
#availableIps=vpcClient.describe_subnet_available_addresses(**{'Filter.1.Name':'subnet-id','Filter.1.Value.1':'0d238ac1-69b0-4602-893b-8da5862069e0'})
57+
#pprint.pprint(dir(vpcClient))
58+
#eipClient.modify_address(**{'AllocationId':'c054f87a-4508-4db2-bc10-f594b34a2ef3','BandWidth':1})
59+
#eipClient.modify_address(**{'AllocationId':'070a4af5-90ff-4953-a388-01a694ebdae5','BandWidth':1})
60+
'''

‎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)

‎examples/slb.py

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
#!/usr/bin/python
2+
3+
# -*- encoding:utf-8 -*-
4+
5+
import json,pprint
6+
from prettyprinter import prettyPrinter
7+
from kscore.session import get_session
8+
9+
if __name__ == "__main__":
10+
s = get_session()
11+
12+
region='cn-beijing-6'
13+
#region='cn-shanghai-2'
14+
slbClient = s.create_client("slb", region, use_ssl=True)
15+
#kecClient = s.create_client("kec", region, use_ssl=True)
16+
17+
#allInstances=kecClient.describe_instances()
18+
#allListeners=slbClient.describe_listeners(**{'Filter.1.Name':'load-balancer-id','Filter.1.Value.1':'89befb57-095a-4329-ae2a-fdfe81959f8c'})
19+
allListeners=slbClient.describe_listeners()
20+
#slbClient.register_instances_with_listener(**{'ListenerId':'9b465945-5214-4038-8436-c1764b8298f5','RealServerIp':'10.0.0.2','RealServerPort':'80','RealServerType':'host'})
21+
#givenListeners=slbClient.describe_listeners(**{'ListenerId.1':'d94b6af0-61bd-4b15-ab2c-c6758a3367bc'})
22+
prettyPrinter().pprint(allListeners)
23+
#slbClient.deregister_instances_from_listener(**{'RegisterId':'cf0245b2-b847-462a-a777-7f680f6e48b8'})
24+
#slbClient.delete_load_balancer(**{'LoadBalancerId':'b5a2fac6-7cd0-40ee-abb5-dbcc59cbb4b7'})
25+
26+
#prettyPrinter().pprint(allInstances)
27+
for item in allListeners['ListenerSet']:
28+
print item['ListenerName']
29+
print item['ListenerId']

0 commit comments

Comments
 (0)