Skip to content

Commit 1d1cc05

Browse files
author
金山云SDK
authored
Merge pull request KscSDK#58 from yangfan21/trunk
modify kls
2 parents 00b5bec + 139e6f0 commit 1d1cc05

File tree

4 files changed

+250
-295
lines changed

4 files changed

+250
-295
lines changed

‎examples/kls.py

Lines changed: 77 additions & 81 deletions
Original file line numberDiff line numberDiff line change
@@ -1,85 +1,81 @@
1-
# -*- encoding:utf-8 -*-
1+
#!/usr/bin/python
2+
# -*- coding: UTF-8 -*-
23
from kscore.kls import getKlsClient
34
import json
45

5-
6-
client = getOfflineClient("kls", "cn-beijing-6",use_ssl=False)
7-
8-
param = {
9-
"UniqueName":"test",
10-
"App":"live",
11-
"Pubdomain":"test.uplive.ks-cdn.com",
12-
"Stream":"yangfan21",
13-
"Mp4VodEnable":1,
14-
"Ks3FileNameM3u8":"a23{Pubdomain}23sf{AppName}",
15-
"Ks3FullPathMP4":"record-1/{UniqueName}/{AppName}/{Pubdomain}/{StreamName}/mp4/{StreamName}-{UnixTimestamp}-activity",
16-
"StartUnixtime":1489485300,
17-
"EndUnixtime":1489485480
18-
}
19-
20-
#定时录制接口需要输入json格式数据
21-
res = client.CreateRecordTask(param)
22-
print json.dumps(res)
23-
24-
#定时录制取消接口需要输入json格式数据
25-
res = client.CancelRecordTask(param)
26-
print json.dumps(res)
27-
28-
#查询录像任务状态接口(GetRecordTask)
29-
#参数
30-
# RecID:录制任务ID
31-
res = client.GetRecordTask(recID = 2017)
32-
print json.dumps(res)
33-
34-
#查询历史录制任务接口 ListHistoryRecordTasks
35-
res = client.ListHistoryRecordTasks(uniqueName="test",app="live",pubdomain="yangfan21.cn",stream="yangfan21",recType=1,limit=10,marker=10,orderTime=1,startUnixTime=123,endUnixTime=321)
36-
print json.dumps(res)
37-
38-
#短视频开始录制接口 : StartStreamRecord
39-
res = client.StartStreamRecord(param)
40-
print json.dumps(res)
41-
42-
#短视频开始录制接口 : StopStreamRecord
43-
res = client.StopStreamRecord(param)
44-
print json.dumps(res)
45-
46-
#查询在线录制任务接口 : ListRecordingTasks
47-
res = client.ListRecordingTasks(uniqueName="test",app="live",pubdomain="yangfan21.cn",stream="yangfan21",recType=1,limit=10,marker=10,orderTime=1,recStatusType=1)
48-
print json.dumps(res)
49-
50-
#查询主播流时长接口 : ListStreamDurations
51-
res = client.ListStreamDurations(uniqueName="test",app="live",pubdomain="yangfan21.cn",stream="yangfan21",startUnixTime=123,endUnixTime=321)
52-
print json.dumps(res)
53-
54-
#查询流历史信息接口 : ListHistoryPubStreamsInfo
55-
res = client.ListHistoryPubStreamsInfo(uniqueName="test",app="live",pubdomain="yangfan21.cn",stream="yangfan21",limit=10,marker=10,orderTime=1,startUnixTime=123,endUnixTime=321)
56-
print json.dumps(res)
57-
58-
#查询流历史错误信息接口 : ListHistoryPubStreamsErrInfo
59-
res = client.ListHistoryPubStreamsErrInfo(uniqueName="test",app="live",pubdomain="yangfan21.cn",stream="yangfan21",limit=10,marker=10,orderTime=1,startUnixTime=123,endUnixTime=321)
60-
print json.dumps(res)
61-
62-
#禁止单路直播流推送 : ForbidStream
63-
res = client.ForbidStream(param)
64-
print json.dumps(res)
65-
66-
#恢复单路直播流推送 : ResumeStream
67-
res = client.ResumeStream(param)
68-
print json.dumps(res)
69-
70-
#查询黑名单列表 : GetBlacklist
71-
res = client.GetBlacklist(uniqueName="test",app="live",pubdomain="yangfan21.cn")
72-
print json.dumps(res)
73-
74-
#转推实时信息查询接口 : listRelayStreamsInfo
75-
res = client.listRelayStreamsInfo(uniqueName="test",app="live",limit=10,marker=10)
76-
print json.dumps(res)
77-
78-
#转推历史错误统计接口 : listRelayErrInfo
79-
res = client.listRelayErrInfo(uniqueName="test",app="live",marker=10,startUnixTime=123,duration=120)
80-
print json.dumps(res)
81-
82-
#踢拉流接口 : KillStreamCache
83-
res = client.KillStreamCache(param)
84-
print json.dumps(res)
6+
if __name__ == "__main__":
7+
client = getKlsClient("kls", "cn-beijing-6",use_ssl=False)
8+
9+
param = {
10+
"UniqueName":"test",
11+
"App":"live",
12+
"Pubdomain":"test.uplive.ks-cdn.com",
13+
"Stream":"yangfan21",
14+
"Mp4VodEnable":1,
15+
"Ks3FileNameM3u8":"a23{Pubdomain}23sf{AppName}",
16+
"Ks3FullPathMP4":"record-1/{UniqueName}/{AppName}/{Pubdomain}/{StreamName}/mp4/{StreamName}-{UnixTimestamp}-activity",
17+
"StartUnixtime":1489485300,
18+
"EndUnixtime":1489485480
19+
}
20+
21+
# 查询推流实时信息接口: ListRealtimePubStreamsInfo
22+
res = client.ListRealtimePubStreamsInfo(UniqueName="test",App="live",Pubdomain="yangfan21.cn")
23+
print json.dumps(res)
24+
25+
26+
#定时录制接口需要输入json格式数据
27+
res = client.CreateRecordTask(param)
28+
print json.dumps(res)
29+
30+
#定时录制取消接口需要输入json格式数据
31+
res = client.CancelRecordTask(param)
32+
print json.dumps(res)
33+
34+
#查询录像任务状态接口(GetRecordTask)
35+
res = client.GetRecordTask(RecID = 2017)
36+
print json.dumps(res)
37+
38+
#查询历史录制任务接口 ListHistoryRecordTasks
39+
res = client.ListHistoryRecordTasks(UniqueName="test",App="live",Pubdomain="yangfan21.cn",Stream="yangfan21",RecType=1,Limit=10,Marker=10,OrderTime=1,StartUnixTime=1489485300,EndUnixTime=1489485480)
40+
print json.dumps(res)
41+
42+
#短视频开始录制接口 : StartStreamRecord
43+
res = client.StartStreamRecord(param)
44+
print json.dumps(res)
45+
46+
#短视频开始录制接口 : StopStreamRecord
47+
res = client.StopStreamRecord(param)
48+
print json.dumps(res)
49+
50+
#查询在线录制任务接口 : ListRecordingTasks
51+
res = client.ListRecordingTasks(UniqueName="test",App="live",Pubdomain="yangfan21.cn",Stream="yangfan21",RecType=1,Limit=10,Marker=10,OrderTime=1,RecStatusType=1)
52+
print json.dumps(res)
53+
54+
#查询主播流时长接口 : ListStreamDurations
55+
res = client.ListStreamDurations(UniqueName="test",App="live",Pubdomain="yangfan21.cn",Stream="yangfan21",StartUnixTime=1489485300,EndUnixTime=1489485480)
56+
print json.dumps(res)
57+
58+
#查询流历史信息接口 : ListHistoryPubStreamsInfo
59+
res = client.ListHistoryPubStreamsInfo(UniqueName="test",App="live",Pubdomain="yangfan21.cn",Stream="yangfan21",Limit=10,Marker=10,OrderTime=1,StartUnixTime=1489485300,EndUnixTime=1489485480)
60+
print json.dumps(res)
61+
62+
#查询流历史错误信息接口 : ListHistoryPubStreamsErrInfo
63+
res = client.ListHistoryPubStreamsErrInfo(UniqueName="test",App="live",Pubdomain="yangfan21.cn",Stream="yangfan21",Limit=10,Marker=10,OrderTime=1,StartUnixTime=1489485300,endUnixTime=1489485480)
64+
print json.dumps(res)
65+
66+
#禁止单路直播流推送 : ForbidStream
67+
res = client.ForbidStream(param)
68+
print json.dumps(res)
69+
70+
#恢复单路直播流推送 : ResumeStream
71+
res = client.ResumeStream(param)
72+
print json.dumps(res)
73+
74+
#查询黑名单列表 : GetBlacklist
75+
res = client.GetBlacklist(UniqueName="test",App="live",Pubdomain="yangfan21.cn")
76+
print json.dumps(res)
77+
78+
#踢拉流接口 : KillStreamCache
79+
res = client.KillStreamCache(param)
80+
print json.dumps(res)
8581

‎kscore/data/kls/2016-10-26/service-2.yaml

Lines changed: 0 additions & 56 deletions
This file was deleted.

0 commit comments

Comments
 (0)