- VisualStudio2022插件的安装及使用-编程手把手系列文章
- pprof-在现网场景怎么用
- C#实现的下拉多选框,下拉多选树,多级节点
- 【学习笔记】基础数据结构:猫树
root@aea87fa6e6a2:/home/node# cat login2.js const request = require('request-promise'); const moment = require('moment'); const cron = require('node-cron'); process.env.TZ = 'Asia/Shanghai'; // 设置时区为上海时区 const rp = require('request-promise'); // 三台服务器地址、用户名和密码数组 const nTime=30; const servers = [ { ip: '192.168.0.4', username: '0463511', password: 'i@123456' }, { ip: '192.168.0.95', username: '0721702', password: '123456' }, { ip: '192.168.0.196', username: '1820318', password: '123456' } ]; // 登录链接 const loginUrl = 'http://{{server}}/api/auth/login'; // {{server}} 是占位符,将 在每次迭代中替换为服务器地址 // 数据采集链接 const dataUrl = 'http://{{server}}/api/icsp/scheduleLog/page?page=1&limit=10'; // 定时器间隔(以毫秒为单位) const interval = 60000; // 循环检测主函数 async function loopCheck() { for (const server of servers) { try { serverIP=server.ip; // 构建当前服务器的登录链接 const currentLoginUrl = loginUrl.replace('{{server}}', server.ip); // 构建当前服务器的数据采集链接 const currentDataUrl = dataUrl.replace('{{server}}', server.ip); // 发送登录请求 const response = await request.post({ url: currentLoginUrl, json: true, body: { userName: server.username, password: server.password } }); // 登录成功则输出信息 if (response.statusCode === 200) { console.log(`[${moment().format('YYYY-MM-DD HH:mm:ss')}] 登录服 务器 ${server.ip} 成功`); // 获取登录凭证(token) const token = response.data.token; // 使用获取的 token 发起数据采集请求 await dataRequest(currentDataUrl, token,server.ip); } else { console.error(`[${moment().format('YYYY-MM-DD HH:mm:ss')}] 登录 服务器 ${server.ip} 失败:`, response.message); } } catch (error) { console.error(`[${moment().format('YYYY-MM-DD HH:mm:ss')}] 登录服务 器 ${server.ip} 失败:`, error.message); } await sleep(3000);//服务器间的检测间隔 } // 检测完所有服务器后,等待一段时间后再次执行循环检测 // setTimeout(loopCheck, interval); //这里是循环检测入口 } async function loopCheck_info() { for (const server of servers) { try { serverIP=server.ip; // 构建当前服务器的登录链接 const currentLoginUrl = loginUrl.replace('{{server}}', server.ip); // 构建当前服务器的数据采集链接 const currentDataUrl = dataUrl.replace('{{server}}', server.ip); // 发送登录请求 const response = await request.post({ url: currentLoginUrl, json: true, body: { userName: server.username, password: server.password } }); // 登录成功则输出信息 if (response.statusCode === 200) { console.log(`[${moment().format('YYYY-MM-DD HH:mm:ss')}] 登录服 务器 ${server.ip} 成功`); // 获取登录凭证(token) const token = response.data.token; // 使用获取的 token 发起数据采集请求 await dataRequest_info(currentDataUrl, token,server.ip); } else { console.error(`[${moment().format('YYYY-MM-DD HH:mm:ss')}] 登录 服务器 ${server.ip} 失败:`, response.message); } } catch (error) { console.error(`[${moment().format('YYYY-MM-DD HH:mm:ss')}] 登录服务 器 ${server.ip} 失败:`, error.message); } await sleep(3000);//服务器间的检测间隔 } // 检测完所有服务器后,等待一段时间后再次执行循环检测 // setTimeout(loopCheck, interval); //这里是循环检测入口 } // 数据请求 async function dataRequest(dataUrl, token,serverIP) { // 构建请求头,包含 token const headers = { 'Authorization': token, 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/118.0.0.0 Safari/537.36' }; // 发送数据采集请求 const response = await request({ url: dataUrl, method: 'GET', headers: headers }); // 解析数据 dataParse(response); } // 数据请求2 async function dataRequest_info(dataUrl, token,serverIP) { // 构建请求头,包含 token const headers = { 'Authorization': token, 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/118.0.0.0 Safari/537.36' }; // 发送数据采集请求 const response = await request({ url: dataUrl, method: 'GET', headers: headers }); // 解析数据 dataParse_info(response); } // 解析数据 async function dataParse(response) { // 检查响应体是否为空 if (!response) { console.error('Received empty response body.'); return; } // 解析 JSON 数据 const jsonData = JSON.parse(response); // 获取数据数组 const rows = jsonData.data.rows; // 标志,表示是否找到了符合条件的条目 let found = false; // 遍历数据数组,查找状态为"数据同步任务运行中"的条目 for (const rowData of rows) { // 如果状态为"数据同步任务运行中",则打印对应的时间 if (rowData.error === "数据同步任务运行中...") { found = true;//检测运行变量 //updateTime是最后更新时间,createTime是创建时间。这里用更新时间 const createTime = moment(rowData.updateTime, 'YYYY-MM-DD HH:mm:ss').toDate(); const currentTime = new Date(); const minutesDifference = (currentTime.getTime() - createTime.getTime()) / (1000 * 60); // 如果时间差超过1小时,则打印超时信息 if (minutesDifference > nTime) { console.log('脚本监测到系统超时'); console.log('超时时间:', minutesDifference.toFixed(0), '分钟'); await sendLogsToAPI(`${moment().format('YYYY-MM-DD HH:mm:ss')} \nAEO ${serverIP} 异常 \n状态超时: ${minutesDifference.toFixed(0)}分钟` ); } console.log('时间:', rowData.updateTime); await sleep(1000); break; // 找到符合条件的条目后直接跳出循环 } } // 如果未找到符合条件的条目,则输出提示信息 if (!found) { console.log('未找到符合条件的条目'); await sendLogsToAPI(`${moment().format('YYYY-MM-DD HH:mm:ss')} \nAEO ${serverIP} 异常 \n进程没有运行` ); } } // 解析数据 async function dataParse_info(response) { // 检查响应体是否为空 if (!response) { console.error('Received empty response body.'); return; } // 解析 JSON 数据 const jsonData = JSON.parse(response); // 获取数据数组 const rows = jsonData.data.rows; // 标志,表示是否找到了符合条件的条目 let found = false; // 遍历数据数组,查找状态为"数据同步任务运行中"的条目 for (const rowData of rows) { // 如果状态为"数据同步任务运行中",则打印对应的时间 if (rowData.error === "数据同步任务运行中...") { found = true;//检测运行变量 //updateTime是最后更新时间,createTime是创建时间。这里用更新时间 const createTime = moment(rowData.updateTime, 'YYYY-MM-DD HH:mm:ss').toDate(); const currentTime = new Date(); const minutesDifference = (currentTime.getTime() - createTime.getTime()) / (1000 * 60); // 如果时间差超过1小时,则打印超时信息 if (minutesDifference > nTime) { console.log('脚本监测到系统超时'); console.log('超时时间:', minutesDifference.toFixed(0), '分钟'); await sendLogsToAPI(`${moment().format('YYYY-MM-DD HH:mm:ss')} \nAEO ${serverIP} 异常 \n状态超时: ${minutesDifference.toFixed(0)}分钟`); }else{ console.log('正常运行中'); await sendLogsToAPI(`${moment().format('YYYY-MM-DD HH:mm:ss')} \nAEO ${serverIP} 正常 \n最后更新: ${minutesDifference.toFixed(0)}分钟前`); } console.log('时间:', rowData.updateTime); await sleep(1000); break; // 找到符合条件的条目后直接跳出循环 } } // 如果未找到符合条件的条目,则输出提示信息 if (!found) { console.log('未找到符合条件的条目'); await sendLogsToAPI(`${moment().format('YYYY-MM-DD HH:mm:ss')} \nAEO ${serverIP} 异常 \n进程没有运行` ); } } const sendLogsToAPI = (logs) => { const resData = { "msgtype": "text", "text": { "content": logs, } }; const options = { method: "POST", uri: "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=17e3b586-20b3-eca2ffa84130", // uri: "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=8ff711ab-f80b-4874-7adf0831a8bc", headers: { "content-type": "application/json", }, body:JSON.stringify(resData), }; try { const response = rp(options); console.log('提示成功!'); } catch (error) { console.error('请求出错:', error); } }; // 休眠函数 function sleep(ms) { return new Promise(resolve => setTimeout(resolve, ms)); } // 开始循环检测 //loopCheck(); // 在每分钟的第 30 秒执行目标函数 cron.schedule('35 8 * * *', () => { console.log('目标函数在8:35执行!'); loopCheck_info(); // 在这里调用你想要定时执行的函数 }); cron.schedule('*/30 9-20 * * *', () => { console.log('目标函数在每分钟的第 50分钟执行!'); loopCheck(); // 在这里调用你想要定时执行的函数 });
。
最后此篇关于NODEJS通过发送json数据查询目标服务,实现服务器状态监控,发现异常发送到微信群提醒的文章就讲到这里了,如果你想了解更多关于NODEJS通过发送json数据查询目标服务,实现服务器状态监控,发现异常发送到微信群提醒的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我创建了一个基于命令行可移植脚本的工业化不可知构建系统,可用于快速构建多个依赖项目,而不必依赖特定的 IDE 或构建工厂。它是不可知的,因为它不是基于单个构建引擎。我使用 cmake 创建了第一个版本
我最初使用 Java 目标开发了一个语法(用于 TestRig 支持),然后将其移植到 Python(从 git hub 语法存储库扩展了 Python3 语法,因此需要将操作移植到 Python
我有一个以 iPhone 和 watchOS 为目标的 Xcode 项目。 iPhone 目标使用加速度计,模拟器不支持。我可以只启动 iPhone 应用程序而不启动 watch 目标吗?我从: Ca
您好,我想创建一个批处理文件,用于在 .eml 文件(目标 A)中查找某些关键字,然后删除它们所在的行。之后,我需要批处理文件将"new"文件放入(目标 B)中的单独 .eml 文件中。文件也可以是
当尝试通过 IntelliJ 运行示例 CorDapp (GitHub CorDapp) 时,我收到以下错误: Cannot inline bytecode built with JVM target
我在尝试向我的 kotlin spring 项目添加一些依赖项时遇到问题。我使用 spring boot 初始化程序来运行一个基本项目。 我的问题:如果我取消对 jackson 或 Koin 依赖项的
这是有问题的网站: http://www.onepixelroom.com/londonrefurb 当我点击关于部分后面的多个圆圈时,我希望它更改上面文本中的引号。 到目前为止,我得到它来显示 文本
单击后,我将删除两个元素 $(this) 和 $("#foo")。 目前我的代码如下所示: $(this).remove(); $("#foo").remove(); 如何在不重复自己的情况下优化它?
我有一个小脚本,可将 Markdown 文件编译为 html,并将其与一些样式表和 javascript 一起插入到模板的主体中。我有一个 GNU makefile 来完成这个: output.htm
已关闭。此问题需要 debugging details 。目前不接受答案。 编辑问题以包含 desired behavior, a specific problem or error, and the
一些背景知识: 在android中我们开发了同样的应用,基本上我们先开发了Android应用,现在我们创建了它的IOS版本,所以这个应用有多个客户端。在 android 中,我们实际上是使用 Andr
我想知道是否可以使用 knockout 来更改html中的目标() 我的所有其他信息都在 JavaScript 中,所以这对我来说是一个大问题。这是我的 JavaScript: var library
这个问题在这里已经有了答案: Selecting and manipulating CSS pseudo-elements such as ::before and ::after using j
我在我的有向图中添加了一堆节点和顶点,使用设置 typedef boost::adjacency_list graph; 创建 Node有一个节点名称字符串,Edge它的分数有一个整数。我试图遍历所有
关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。 这个问题似乎与 help center 中定义的范围内的编程无关。 . 关闭 8 年前。 Improve
如何存储我在 NSUserDefaults 中创建的 Goal 类型的对象数组? ( swift ) 代码如下: func saveGoalList ( newGoalList : [Goal] ){
Array.prototype.indexOf 和 Date.now 已在 ES5 中引入。如果我编译存储在文件 test.ts 中的以下代码,为什么 Typescript 不能转译? Date.no
我正在阅读有关属性的内容,并了解到可以使用您的代码将它们应用于不同的目标实体 -(请参阅 Attribute Targets)。 因此,查看我项目中的 AssemblyInfo.cs 文件,我可以看到
给定一个 Makefile: all: build/a build/b build/c # need to change this to all: build/* build/a:
我有一个带有多框架目标的项目- netstandard2.0;net471 . 我想为 netframework 构建解决方案和 netstandard分别。 目前我使用这个 MSBuild 命令:
我是一名优秀的程序员,十分优秀!