kls add ListRealtimeStreamsInfo

yangfan16 · yangfan16 · commit 0ed9919cdb98 · 2017-10-17T12:13:52.000+08:00
diff --git a/examples/kls.py b/examples/kls.py
@@ -4,7 +4,10 @@
 import json
 
 if __name__ == "__main__":
+	#ks_access_key_id='xxxxxxxxxxxxxxxxxxxxxxxxxx'
+	#ks_secret_access_key='xxxxxxxxxxxxxxxxxxxxxxxxxx'
 	client = getKlsClient("kls", "cn-beijing-6",use_ssl=False)
+	#client = getKlsClient("kls", "cn-beijing-6",use_ssl=False,ks_access_key_id=ks_access_key_id,ks_secret_access_key=ks_secret_access_key)
 	
 	param = {
 		"UniqueName":"test",
@@ -79,3 +82,7 @@
 	res = client.KillStreamCache(param)
 	print json.dumps(res)
 
+	#查询主播汇总实时信息接口 : ListRealtimeStreamsInfo
+	res = client.ListRealtimeStreamsInfo(param)
+	print json.dumps(res)
+
diff --git a/kscore/data/kls/2017-01-01/service-2.yaml b/kscore/data/kls/2017-01-01/service-2.yaml
@@ -117,6 +117,11 @@ operations:
     http:
       method: POST
 
+  ListRealtimeStreamsInfo:
+    name: ListRealtimeStreamsInfo
+    http:
+      method: POST
+
 shapes:  
   UniqueName:
     type: string
diff --git a/kscore/kls.py b/kscore/kls.py
@@ -59,6 +59,9 @@ def GetBlacklist(self,UniqueName="",App="",Pubdomain=""):
   def CheckBlacklist(self,UniqueName="",App="",Pubdomain="",Stream=""):
     return self.client.check_blacklist(UniqueName = UniqueName,App = App, Pubdomain = Pubdomain,Stream = Stream)
 
+  def ListRealtimeStreamsInfo(self,param):
+    return self.client.list_realtime_streams_info(**param)
+
   def KillStreamCache(self,param):
     return self.client.kill_stream_cache(**param)
 
