Skip to content

Commit ddbe220

Browse files
author
lijing
committed
update sdk with bfront v2.2.4
1 parent e12bdc0 commit ddbe220

File tree

6 files changed

+130
-1
lines changed

6 files changed

+130
-1
lines changed

‎examples/ket.py

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
#!/usr/bin/python
22
# -*- coding: UTF-8 -*-
33
from kscore.ket import getKetClient
4+
import time
45
import json
56

67
if __name__ == "__main__":
@@ -121,3 +122,19 @@
121122
res = client.StopLoop(param4)
122123
print json.dumps(res)
123124

125+
#查询直播转码时长统计数据接口调用示例 : GetLiveTransDuration
126+
#参数
127+
# StartUnixTime:查询起始时间戳秒数
128+
# EndUnixTime:查询截止时间戳秒数
129+
# Granularity:统计时间粒度
130+
# ResultType:返回结果类型
131+
start = "2017-06-16 00:00:00"
132+
end = "2017-06-20 00:00:00"
133+
t0 = time.strptime(start, "%Y-%m-%d %H:%M:%S")
134+
t1 = time.strptime(end, "%Y-%m-%d %H:%M:%S")
135+
StartUnixTime = int(time.mktime(t0))
136+
EndUnixTime = int(time.mktime(t1))
137+
Granularity = 5
138+
ResultType = 1
139+
res = client.GetLiveTransDuration(StartUnixTime, EndUnixTime, Granularity, ResultType)
140+
print json.dumps(res)

‎examples/kvs.py

Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
# -*- encoding:utf-8 -*-
22
from kscore.kvs import getKvsClient
33
import json
4+
import time
45

56
#没有配置kscore.cfg调用方式
67
#ks_access_key_id='xxxxxxxxxxxxxxxxxxxx'
@@ -66,6 +67,23 @@
6667
res = client.DelPreset(Preset=presetname)
6768
print json.dumps(res)
6869

70+
#修改任务队列接口调用示例 : UpdatePipeline
71+
# 该接口需要输入json格式数据
72+
pipeinfo = {
73+
"PipelineName": "usual",
74+
"Description": "test pipeline",
75+
"State": "Active",
76+
"RegularStart": "01:00:00",
77+
"RegularDuration":7200
78+
}
79+
res = client.UpdatePipeline(pipeinfo)
80+
print json.dumps(res)
81+
82+
#查询任务队列接口调用示例 : QueryPipeline
83+
# PipelineName:队列名称
84+
res = client.QueryPipeline(PipelineName="usual")
85+
print json.dumps(res)
86+
6987

7088
#创建任务接口调用示例 : CreateTask
7189
#具体参数请参考官方文档
@@ -124,3 +142,28 @@
124142
# Limit:单次请求的记录数，默认为100，最大值为100
125143
res = client.GetTaskMetaInfo(StartDate=20170100,EndDate=20170112,Marker=0,Limit=50)
126144
print json.dumps(res)
145+
146+
#查询转码时长统计数据接口调用示例 : GetMediaTransDuration
147+
#查询转码API调用次数统计数据接口调用示例 : GetInterfaceNumber
148+
#查询转码截图统计数据接口调用示例 : GetScreenshotNumber
149+
#参数
150+
# StartUnixTime:查询起始时间戳秒数
151+
# EndUnixTime:查询截止时间戳秒数
152+
# Granularity:统计时间粒度
153+
# ResultType:返回结果类型
154+
start = "2017-06-16 00:00:00"
155+
end = "2017-06-20 00:00:00"
156+
t0 = time.strptime(start, "%Y-%m-%d %H:%M:%S")
157+
t1 = time.strptime(end, "%Y-%m-%d %H:%M:%S")
158+
StartUnixTime = int(time.mktime(t0))
159+
EndUnixTime = int(time.mktime(t1))
160+
Granularity = 5
161+
ResultType = 1
162+
res = client.GetMediaTransDuration(StartUnixTime, EndUnixTime, Granularity, ResultType)
163+
print json.dumps(res)
164+
165+
res = client.GetInterfaceNumber(StartUnixTime, EndUnixTime, Granularity, ResultType)
166+
print json.dumps(res)
167+
168+
res = client.GetScreenshotNumber(StartUnixTime, EndUnixTime, Granularity, ResultType)
169+
print json.dumps(res)

‎kscore/data/ket/2017-01-01/service-2.yaml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,11 @@ operations:
9090
http:
9191
method: GET
9292

93+
GetLiveTransDuration:
94+
name: GetLiveTransDuration
95+
http:
96+
method: GET
97+
9398
shapes:
9499
App:
95100
type: string

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

Lines changed: 47 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,31 @@ operations:
8888
requestUri: /
8989
input:
9090
shape: GetTaskByTaskIDInstance
91+
92+
UpdatePipeline:
93+
name: UpdatePipeline
94+
http:
95+
method: POST
96+
97+
QueryPipeline:
98+
name: QueryPipeline
99+
http:
100+
method: GET
101+
102+
GetInterfaceNumber:
103+
name: GetInterfaceNumber
104+
http:
105+
method: GET
106+
107+
GetMediaTransDuration:
108+
name: GetMediaTransDuration
109+
http:
110+
method: GET
111+
112+
GetScreenshotNumber:
113+
name: GetScreenshotNumber
114+
http:
115+
method: GET
91116

92117
shapes:
93118
Preset:
@@ -108,6 +133,16 @@ shapes:
108133
type: integer
109134
Limit:
110135
type: integer
136+
PipelineName:
137+
type: string
138+
StartUnixTime:
139+
type: integer
140+
EndUnixTime:
141+
type: integer
142+
Granularity:
143+
type: integer
144+
ResultType:
145+
type: integer
111146
PresetInstance:
112147
type: structure
113148
members:
@@ -152,4 +187,15 @@ shapes:
152187
Limit:
153188
shape: Limit
154189

155-
190+
StatisticsInstance:
191+
type: structure
192+
members:
193+
StartUnixTime:
194+
shape: StartUnixTime
195+
EndUnixTime:
196+
shape: EndUnixTime
197+
Granularity:
198+
shape: Granularity
199+
ResultType:
200+
shape: ResultType
201+

‎kscore/ket.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,5 +49,8 @@ def UpdateLoop(self,param):
4949
def GetLoopList(self,App='live',UniqName='',StreamID=''):
5050
return self.client.get_loop_list(App=App,UniqName=UniqName,StreamID=StreamID)
5151

52+
def GetLiveTransDuration(self,StartUnixTime,EndUnixTime,Granularity=5,ResultType=1):
53+
return self.client.get_live_trans_duration(StartUnixTime=StartUnixTime,EndUnixTime=EndUnixTime,Granularity=Granularity,ResultType=ResultType)
54+
5255
def getKetClient(service_name,region_name,use_ssl=False,ks_access_key_id=None, ks_secret_access_key=None):
5356
return KetClient(service_name,region_name,use_ssl,ks_access_key_id, ks_secret_access_key)

‎kscore/kvs.py

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,5 +56,20 @@ def GetTaskMetaInfo(self,TaskID = '',StartDate=0,EndDate=0,Marker=0,Limit=100):
5656
else:
5757
return self.client.get_task_meta_info(TaskID = TaskID)
5858

59+
def UpdatePipeline(self,param):
60+
return self.client.update_pipeline(**param)
61+
62+
def QueryPipeline(self,PipelineName="usual"):
63+
return self.client.query_pipeline(PipelineName=PipelineName)
64+
65+
def GetInterfaceNumber(self,StartUnixTime,EndUnixTime,Granularity=5,ResultType=1):
66+
return self.client.get_interface_number(StartUnixTime=StartUnixTime,EndUnixTime=EndUnixTime,Granularity=Granularity,ResultType=ResultType)
67+
68+
def GetMediaTransDuration(self,StartUnixTime=0,EndUnixTime=0,Granularity=5,ResultType=1):
69+
return self.client.get_media_trans_duration(StartUnixTime=StartUnixTime,EndUnixTime=EndUnixTime,Granularity=Granularity,ResultType=ResultType)
70+
71+
def GetScreenshotNumber(self,StartUnixTime,EndUnixTime,Granularity=5,ResultType=1):
72+
return self.client.get_screenshot_number(StartUnixTime=StartUnixTime,EndUnixTime=EndUnixTime,Granularity=Granularity,ResultType=ResultType)
73+
5974
def getKvsClient(service_name,region_name,use_ssl=False,ks_access_key_id=None, ks_secret_access_key=None):
6075
return KvsClient(service_name,region_name,use_ssl,ks_access_key_id, ks_secret_access_key)

0 commit comments

Comments
 (0)