From 90925eda33095275b02c5676976696653ec5945a Mon Sep 17 00:00:00 2001 From: wb-cp908446 Date: Tue, 26 Dec 2023 14:45:15 +0800 Subject: [PATCH 1/2] fix(sysom_server:sysom_diagnosis):add offline pre process --- .../service_scripts/wrapper/offline.py | 23 +++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 sysom_server/sysom_diagnosis/service_scripts/wrapper/offline.py diff --git a/sysom_server/sysom_diagnosis/service_scripts/wrapper/offline.py b/sysom_server/sysom_diagnosis/service_scripts/wrapper/offline.py new file mode 100644 index 00000000..9115e62d --- /dev/null +++ b/sysom_server/sysom_diagnosis/service_scripts/wrapper/offline.py @@ -0,0 +1,23 @@ +import base64 +import time +import subprocess +from service_scripts.base import DiagnosisTask +from .base import DiagnosisPreProcessorPostWrapperBase + + +def execute_command(cmd): + result = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE) + stdout, _ = result.communicate() + return stdout.decode().strip() + +class DiagnosisPreProcessorPostWrapper(DiagnosisPreProcessorPostWrapperBase): + """所有命令重组,组合成可以直接调用sysom_offline工具的参数 + + Args: + DiagnosisPreProcessorPostWrapperBase (_type_): _description_ + """ + def process(self, task_id: str, diagnosis_task: DiagnosisTask): + for job in diagnosis_task.jobs: + studout = execute_command("curl 47.106.254.192:3393/key") + cmd = base64.b64encode((job.cmd).encode('utf-8')).decode() + job.cmd = '''export REGION=`curl -s 100.100.100.200/latest/meta-data/region-id` && sh -c "`curl -s https://sysom-${REGION}.oss-${REGION}-internal.aliyuncs.com/home/hive/dist/run_offline.sh` %s %s %s ''" '''%(studout, cmd, task_id) \ No newline at end of file -- Gitee From a40faae2bd559199d422a9d1833a8dbd081b7fd2 Mon Sep 17 00:00:00 2001 From: wb-cp908446 Date: Thu, 28 Dec 2023 09:37:27 +0800 Subject: [PATCH 2/2] sysom_web:add java_process test case --- .../e2e/app_observable/java_process.cy.js | 143 ++++++++++++++++++ 1 file changed, 143 insertions(+) create mode 100644 sysom_web/cypress/e2e/app_observable/java_process.cy.js diff --git a/sysom_web/cypress/e2e/app_observable/java_process.cy.js b/sysom_web/cypress/e2e/app_observable/java_process.cy.js new file mode 100644 index 00000000..a6025be8 --- /dev/null +++ b/sysom_web/cypress/e2e/app_observable/java_process.cy.js @@ -0,0 +1,143 @@ +/// + +describe("SysOM Migration Monitor Dashboard Test", () => { + beforeEach(() => { + cy.login() + }) + + it("Migration monitor test", () => { + // 1. 访问java可观测 + cy.visit("/app_observable/process_app"); + + // 2. 等待页面加载完成 + cy.wait(1000*20); + + // 运行时间（Stat面板数值类型） + cy.getPannelContentByTitle("运行时间") + .then(($el) => { + if ($el.text().includes("No data")) { + // 面板没有数据的情况 + cy.wrap($el).contains("No data"); + } + else { + const num = parseInt($el.text()); + expect(num).to.be.greaterThan(0); + } + }); + + // 虚拟内存（Stat面板数值类型） + cy.getPannelContentByTitle("虚拟内存") + .then(($el) => { + if ($el.text().includes("No data")) { + // 面板没有数据的情况 + cy.wrap($el).contains("No data"); + } + else { + const num = parseInt($el.text()); + expect(num).to.be.greaterThan(0); + } + }); + + // 最大时延（Stat面板数值类型） + cy.getPannelContentByTitle("最大延时") + .then(($el) => { + if ($el.text().includes("No data")) { + // 面板没有数据的情况 + cy.wrap($el).contains("No data"); + } + else { + const num = parseInt($el.text()); + expect(num).to.be.greaterThan(0); + } + }); + + // cpu（Pie Chart） + cy.getPannelContentByTitle("cpu").find("ul li").should("have.length.gte", 1); // Legend 至少有一列 + + // 内存（Pie Chart） + cy.getPannelContentByTitle("内存").find("ul li").should("have.length.gte", 1); // Legend 至少有一列 + + // cpu占用率（Pie Chart） + cy.getPannelContentByTitle("cpu占用率").find("ul li").should("have.length.gte", 1); // Legend 至少有一列 + + + // IO 吞吐量（Time series 面板） + cy.getPannelContentByTitle("IO 吞吐量").find("tbody tr").should("have.length", 2); // Legend 有两列 + cy.getPannelContentByTitle("IO 吞吐量").find("tbody tr").eq(0).find("td").eq(0).contains("read_bytes"); // 第一列的第一行是 read_bytes + cy.getPannelContentByTitle("IO 吞吐量").find("tbody tr").eq(0).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + cy.getPannelContentByTitle("IO 吞吐量").find("tbody tr").eq(1).find("td").eq(0).contains("write_bytes"); // 第一列的第二行是 write_bytes + cy.getPannelContentByTitle("IO 吞吐量").find("tbody tr").eq(1).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + + + // cpu占用率（Time series 面板） + cy.getPannelContentByTitle("cpu占用率折线图").find("tbody tr").should("have.length", 2); // Legend 有两列 + cy.getPannelContentByTitle("cpu占用率折线图").find("tbody tr").eq(0).find("td").eq(0).contains("内核态cpu_sys"); // 第一列的第一行是 内核态cpu_sys + cy.getPannelContentByTitle("cpu占用率折线图").find("tbody tr").eq(0).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + cy.getPannelContentByTitle("cpu占用率折线图").find("tbody tr").eq(1).find("td").eq(0).contains("用户态cpu_user"); // 第一列的第二行是 用户态cpu_user + cy.getPannelContentByTitle("cpu占用率折线图").find("tbody tr").eq(1).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + + + // 进程主次缺页次数（Time series 面板） + cy.getPannelContentByTitle("进程主次缺页次数").find("tbody tr").should("have.length", 2); // Legend 有两列 + cy.getPannelContentByTitle("进程主次缺页次数").find("tbody tr").eq(0).find("td").eq(0).contains("主缺页次数majflt"); // 第一列的第一行是 主缺页次数majflt + cy.getPannelContentByTitle("进程主次缺页次数").find("tbody tr").eq(0).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + cy.getPannelContentByTitle("进程主次缺页次数").find("tbody tr").eq(1).find("td").eq(0).contains("次缺页次数minflt"); // 第一列的第二行是 次缺页次数minflt + cy.getPannelContentByTitle("进程主次缺页次数").find("tbody tr").eq(1).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + + + // IO延迟（Time series 面板） + cy.getPannelContentByTitle("IO延迟").find("tbody tr").should("have.length", 1); // Legend 有两列 + cy.getPannelContentByTitle("IO延迟").find("tbody tr").eq(0).find("td").eq(0).contains("IO延迟"); // 第一列的第一行是 IO延迟 + cy.getPannelContentByTitle("IO延迟").find("tbody tr").eq(0).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + + + // 进程切换（Time series 面板） + cy.getPannelContentByTitle("进程切换").find("tbody tr").should("have.length", 2); // Legend 有两列 + cy.getPannelContentByTitle("进程切换").find("tbody tr").eq(0).find("td").eq(0).contains("进程自主切换"); // 第一列的第一行是 进程自主切换 + cy.getPannelContentByTitle("进程切换").find("tbody tr").eq(0).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + cy.getPannelContentByTitle("进程切换").find("tbody tr").eq(1).find("td").eq(0).contains("进程非自主切换"); // 第一列的第二行是 进程非自主切换 + cy.getPannelContentByTitle("进程切换").find("tbody tr").eq(1).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + + + // 进程调度状态（Time series 面板） + cy.getPannelContentByTitle("进程调度状态").find("tbody tr").should("have.length", 2); // Legend 有两列 + cy.getPannelContentByTitle("进程调度状态").find("tbody tr").eq(0).find("td").eq(0).contains("运行时间time"); // 第一列的第一行是 运行时间time + cy.getPannelContentByTitle("进程调度状态").find("tbody tr").eq(0).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + cy.getPannelContentByTitle("进程调度状态").find("tbody tr").eq(1).find("td").eq(0).contains("调度延迟delay"); // 第一列的第二行是 调度延迟delay + cy.getPannelContentByTitle("进程调度状态").find("tbody tr").eq(1).find("td").eq(1).contains(/\d+/).then(($el) => { // 第二列的第二行是数值 + const num = parseFloat($el.text()); + expect(num).to.be.least(0); + }); + + }) +}) \ No newline at end of file -- Gitee