gfwleak/dongxiaoyan-tsg-autotest
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改log纯接口关键字

Browse Source
This commit is contained in:
byb11
2021-05-08 10:12:16 +08:00
parent 798c906d55
commit 3d8a75f8e5
1 changed files with 19 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
04-CustomLibrary/Custometest/LogSchema.py
View File

@@ -261,11 +261,8 @@ def loglistverify(logurl, schemauerl, token, starttime, endtime, logtype, filter
"fields": fields,
"filter": filtervalue
}
print(data)
print(json.dumps(data))
response1 = requests.post(url=url, data=json.dumps(data), headers=headers)
code = response1.json()["code"]
print(response1.json())
assert code == 200
print(response1.json()["code"])
return response1.json()
@@ -284,38 +281,35 @@ def distributed_query(logurl, token):
#日志检索条件校验 纯接口
def LogRetrieve(schemaurl,host,port,token,logType,datajson):
number = random.randint(0, 2147483647)
str1 = random.choice('abcdefghijklmnopqrstuvwxyz')
data=datajson["data"]["list"][0]
keylist = LogResponseVAL.getKeys(data)
a = schema(schemaurl, token)
fields=a["data"]["fields"]
for i in keylist:
conditions = data[i]
if conditions != None:
for field in fields:
name = field["name"]
if i == name:
if field["type"] == "string":
filter = "logType=" + logType + "&" + "filter=" + i + "=" + "'" + conditions + "'"
for field in fields:
name = field["name"]
if i == name:
if field["type"] == "string":
filter = "logType=" + logType + "&" + "filter=" + i + "=" + "'" + str1 + "'"
Logurl = "http://" + host + ":" + port + "/v1/interface/gateway/sql/galaxy/log/filter/validation?" + filter
print(Logurl)
responsebody = distributed_query(Logurl, token)
else:
if i == "common_recv_time" or i == "common_start_time" or i == "common_end_time" or i == "common_processing_time":
timeArray = time.strptime(conditions, "%Y-%m-%d %H:%M:%S")
timeStamp = str(int(time.mktime(timeArray)))
filter = "logType=" + logType + "&" + "filter=" + i + "=" + timeStamp
Logurl = "http://" + host + ":" + port + "/v1/interface/gateway/sql/galaxy/log/filter/validation?" + filter
print(Logurl)
responsebody = distributed_query(Logurl, token)
else:
if i == "common_recv_time" or i == "common_start_time" or i == "common_end_time" or i == "common_processing_time":
timeArray = time.strptime(conditions, "%Y-%m-%d %H:%M:%S")
timeStamp = str(int(time.mktime(timeArray)))
filter = "logType=" + logType + "&" + "filter=" + i + "=" + timeStamp
Logurl = "http://" + host + ":" + port + "/v1/interface/gateway/sql/galaxy/log/filter/validation?" + filter
print(Logurl)
responsebody = distributed_query(Logurl, token)
else:
filter = "logType="+logType+"&"+"filter="+i+"="+conditions
Logurl = "http://"+host+":"+port+"/v1/interface/gateway/sql/galaxy/log/filter/validation?"+filter
print(Logurl)
responsebody = distributed_query(Logurl, token)
filter = "logType=" + logType + "&" + "filter=" + i + "=" + str(number)
Logurl = "http://" + host + ":" + port + "/v1/interface/gateway/sql/galaxy/log/filter/validation?" + filter
print(Logurl)
responsebody = distributed_query(Logurl, token)
# 原始日志检索时间分布计算