diff --git a/04-CustomLibrary/Custometest/Schema.py b/04-CustomLibrary/Custometest/Schema.py
index ed6137a..6c59dec 100644
--- a/04-CustomLibrary/Custometest/Schema.py
+++ b/04-CustomLibrary/Custometest/Schema.py
@@ -247,5 +247,28 @@ def loglistverify(logurl,schemauerl,token,starttime,endtime,logtype,filtervalue)
     assert code == 200
     print(response1.json()["code"])
     return response1.json()
+  
+#事件日志和通联日志时间分布查询 ，日志检索条件校验（filter内容验证） 
+def distributed_query(logurl,token):
+    url = logurl	#url示例：http://192.168.44.72:8080/v1/interface/gateway/sql/galaxy/security_event_hits_log/timedistribution?logType=security_event_hits_log&startTime=2021-03-26 12:27:03&endTime=2021-03-29 12:27:03&granularity=PT5M
+    headers = {"Content-Type": "application/json", "Authorization": token}
+    response = requests.get(url=url, headers=headers)
+    return response.json()
+    
+#原始日志检索时间分布计算
+def timedistribution(logurl,token,starttime,endtime,logtype,granularity,filtervalue):
+    url = logurl  # "http://192.168.44.72:8080/v1/log/timedistribution"
+    headers = {"Content-Type": "application/json",
+               "Authorization": token}
+    data = {
+        "start_common_recv_time": starttime,
+        "end_common_recv_time": endtime,
+        "logType": logtype,
+        "granularity": granularity,
+        "filter": filtervalue
+    }
+    print(data)
+    print(json.dumps(data))
+    response1 = requests.post(url=url, data=json.dumps(data), headers=headers)
 #if __name__ == '__main__':
 #    logapiverify("http://192.168.32.59:8080/v1/log/list","http://192.168.32.59:8080/v1/log/schema?logType=security_event_log","d475b20d-e2b8-4f24-87ee-d54af46e6aff&807&",'2021-03-20 16:36:41','2021-03-21 17:36:41',"security_event_log")
\ No newline at end of file