NodeJS -> Мониторинг состояния ПК

Рассмотрим пример скрипта для Мониторинга за ПК, Ноутбуком или Серверов. Для сбора информации об ПК воспользуемся пакетом NodeJS под названием systeminformation.

Что нам потребуется:

  • Компьютер: Любой компьютер с операционной системой Linux, в данном случае Debian
  • Программы:
    • Nano — консольный текстовый редактор
    • cURL — программа командной строки, для работы с HTTP
    • cron —демон, использующийся для периодического выполнения заданий.
    • NodeJS — это серверная платформа для работы с JavaScript через движок V8.
    • systeminformation— пакет NodeJS для получения данных об ПК.

Добавление и настройка устройства:

  1. Добавим новое устройство в VizIoT с именем «VizIoTSystemInfo»
  2. В «Основных настройках» устройства скопируем Ключ доступа и Пароль доступа.

Установка NodeJS:

Смотрите в «документацию NodeJS». Стандартная установка для Ubuntu или Debian:

# Using Ubuntu
curl -fsSL https://deb.nodesource.com/setup_lts.x | sudo -E bash -
sudo apt-get install -y nodejs
# Using Debian, as root
curl -fsSL https://deb.nodesource.com/setup_lts.x | bash -
apt-get install -y nodejs

Создания программы на NodeJS.

Программа будет получать данные от пакета systeminformation, собирать в пакет и отправлять его на сервер VizIoT каждые 15:

Создадим директорию:

mkdir /var/viziot/
mkdir /var/viziot/VizIoTSystemInfo

перейдем в директорию:

cd /var/viziot/VizIoTSystemInfo

Создадим NodeJS проект:

npm init

Установим пакеты для работы

  • systeminformation (https://github.com/sebhildebrandt/systeminformation)- пакет для сбора информации об ПК, ноутбука или сервера с операционными системами: Linux, macOS, Windows, FreeBSD, OpenBSD, NetBSD, SunOS;
    npm install systeminformation --save
  • viziot-mqtt-client-nodejs (https://www.npmjs.com/package/viziot-mqtt-client-nodejs) - модуль позволяет быстро и легко отправлять данные на сервер VizIoT по протоколу MQTT:
    npm install viziot-mqtt-client-nodejs --save

Создадим файл скрипта:

nano ./index.js

Содержание скрипта:

'use strict';
//#ключ и пароль доступа VizIoT
let keyDevice = "_______________";
let passDevice = "_____________________";
let idIntervalSend = 0;
let viziotMQTT = require('viziot-mqtt-client-nodejs');
let viziotMQTTClient = new viziotMQTT(keyDevice, passDevice);
viziotMQTTClient.connect(function () {
	clearInterval(idIntervalSend);
	idIntervalSend = setInterval(function () {
		getPacketAndSendToServer();
	}, 15000);
});

//https://github.com/sebhildebrandt/systeminformation
const si = require('systeminformation');
console.log("systeminformation version", si.version());

//TODO Укажите сетевой интерфейс для мониторинга сетевого трафика
let networkInterface = "Ethernet 5";
//для просмотра всех сетевых интерфейсов
// si.networkInterfaces(function(data){console.log(data); })

//необходимо при старте программы один раз прочитывать статус сетевого интерфейса для того была начальная точка отсчета, если это не делать, то первые данные будут нулевые
if(networkInterface != null && networkInterface.length > 0){
	si.networkStats(networkInterface, function(data) {});
}

//настроим какие параметры мы хотим мониторить
let listGetData = {
	'currentLoadCPU' : true,
	'currentLoadCPUCore' : false,
	'memRAMTotal_Gb' : false,
	'memRAMUsed_Gb' : true,
	'memRAMFree_Gb' : true,
	'memRAMUsed_Percent' : true,
	'memRAMFree_Percent' : true,
	'logicDiskTotal_Gb' : false,
	'logicDiskUsed_Gb' : true,
	'logicDiskFree_Gb' : true,
	'logicDiskUsed_Percent' : true,
	'logicDiskFree_Percent' : true,
	'countProcesses' : true,
	'mostActiveProcesses' : true, //укажите минимальную нагрузку приложением на CPU в процентах, чтобы отслеживать приложение которые сильно загрузили CPU
	'networkStatsInterface' : true,
	'time' : true,
	'uptimeDays' : true,
	'countUsers' : true,
	'countOnlineUsers' : true,
	'cpuTemperature' : true,
	'battery' : true,
};
let maxCPUUsed = 50; // разрешенный диапазон от 10 до 100. Если вы поставите 1, то программа будет отслеживать почти все процессы в ПК
let maxMEMUsed = 50; // разрешенный диапазон от 10 до 100. Если вы поставите 1, то программа будет отслеживать почти все процессы в ПК

//подсчитываем сколько нужно получить результатов от пакета systeminformation для отправки на сервер VizIoT.
let countResultsForSendPacket = 0;
for(let key in listGetData){
	if(listGetData[key] == true){
		countResultsForSendPacket++;
	}
}

function getRoundData(data, digits){
	if (data == undefined){
		return undefined;
	}
	if (digits == undefined){
		digits = 2;
	}
	return +(data).toFixed(digits);
}
function sendPacketToServer(packet, countResults) {
	if(countResults == countResultsForSendPacket){
		viziotMQTTClient.sendDataToVizIoT(packet, function (err) {
			if (err) {
				console.log("publish", err);
			}
		});
	}
}
function getPacketAndSendToServer() {
	let packet ={};
	let countResults = 0;
	let timePC = si.time();

	if(listGetData['currentLoadCPU'] || listGetData['currentLoadCPUCore'] ){
		si.currentLoad(function(data) {
			if(listGetData['currentLoadCPU']){
				packet.loadCPU = getRoundData(data.currentload);
				packet.loadUserCPU = getRoundData(data.currentloadUser);
				packet.loadSystemCPU = getRoundData(data.currentloadSystem);
				countResults++;
			}
			if(listGetData['currentLoadCPUCore']){
				for (let jj = 0; jj < data.cpus.length; jj++) {
					let core = data.cpus[jj];
					packet["loadCore" + jj] = getRoundData(core.load);
					packet["loadUserCore" + jj] = getRoundData(core.loadUser);
					packet["loadSystemCore" + jj] = getRoundData(core.loadSystem);
				}
				countResults++;
			}
			sendPacketToServer(packet, countResults);
		});
	}
	if(listGetData['memRAMTotal_Gb'] || listGetData['memRAMUsed_Gb'] || listGetData['memRAMFree_Gb'] || listGetData['memRAMUsed_Percent'] || listGetData['memRAMFree_Percent']){
		si.mem(function(data) {
			if(listGetData['memRAMTotal_Gb']){
				packet.memRAMTotal_Gb = getRoundData(data.total/1073741824);
				countResults++;
			}
			if(listGetData['memRAMUsed_Gb']){
				packet.memRAMUsed_Gb = getRoundData(data.used/1073741824);
				countResults++;
			}
			if(listGetData['memRAMFree_Gb']){
				packet.memRAMFree_Gb = getRoundData(data.free/1073741824);
				countResults++;
			}
			if(listGetData['memRAMUsed_Percent']){
				packet.memRAMUsed_Percent = getRoundData(data.used / data.total * 100);
				countResults++;
			}
			if(listGetData['memRAMFree_Percent']){
				packet.memRAMFree_Percent = getRoundData(data.free / data.total * 100);
				countResults++;
			}
			sendPacketToServer(packet, countResults);
		});
	}
	if(listGetData['logicDiskTotal_Gb'] || listGetData['logicDiskUsed_Gb'] || listGetData['logicDiskFree_Gb'] || listGetData['logicDiskUsed_Percent'] || listGetData['logicDiskFree_Percent']){
		si.fsSize(function(data) {
			if(listGetData['logicDiskTotal_Gb']){
				for (let jj = 0; jj < data.length; jj++) {
					let disc = data[jj];
					if(disc.type != undefined){
						let discName = disc.fs.replace(/\W/g, '');
						packet["logicDisk" + discName + "Total_Gb"] = getRoundData(disc.size/1073741824);
					}
				}
				countResults++;
			}
			if(listGetData['logicDiskUsed_Gb']){
				for (let jj = 0; jj < data.length; jj++) {
					let disc = data[jj];
					if(disc.type != undefined){
						let discName = disc.fs.replace(/\W/g, '');
						packet["logicDisk" + discName + "Used_Gb"] = getRoundData(disc.used/1073741824);
					}
				}
				countResults++;
			}
			if(listGetData['logicDiskFree_Gb']){
				for (let jj = 0; jj < data.length; jj++) {
					let disc = data[jj];
					if(disc.type != undefined){
						let discName = disc.fs.replace(/\W/g, '');
						packet["logicDisk" + discName + "Free_Gb"] = getRoundData((disc.size - disc.used)/1073741824);
					}
				}
				countResults++;
			}
			if(listGetData['logicDiskUsed_Percent']){
				for (let jj = 0; jj < data.length; jj++) {
					let disc = data[jj];
					if(disc.type != undefined){
						let discName = disc.fs.replace(/\W/g, '');
						packet["logicDisk" + discName + "Used_Percent"] = getRoundData(disc.use);
					}
				}
				countResults++;
			}
			if(listGetData['logicDiskFree_Percent']){
				for (let jj = 0; jj < data.length; jj++) {
					let disc = data[jj];
					if(disc.type != undefined){
						let discName = disc.fs.replace(/\W/g, '');
						packet["logicDisk" + discName + "Free_Percent"] = getRoundData(100 - disc.use);
					}
				}
				countResults++;
			}
			sendPacketToServer(packet, countResults);
		});
	}
	if(listGetData['countProcesses'] || listGetData['mostActiveProcesses']){
		si.processes(function(data) {
			if(listGetData['countProcesses']){
				packet.countProceses = data.all;
				countResults++;
			}
			if(listGetData['mostActiveProcesses']){
				for (let jj = 0; jj < data.list.length; jj++) {
					let process = data.list[jj];
					let processName = process.name.replace(/\W/g, '');
					if(process.pcpu >= maxCPUUsed || process.pmem >= maxMEMUsed){
						packet["p_" + processName + "_cpu"] = getRoundData(process.pcpu);
						packet["p_" + processName + "_mem"] = getRoundData(process.pmem);
					}
				}
				countResults++;
			}
			sendPacketToServer(packet, countResults);
		});
	}
	if(listGetData['networkStatsInterface']){
		if(networkInterface != undefined && networkInterface.length > 0){
			si.networkStats(networkInterface, function(data) {
				packet.networkReadSpeed = getRoundData(data[0].rx_sec * 8 / 1024 / 1024);
				packet.networkWriteSpeed = getRoundData(data[0].tx_sec * 8 / 1024 / 1024);
				countResults++;
				sendPacketToServer(packet, countResults);
			});
		}else{
			countResults++;
			sendPacketToServer(packet, countResults);
		}
	}
	if(listGetData['time']) {
		packet.date = parseInt(timePC.current / 1000);
		countResults++;
		sendPacketToServer(packet, countResults);
	}
	if(listGetData['uptimeSeconds']){
		packet.uptimeSeconds = getRoundData(timePC.uptime, 3);
		countResults++;
		sendPacketToServer(packet, countResults);
	}
	if(listGetData['uptimeMinutes']){
		packet.uptimeMinutes = getRoundData(timePC.uptime/60, 3);
		countResults++;
		sendPacketToServer(packet, countResults);
	}
	if(listGetData['uptimeHours']){
		packet.uptimeHours = getRoundData(timePC.uptime/3600, 3);
		countResults++;
		sendPacketToServer(packet, countResults);
	}
	if(listGetData['uptimeDays']){
		packet.uptimeDays = getRoundData(timePC.uptime/86400, 3);
		countResults++;
		sendPacketToServer(packet, countResults);
	}
	if(listGetData['countUsers'] || listGetData['countOnlineUsers']){
		si.users(function(data) {
			if(Array.isArray(data)){
				if(listGetData['countUsers']){
					packet.countUsers = data.length;
					countResults++;
				}
				if(listGetData['countOnlineUsers']){
					packet.countOnlineUsers = data.filter(user => user.tty.length > 0).length;
					countResults++;
				}
			}else{
				packet.countUsers = -1;
				packet.countOnlineUsers = -1;
				countResults++;
			}
			sendPacketToServer(packet, countResults);
		});
	}
	if(listGetData['cpuTemperature']){
		si.cpuTemperature(function(data) {
			packet.temperatureCPU = data.main;
			for (let jj = 0; jj < data.cores.length; jj++) {
				packet["temperatureCore" + jj] = data.cores[jj];
			}
			countResults++;
			sendPacketToServer(packet, countResults);
		});
	}
	if(listGetData['battery']){
		si.battery(function(data) {
			if(data.hasbattery ==  true){
				packet.batIsCharg = (data.ischarging == true) ? 1 : 0;
				packet.batMaxCapacit = data.maxcapacity;
				packet.batCapacit = data.currentcapacity;
				packet.batPercent = data.percent;
				packet.batCycleCount = data.cyclecount;
			}
			countResults++;
			sendPacketToServer(packet, countResults);
		});
	}
}

Данный скрипт будем запускать при старте системы. Для этого добавим запись в cron. Запустим редактор cron:

crontab -e

И в самый конец добавим строку, которая будет запускать скрипт «/var/viziot/VizIoTSystemInfo/index.js»:

@reboot node /var/viziot/VizIoTSystemInfo/index.js > /var/viziot/VizIoTSystemInfo/output.txt &
Добавления виджета:
  1. Создадим новую панель с именем «Информация о ПК»
  2. Добавим виджет «CPU»
    1. тип: «График с областями суммирующий»;
    2. устройство: «VizIoTSystemInfo;
    3. параметры: loadUserCPU, loadSystemCPU;
  3. Добавим виджет «RAM»
    1. тип: «График с областями суммирующий»;
    2. устройство: «VizIoTSystemInfo;
    3. параметры: memRAMUsed_Gb, memRAMFree_Gb;
  4. Добавим виджет «Disk C»
    1. тип: «График с областями суммирующий»;
    2. устройство: «VizIoTSystemInfo;
    3. параметры: logicDiskCUsed_Gb, logicDiskCFree_Gb;
  5. Добавим виджет «Скорость Интернета»
    1. тип: «График с областями»;
    2. устройство: «VizIoTSystemInfo;
    3. параметры: networkReadSpeed, networkWriteSpeed;
  6. Теперь вы все настроили и можете наблюдать за состоянием своего ПК.