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
galaxy-platform-galaxy-trou…/24.05/tsg_olap_e2e_test/README.md
2024-04-26 03:40:35 +00:00

127 lines
4.0 KiB
Markdown
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

# TSG OLAP End-to-End Test
## 概述
TSG OLAP的数据摄入分为三种类型Logs、Metrics 和 File Chunks。为确保能够正确处理并写入相应存储系统需要支持端到端业务自检。支持部署方式
- 集中式部署
- 多数据中心部署
![End-to-End Workflow](images/e2e-test-flow-figure.png)
## 环境依赖
- Logs和Metric生成工具 `kafka-operation.sh` ,详细参考[帮助文档](https://docs.geedge.net/pages/viewpage.action?pageId=8029767)
- File Chunks生成工具 `file-chunk-generator.jar`
- 安装`Newman`,详细参考[帮助文档](https://learning.postman.com/docs/collections/using-newman-cli/newman-options/)
## 使用方法
### 配置Newman CLI enviroment.json
```json
{
"key": "qgw_ip",
"value": "192.168.44.30",
"type": "default",
"enabled": true
},
{
"key": "qgw_port",
"value": "9999",
"type": "default",
"enabled": true
},
{
"key": "hos_ip",
"value": "192.168.44.30",
"type": "default",
"enabled": true
},
{
"key": "hos_port",
"value": "9098",
"type": "default",
"enabled": true
},
{
"key": "hos_token",
"value": "xxxxxx",
"type": "default",
"enabled": true
}
```
### 配置File Chunks 生成工具
- 修改`config.properties`, 增加Kafka访问地址
```props
kafka.server=192.168.41.29:9092
```
### 写入测试集至Kafka
- Logs
```shell
cd tsg_olap_e2e_test/
kafka-operation.sh producer SESSION-RECORD < ./datasets/logs/session_record.dat
kafka-operation.sh producer VOIP-RECORD < ./datasets/logs/voip_record.dat
kafka-operation.sh producer PROXY-EVENT < ./datasets/logs/proxy_event.dat
```
- Metrics
```shell
cd tsg_olap_e2e_test/
kafka-operation.sh producer NETWORK-TRAFFIC-METRIC < ./datasets/metrics/network_traffic_metric.dat
kafka-operation.sh producer POLICY-RULE-METRIC < ./datasets/metrics/policy_rule_metric.dat
kafka-operation.sh producer OBJECT-STATISTICS-METRIC < ./datasets/metrics/object_statistics_metric.dat
kafka-operation.sh producer STATISTICS-RULE-METRIC < ./datasets/metrics/statistics_rule_metric.dat
```
- Files(与日志路径对应)
```shell
cd file-chunk-generator/
java -jar file-chunk-generator.jar --topic TRAFFIC-FILE-STREAM-RECORD -n 123e4567-e89b-12d3-a456-426614174001 --file_type traffic_pcapng
java -jar file-chunk-generator.jar --topic TRAFFIC-FILE-STREAM-RECORD -n 123e4567-e89b-12d3-a456-426614174002 --file_type html
java -jar file-chunk-generator.jar --topic TRAFFIC-FILE-STREAM-RECORD -n 123e4567-e89b-12d3-a456-426614174003 --file_type html
java -jar file-chunk-generator.jar --topic TRAFFIC-FILE-STREAM-RECORD -n 123e4567-e89b-12d3-a456-426614174004 --file_type eml
java -jar file-chunk-generator.jar --topic TRAFFIC-FILE-STREAM-RECORD -n 123e4567-e89b-12d3-a456-426614174005 --file_type traffic_pcapng
java -jar file-chunk-generator.jar --topic TROUBLESHOOTING-FILE-STREAM-RECORD -n 123e4567-e89b-12d3-a456-426614174006 --file_type troubleshooting_pcapng
java -jar file-chunk-generator.jar --topic TROUBLESHOOTING-FILE-STREAM-RECORD -n 123e4567-e89b-12d3-a456-426614174007 --file_type datapath_telemetry_pcapng
```
### 输出故障诊断报告等待3-5分钟
```shell
# -n 执行次数 --folder 测试目录logsmetricsfiles不指定将对所有模块进行自检
# Logs进行故障诊断输出诊断明细
newman run ./collection.json -n 1 -e ./environment.json --delay-request 500 --timeout-script 10000 --timeout-request 300000 --timeout 3600000 --insecure --verbose --ignore-redirects --folder logs
#Logs进行故障诊断通过表情形式输出测试结果
newman run ./collection.json -n 1 --delay-request 500 -e ./environment.json --ignore-redirects --folder logs -r emojitrain
#Logs进行故障诊断输出报告json格式自动存储newman目录
newman run ./collection.json -n 1 --delay-request 500 -e ./environment.json --ignore-redirects --folder logs -r cli,json
#清除测试数据(暂支持对文件的删除)
newman run ./collection.json -n 1 --delay-request 500 -e ./environment.json --ignore-redirects --folder clear_test_data -r emojitrain
```