|
| 1 | +# -*- encoding:utf-8 -*- |
| 2 | +from kscore.kls import getKlsClient |
| 3 | +import json |
| 4 | + |
| 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) |
| 85 | + |
0 commit comments