Как извлечь данные из функции объекта с цикличным вызовом?

Question

[Mazino]

Я пытаюсь написать скрипт на node.js, который будет обходить некоторое количество устройств по snmp протоколу,
используя для этого библиотеку net-snmp.

var snmp = require('net-snmp');
var sessions; //Объект содержащий объекты созданных snmp сессий через которые будут совершаться запросы
async function getTypes(sessions) {//Устройства есть 2х видов нужно, обойти их, чтобы узнать их тип и что делать дальше
    sessions.forEach(session => {
        session.get([oid], (err,res) => { 
             if(err) throw new Error(err);
             //Какой-то код
        });
    });
}

Я уже пробовал кучу всего, но так и не понял, как мне собрать и передать данные, чтобы

(async () => {
    let type = await getTypes(sessions);//Сюда попал массив с результатами
})();

Answer 1

[Алексей Лауд]

function getSession(session, oid) {
	return new Promise((resolve) => {
		session.get([oid], (err,res) => { 
             if(err) throw new Error(err);
             //Какой-то код
             resolve(/* Результат для сессии */)
        });
	})
}

async function getTypes(sessions) {//Устройства есть 2х видов нужно, обойти их, чтобы узнать их тип и что делать дальше
    const results = [];
    for (session of sessions) { // Избавляемся от функции
    	results.push(await getSession(session, oid));
    }
}

Comments

[Mazino]

Хоть это и не совсем то о чем я спрашивал, ваш пример подал мне идею, надо сказать, что выглядит отвратительно, но работает, спасибо.

var snmp = require('net-snmp');
var mysql = require('mysql');
var config = require('./config.json');
var connection = mysql.createConnection(config.mysql_read);

const options = config.options;
const community = config.community;
const oids = config.oids;

async function getSessionsList() {
        var sessions = [];
	return new Promise((resolve,reject) => {
		connection.query('select `device_ip` from `setup_devices` where `is_enabled` = 1;', (err, data) => {
			if(err) reject(err);
			data.forEach(item => 
				sessions.push(new snmp.createSession(item.device_ip,community,options)));
			resolve(sessions);
		});
	});
}

async function getTypes(sessions) {
	let types = [];
	for (let session of sessions) {
		types.push((() => {
			return new Promise(resolve => {
				session.get([oids.info], (err,res) => {
					if(err) throw new Error(err);
					resolve(res);
				});
			});
		})());
	}
	return Promise.all(types);
}

(async () => {
	let list = await getSessionsList();
	let types = await getTypes(list);
        console.log(types);//Result
})();

[Алексей Лауд]

Mazino,

// Это можно немного упростить
types.push((() => {
  return new Promise(resolve => {
    session.get([oids.info], (err,res) => {
      if(err) throw new Error(err);
      resolve(res);
    });
  });
})());

// Вам не нужно создавать функцию,
// возвращающую промис и сразу вызывать ее
// Достаточно сразу создать промис
types.push(new Promise(resolve => {
	session.get([oids.info], (err,res) => {
	  if(err) throw new Error(err);
	  resolve(res);
	});
}));

[Mazino]

Алексей Казаков, Вы правы, спасибо. Хочу просить, насколько такой вариант приближен к "нормальной практике"?
Может есть вариант еще лучше? Просто сейчас у меня таких сессий 32 и по каждой нужно делать обход в 3 потока, а после собрать из результатов объект и сохранить его в бд, скорость является ключевым параметром, потому, что потом сессий будет больше.

[Алексей Лауд]

Mazino, на всякий случай уточню, что JavaScript однопоточный, поэтому то, что выполняется в асинхронных функциях, все равно выполняется по очереди. Практика использования асинхронности в таком виде вполне нормальная.
В будущем, если понадобится обрабатывать много данных, можно подумать о разбиении работы на отдельные процессы, в Node это достаточно легко сделать.