gfwleak/dongxiaoyan-tsg-autotest
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
This repository has been archived on 2025-09-14. You can view files and clone it, but cannot push or open issues or pull requests.
Files
361e22c9c7f45bdb82b51e68c8d2afbbaf114354
dongxiaoyan-tsg-autotest/02-Keyword/tsg_bfapi/LogStatistics.robot

269 lines
24 KiB
Plaintext
Raw Normal View History

0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
*** Settings ***
Revert "日志统计查询时最近一小时、一天、一周、一个月、一年" This reverts commit 4248f1a1
2020-04-30 18:54:11 +08:00
Resource ../../03-Variable/BifangApiVariable.txt
日志统计代码完善
2020-05-06 10:08:06 +08:00
Library RequestsLibrary
Library String
Library Collections
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
*** Keywords ***
GetApi
统计日志自动化代码
2020-05-26 19:54:19 +08:00
[Arguments] ${apiName} ${url} ${startTime}=${None} ${endTime}=${None} ${limit}=50000 ${statisticTime}=${None} ${statisticsUnit}=${None} ${timeGranularity}=${None} ${policy_id}=${None} ${ip}=${None} ${device_ids}=${None} ${policy_ids}=${None} ${orderBy}=${None}
log policy_ids:${policy_ids}
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
#拼接查询条件
${strstrartTime}= run keyword if '${startTime}'!='${None}' Set Variable startTime=${startTime}&
... ELSE Set Variable ${EMPTY}
${strendTime}= run keyword if '${endTime}'!='${None}' Set Variable endTime=${endTime}&
... ELSE Set Variable ${EMPTY}
${strstatisticTime}= run keyword if '${statisticTime}'!='${None}' Set Variable statisticTime=${statisticTime}&
... ELSE Set Variable ${EMPTY}
${strlimit}= run keyword if '${limit}'!='${None}' Set Variable limit=${limit}&
... ELSE Set Variable ${EMPTY}
${strstatisticsUnit}= run keyword if '${statisticsUnit}'!='${None}' Set Variable statisticsUnit=${statisticsUnit}&
... ELSE Set Variable ${EMPTY}
${strtimeGranularity}= run keyword if '${timeGranularity}'!='${None}' Set Variable timeGranularity=${timeGranularity}&
... ELSE Set Variable ${EMPTY}
统计日志自动化代码
2020-05-26 19:54:19 +08:00
${strpolicy_id}= run keyword if '${policy_id}'!='${None}' Set Variable policy_id=${policy_id}&
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
... ELSE Set Variable ${EMPTY}
统计日志自动化代码
2020-05-26 19:54:19 +08:00
${strip}= run keyword if '${ip}'!='${None}' Set Variable ip=${ip}&
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
... ELSE Set Variable ${EMPTY}
统计日志自动化代码
2020-05-26 19:54:19 +08:00
${strdevice_ids}= run keyword if '${device_ids}'!='${None}' Set Variable device_ids=${device_ids}&
... ELSE Set Variable ${EMPTY}
${strpolicy_ids}= run keyword if '${policy_ids}'!='${None}' Set Variable policy_ids=${policy_ids}&
... ELSE Set Variable ${EMPTY}
${strorderBy}= run keyword if '${orderBy}'!='${None}' Set Variable orderBy=${orderBy}&
... ELSE Set Variable ${EMPTY}
#替换policy_id为policyId
${strpolicy_id}= run keyword if '${apiName}'=='domain_resource' replace string ${strpolicy_id} policy_id policyId
... ELSE Set Variable ${strpolicy_id}
#bifang请求信息
${condition} catenate SEPARATOR= ${strstrartTime} ${strendTime} ${strstatisticTime} ${strlimit} ${strstatisticsUnit} ${strtimeGranularity} ${strpolicy_id} ${strip} ${strdevice_ids} ${strpolicy_ids} ${strorderBy}
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
#创建请求信息
${header} Create Dictionary Content-Type=application/x-www-form-urlencoded Authorization=${token}
1、调整版本掺入位置，适应版本变化； 2、调整日志查询时间范围为当前； 3、调整case引用文件路径错误；
2020-06-18 11:19:51 +08:00
Create Session api http://${host}:${port}
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
#发送请求
${remoteResponse} Get Request api ${url}?${condition} headers=${header}
日志统计代码完善
2020-05-06 10:08:06 +08:00
${bifang} to json ${remoteResponse.content}
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
#验证请求是否成功
Should Be Equal As Strings ${remoteResponse.status_code} 200
日志统计代码完善
2020-05-06 10:08:06 +08:00
Should Be Equal As Strings ${bifang}[code] 200
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
#请求大数据
日志统计代码完善
2020-05-06 10:08:06 +08:00
${strstrartTime}= run keyword if '${startTime}'!='${None}' Set Variable __time > '${startTime}' and
... ELSE Set Variable ${EMPTY}
${strendTime}= run keyword if '${endTime}'!='${None}' Set Variable __time < '${endTime}' and
... ELSE Set Variable ${EMPTY}
${strstatisticTime}= run keyword if '${statisticTime}'!='${None}' Set Variable statisticTime=${statisticTime} and
... ELSE Set Variable ${EMPTY}
${strstatisticsUnit}= run keyword if '${statisticsUnit}'!='${None}' Set Variable statisticsUnit=${statisticsUnit} and
... ELSE Set Variable ${EMPTY}
${strtimeGranularity}= run keyword if '${timeGranularity}'!='${None}' Set Variable timeGranularity=${timeGranularity} and
... ELSE Set Variable ${EMPTY}
统计日志自动化代码
2020-05-26 19:54:19 +08:00
${strpolicy_id}= run keyword if '${policy_id}'!='${None}' Set Variable policy_id=${policy_id} and
... ELSE Set Variable ${EMPTY}
${strip}= run keyword if '${ip}'!='${None}' Set Variable ip=${ip} and
日志统计代码完善
2020-05-06 10:08:06 +08:00
... ELSE Set Variable ${EMPTY}
统计日志自动化代码
2020-05-26 19:54:19 +08:00
${strdevice_ids}= run keyword if '${device_ids}'!='${None}' Set Variable device_ids=${device_ids} and
日志统计代码完善
2020-05-06 10:08:06 +08:00
... ELSE Set Variable ${EMPTY}
#sql拼接 ${where}
统计日志自动化代码
2020-05-26 19:54:19 +08:00
${sqlwhere} catenate ${strstrartTime} ${strendTime} ${strstatisticTime} ${strstatisticsUnit} ${strtimeGranularity} ${strpolicy_id} ${strip} ${strdevice_ids}
日志统计代码完善
2020-05-06 10:08:06 +08:00
${strippedwhere}= Strip String ${sqlwhere} mode=right
#截取最后一个and
${where}= Get Substring ${strippedwhere} \ -4
统计日志自动化代码
2020-05-26 19:54:19 +08:00
#injectionstatics 时间粒度默认为30
${timeGranularity}= run keyword if '${timeGranularity}'=="${None}" and '${apiName}'=="injectionstatics" set variable 30
... ELSE set variable ${timeGranularity}
log ${apiName}
#topn排序依据： \ sessions、totalbytes、totalpackets
${TotalOrderBy}= run keyword if '${orderBy}'=="bytes" and '${apiName}'=="topn" set variable totalBytes
... ELSE IF '${orderBy}'=="packets" and '${apiName}'=="topn" set variable totalPackets
... ELSE IF '${orderBy}'=="sessions" and '${apiName}'=="topn" set variable sessions
日志统计代码完善
2020-05-06 10:08:06 +08:00
#BigData
${sql}= run keyword if '${apiName}'=="country" Set Variable SELECT country, APPROX_COUNT_DISTINCT_DS_HLL(ip_object) as num FROM source_country_ip_num_log where ${where} group by country order by num desc limit ${limit}
... ELSE IF '${apiName}'=="domain" Set Variable SELECT domain, protocol_type, ip_num, session_num \ FROM top_domain_recommend_daily_log where __time = '${statisticTime}'
... ELSE IF '${apiName}'=="url" Set Variable SELECT url, content_length, ip_num, session_num \ FROM top_website_urls_daily_log where __time = '${statisticTime}'
... ELSE IF '${apiName}'=="traffic" and '${statisticsUnit}'=='bytes' Set Variable select sum(total_in_bytes) as trafficInBytes, sum(total_out_bytes) as trafficOutBytes, \ sum(total_in_bytes+total_out_bytes) as trafficTotalBytes \ \ from traffic_metrics_log where __time >= '${startTime}' and __time < '${endTime}'
... ELSE IF '${apiName}'=="traffic" and '${statisticsUnit}'=='packets' Set Variable select sum(total_in_packets) as trafficInPackets,sum(total_out_packets) as trafficOutPackets,sum(total_in_packets+total_out_packets) as trafficTotalPackets from traffic_metrics_log where __time >= '${startTime}' and __time < '${endTime}'
... ELSE IF '${apiName}'=="traffic" and '${statisticsUnit}'=='sessions' Set Variable select sum(new_conn_num) as sessions \ from traffic_metrics_log where __time >= '${startTime}' and __time < '${endTime}'
... ELSE IF '${apiName}'=="traffic" and '${statisticsUnit}'=='${None}' Set Variable select sum(total_in_bytes) as trafficInBytes, sum(total_out_bytes) as trafficOutBytes, \ sum(total_in_bytes+total_out_bytes) as trafficTotalBytes, sum(total_in_packets) as trafficInPackets,sum(total_out_packets) as trafficOutPackets,sum(total_in_packets+total_out_packets) as trafficTotalPackets, sum(new_conn_num) as sessions from traffic_metrics_log where __time >= '${startTime}' and __time < '${endTime}'
... ELSE IF '${apiName}'=="ip_correlation_domain" and '${ip}'!='${None}' Set Variable SELECT \ ip, FROM_UNIXTIME(max(stat_time)) as last_time, FROM_UNIXTIME(min(stat_time)) as first_time, groupUniqArrayMerge(domain_list) as domain_list, groupUniqArrayMerge(port_list) as port_list \ FROM security_ip_info where \ stat_time >= '${startTime}' and stat_time < '${endTime}' and ip='${ip}' group by ip
... ELSE IF '${apiName}'=="ip_correlation_domain" and ${ip}==${None} Set Variable SELECT ip,FROM_UNIXTIME(max(stat_time)) as last_time, FROM_UNIXTIME(min(stat_time)) as first_time, groupUniqArrayMerge(domain_list) as domain_list, groupUniqArrayMerge(port_list) as port_list \ FROM security_ip_info where \ stat_time >= '${startTime}' and stat_time < '${endTime}' \ group by ip
统计日志自动化代码
2020-05-26 19:54:19 +08:00
... ELSE IF '${apiName}'=="hijack_srcip_num" Set Variable SELECT policy_id,country,location, APPROX_COUNT_DISTINCT_DS_HLL(ip_object) as num \ FROM proxy_event_hits_log where \ __time >='${startTime}' and __time <'${endTime}' and policy_id in \ ( ${policy_ids} ) group by policy_id , country,location order by num desc
日志统计代码完善
2020-05-06 10:08:06 +08:00
... ELSE IF '${apiName}'=="hijack_srcip_location" Set Variable select ip, IP_TO_CITY(ip) as location, IP_TO_GEO(ip) as geo from (SELECT policy_id, arrayJoin(groupUniqArrayMerge(ip_list)) as ip FROM proxy_ip_info where \ stat_time >= '${startTime}' and stat_time < '${endTime}' and policy_id = ${policy_id} group by policy_id )
统计日志自动化代码
2020-05-26 19:54:19 +08:00
... ELSE IF '${apiName}'=="domain_resource" Set Variable SELECT \ domain, groupUniqArrayMerge(ip_list) as ip_list, groupUniqArrayMerge(cdn_list) as cdn_list, groupUniqArrayMerge(protocol_type_list) as protocol_type_list, groupUniqArrayMerge(port_list) as port_list \ FROM security_website_domain_info where \ stat_time >= '${startTime}' and stat_time < '${endTime}' and policy_id=${policy_id} group by domain
... ELSE IF '${apiName}'=="injectionstatistics" Set Variable select DATE_FORMAT(FROM_UNIXTIME(FLOOR(UNIX_TIMESTAMP(__time)/${timeGranularity})*${timeGranularity}),'%Y-%m-%d %H:%i:%s') as stat_time, \ sum(bytes) as bytes from injection_metrics_log \ where __time >= '${startTime}' and __time < '${endTime}' group by DATE_FORMAT(FROM_UNIXTIME(FLOOR(UNIX_TIMESTAMP(__time)/${timeGranularity})*${timeGranularity}),'%Y-%m-%d %H:%i:%s') limit ${limit}
... ELSE IF '${apiName}'=="topn" Set Variable select domain,sum(session_num) as sessions,sum(c2s_byte_num) as sentBytes,sum(s2c_byte_num) as receivedBytes,sum(c2s_byte_num+s2c_byte_num) as totalBytes,sum(c2s_pkt_num) as sentPackets,sum(s2c_pkt_num) as receivedPackets,sum(c2s_pkt_num+s2c_pkt_num) as totalPackets from top_website_domain_log where __time >= '${startTime}' \ and __time < '${endTime}' \ and order_by='${orderBy}' \ group by domain order by ${TotalOrderBy} desc limit ${limit}
log ${sql}
日志统计代码完善
2020-05-06 10:08:06 +08:00
log sql------------${sql}
#traffic二次请求sql
${sql2}= run keyword if '${apiName}'=='traffic' SplicingTrafficSql ${apiName} ${startTime} ${endTime} statisticsUnit=${statisticsUnit} timeGranularity=${timeGranularity} limit=${limit}
#请求大数据接口
${response}= BigData ${sql}
${bigdata} to json ${response.content}
#traffic二次请求大数据
${response2}= run keyword if '${apiName}'=="traffic" BigData ${sql2}
${bigdata2} run keyword if '${apiName}'=="traffic" to json ${response2.content}
#响应码断言
Should Be Equal As Strings ${response.status_code} 200
Should Be Equal As Strings ${bigdata}[status] 200
#traffic二次请求响应码断言
run keyword if '${apiName}'=="traffic" run keywords Should Be Equal As Strings ${response2.status_code} 200
... AND Should Be Equal As Strings ${bigdata2}[status] 200
#traffic二次请求json拼接与毕方一致
${bigdataTraffic}= run keyword if '${apiName}'=="traffic" SplicingTrafficJson ${bigdata} ${bigdata2}
统计日志自动化代码
2020-05-26 19:54:19 +08:00
${bifanglist} run keyword if '${apiName}'=="ip_correlation_domain" \ or '${apiName}'=='domain_resource' set variable ${bifang['data']['list']['list']}
日志统计代码完善
2020-05-06 10:08:06 +08:00
... ELSE IF '${apiName}'=="traffic" set variable ${bifang['data']}
... ELSE set variable ${bifang['data']['list']}
${bigdatalist} run keyword if '${apiName}'=="traffic" set variable ${bigdataTraffic}
... ELSE set variable ${bigdata['data']}
FOR ${k} ${v} IN ENUMERATE @{bifanglist}
run keyword if '${apiName}'=="hijack_srcip_location" List Should Contain Value ${bigdatalist} ${v}
... ELSE IF '${apiName}'=="traffic" ForSecondary ${bigdatalist} ${bifanglist} ${apiName}
... ELSE ForSecondary @{bigdatalist}[${k}] ${v} ${apiName}
END
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
BigData
[Arguments] ${sql}
#创建请求信息
日志统计用例完善
2020-05-27 16:19:37 +08:00
Create Session api http://192.168.40.186:9999
0426 日志查询封装公共部分
2020-04-26 18:53:34 +08:00
#发送请求
日志统计代码完善
2020-05-06 10:08:06 +08:00
${remoteResponse}= Get Request api ?query=${sql}
[Return] ${remoteResponse}
ForSecondary
[Arguments] ${bigdata} ${v} ${apiName}
${bigdata} run keyword if '${apiName}'=='traffic' Convert To Dictionary ${bigdata}
... ELSE Set Variable ${bigdata}
${strbig} Get Dictionary Values ${bigdata}
${strfang} Get Dictionary Values ${v}
FOR ${key} ${var} IN ENUMERATE @{bigdata}
${string} Convert To String ${v}[${var}]
${stt} Get Substring ${string} 0 1
run keyword if '${stt}'=='[' ForTertiary ${bigdata}[${var}] ${v}[${var}]
... ELSE List Should Contain Value ${strbig} ${v}[${var}]
END
ForTertiary
[Arguments] ${str1} ${str2}
${str1} Convert To List ${str1}
${str2} Convert To List ${str2}
FOR ${kk} ${vv} IN ENUMERATE @{str1}
List Should Contain Value ${str1} ${vv}
END
SplicingTrafficJson
[Arguments] ${bigdata} ${bigdata2}
${bigdata} set variable ${bigdata['data']}[0]
@{trafficOutPacketsList} Create list
@{trafficOutBytesList} Create list
@{trafficTotalPacketsList} Create list
@{trafficInPacketsList} Create list
@{trafficInBytesList} Create list
@{sessionsList} Create list
@{trafficTotalBytesList} Create list
FOR ${k} ${v} IN ENUMERATE @{bigdata2['data']}
${total_out_packets}= Run keyword and ignore error log ${v['total_out_packets']}
${trafficOutPacketsListData}= run keyword if '${total_out_packets}[0]'!='FAIL' Create Dictionary statisticsTime=${v['statisticsTime']} statisticsNum=${v['total_out_packets']}
${total_out_bytes}= Run keyword and ignore error log ${v['total_out_bytes']}
${trafficOutBytesListData}= run keyword if '${total_out_bytes}[0]'!='FAIL' Create Dictionary statisticsTime=${v['statisticsTime']} statisticsNum=${v['total_out_bytes']}
${total_all_packets}= Run keyword and ignore error log ${v['total_all_packets']}
${trafficTotalPacketsListData}= run keyword if '${total_all_packets}[0]'!='FAIL' Create Dictionary statisticsTime=${v['statisticsTime']} statisticsNum=${v['total_all_packets']}
${total_in_packets}= Run keyword and ignore error log ${v['total_in_packets']}
${trafficInPacketsListData}= run keyword if '${total_in_packets}[0]'!='FAIL' Create Dictionary statisticsTime=${v['statisticsTime']} statisticsNum=${v['total_in_packets']}
${total_in_bytes}= Run keyword and ignore error log ${v['total_in_bytes']}
${trafficInBytesListData}= run keyword if '${total_in_bytes}[0]'!='FAIL' Create Dictionary statisticsTime=${v['statisticsTime']} statisticsNum=${v['total_in_bytes']}
${sessions}= Run keyword and ignore error log ${v['sessions']}
${sessionsListData}= run keyword if '${sessions}[0]'!='FAIL' Create Dictionary statisticsTime=${v['statisticsTime']} statisticsNum=${v['sessions']}
${total_all_bytes}= Run keyword and ignore error log ${v['total_all_bytes']}
${trafficTotalBytesListData}= run keyword if '${total_all_bytes}[0]'!='FAIL' Create Dictionary statisticsTime=${v['statisticsTime']} statisticsNum=${v['total_all_bytes']}
Append To List ${trafficTotalPacketsList} ${trafficTotalPacketsListData}
Append To List ${trafficInPacketsList} ${trafficInPacketsListData}
Append To List ${trafficInBytesList} ${trafficInBytesListData}
Append To List ${sessionsList} ${sessionsListData}
Append To List ${trafficTotalBytesList} ${trafficTotalBytesListData}
Append To List ${trafficOutPacketsList} ${trafficOutPacketsListData}
Append To List ${trafficOutBytesList} ${trafficOutBytesListData}
END
${bigdataTraffic} Create Dictionary
${1}= Run keyword and ignore error log ${bigdata['sessions']}
run keyword if '${1}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} sessions=${bigdata['sessions']}
${2}= Run keyword and ignore error log ${bigdata['trafficInPackets']}
run keyword if '${2}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficInPackets=${bigdata['trafficInPackets']}
${3}= Run keyword and ignore error log ${bigdata['trafficTotalBytes']}
run keyword if '${3}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficTotalBytes=${bigdata['trafficTotalBytes']}
${4}= Run keyword and ignore error log ${v['total_out_packets']}
run keyword if '${4}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficOutPacketsList=${trafficOutPacketsList}
${5}= Run keyword and ignore error log ${bigdata['trafficInBytes']}
run keyword if '${5}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficInBytes=${bigdata['trafficInBytes']}
${6}= Run keyword and ignore error log ${bigdata['trafficOutBytes']}
run keyword if '${6}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficOutBytes=${bigdata['trafficOutBytes']}
${7}= Run keyword and ignore error log ${bigdata['trafficOutPackets']}
run keyword if '${7}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficOutPackets=${bigdata['trafficOutPackets']}
${8}= Run keyword and ignore error log ${bigdata2['data'][0]['total_out_bytes']}
run keyword if '${8}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficOutBytesList=${trafficOutBytesList}
${9}= Run keyword and ignore error log ${bigdata2['data'][0]['total_all_packets']}
run keyword if '${9}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficTotalPacketsList=${trafficTotalPacketsList}
${10}= Run keyword and ignore error log ${bigdata2['data'][0]['total_in_packets']}
run keyword if '${10}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficInPacketsList=${trafficInPacketsList}
${11}= Run keyword and ignore error log ${bigdata2['data'][0]['total_in_bytes']}
run keyword if '${11}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficInBytesList=${trafficInBytesList}
${12}= Run keyword and ignore error log ${bigdata2['data'][0]['sessions']}
run keyword if '${12}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} sessionsList=${sessionsList}
${13}= Run keyword and ignore error log ${bigdata2['data'][0]['total_all_bytes']}
run keyword if '${13}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficTotalBytesList=${trafficTotalBytesList}
${14}= Run keyword and ignore error log ${bigdata['trafficTotalPackets']}
run keyword if '${14}[0]'!='FAIL' Set To Dictionary ${bigdataTraffic} trafficTotalPackets=${bigdata['trafficTotalPackets']}
[Return] ${bigdataTraffic}
SplicingTrafficSql
[Arguments] ${apiName} ${startTime} ${endTime} ${statisticsUnit} ${limit} ${timeGranularity}
${bytes}= run keyword if '${apiName}'=="traffic" and '${statisticsUnit}'=='bytes' Set Variable sum(total_in_bytes) as total_in_bytes, sum(total_out_bytes) as total_out_bytes, sum(total_in_bytes+total_out_bytes) as total_all_bytes,
... ELSE Set Variable ${EMPTY}
${packets}= run keyword if '${apiName}'=="traffic" and '${statisticsUnit}'=='packets' Set Variable sum(total_in_packets) as total_in_packets, sum(total_out_packets) as total_out_packets, sum(total_in_packets+total_out_packets) as total_all_packets,
... ELSE Set Variable ${EMPTY}
${sessions}= run keyword if '${apiName}'=="traffic" and '${statisticsUnit}'=='sessions' Set Variable sum(new_conn_num) as sessions
... ELSE Set Variable ${EMPTY}
${where} catenate ${bytes} ${packets} ${sessions}
${where} run keyword if '${apiName}'=="traffic" and '${statisticsUnit}'=='${None}' Set Variable sum(total_in_bytes) as total_in_bytes, sum(total_out_bytes) as total_out_bytes, sum(total_in_bytes+total_out_bytes) as total_all_bytes, sum(total_in_packets) as total_in_packets, sum(total_out_packets) as total_out_packets, sum(total_in_packets+total_out_packets) as total_all_packets, sum(new_conn_num) as sessions,
... ELSE Set Variable ${where}
#清空尾随空格
${strippedwhere}= Strip String ${where} mode=right
#时间粒度默认值
${timeGranularity}= run keyword if '${timeGranularity}'=="${None}" set variable 30
... ELSE set variable ${timeGranularity}
#截取最后一个and
${where}= Get Substring ${strippedwhere} \ -1
${sql2} catenate select DATE_FORMAT(FROM_UNIXTIME(FLOOR(UNIX_TIMESTAMP(__time)/${timeGranularity})*${timeGranularity}),'%Y-%m-%d %H:%i:%s') as statisticsTime, ${where} from traffic_metrics_log where __time >= '${startTime}' and __time < '${endTime}' group by DATE_FORMAT(FROM_UNIXTIME(FLOOR(UNIX_TIMESTAMP(__time)/${timeGranularity})*${timeGranularity}),'%Y-%m-%d %H:%i:%s') limit ${limit}
[Return] ${sql2}
添加推荐、趋势、时间和计数关键字
2020-05-28 14:14:12 +08:00
Recommend
[Arguments] ${url} ${statisticTime}
${header} Create Dictionary Content-Type=application/x-www-form-urlencoded Authorization=${token}
1、调整版本掺入位置，适应版本变化； 2、调整日志查询时间范围为当前； 3、调整case引用文件路径错误；
2020-06-18 11:19:51 +08:00
#Create Session api http://${host}:${port}/${version} headers=${header}
Create Session api http://${host}:${port} headers=${header}
添加推荐、趋势、时间和计数关键字
2020-05-28 14:14:12 +08:00
${remoteResponse} Get Request api ${url}?statisticTime=${statisticTime} headers=${header}
${response} to json ${remoteResponse.content}
Should Be Equal As Strings ${remoteResponse.status_code} 200
Trend
[Arguments] ${url} ${startTime} ${endTime} ${logType} ${policyId}
${header} Create Dictionary Content-Type=application/x-www-form-urlencoded Authorization=${token}
1、添加时间工具关键字 2、调整部分错误
2020-06-18 13:46:16 +08:00
Create Session api http://${host}:${port} headers=${header}
添加推荐、趋势、时间和计数关键字
2020-05-28 14:14:12 +08:00
${remoteResponse} Get Request api ${url}?policyId=${policyId}&logType=${logType}&startTime=${startTime}&endTime=${endTime} headers=${header}
${response} to json ${remoteResponse.content}
Should Be Equal As Strings ${remoteResponse.status_code} 200
Should Be Equal As Strings ${remoteResponse.json()}[msg] Success
Timeandcount
[Arguments] ${url} ${logType} ${policyIds}
${header} Create Dictionary Content-Type=application/x-www-form-urlencoded Authorization=${token}
1、调整版本掺入位置，适应版本变化； 2、调整日志查询时间范围为当前； 3、调整case引用文件路径错误；
2020-06-18 11:19:51 +08:00
#Create Session api http://${host}:${port}/${version} headers=${header}
Create Session api http://${host}:${port} headers=${header}
添加推荐、趋势、时间和计数关键字
2020-05-28 14:14:12 +08:00
${remoteResponse} Get Request api ${url}?policyIds=${policyIds}&logType=${logType} headers=${header}
${response} to json ${remoteResponse.content}
Should Be Equal As Strings ${remoteResponse.status_code} 200
Should Be Equal As Strings ${remoteResponse.json()}[msg] Success
${data} set variable ${response}[data][list]
FOR ${kk} ${vv} IN ENUMERATE @{data}
log ${vv}[policyId]
${true} Evaluate "${vv}[policyId]" in "${policyIds}"
Should Be Equal As Strings ${true} True
END
Reference in New Issue Copy Permalink