Node.js ЗАПРОС броска ECONNREFUSED после нескольких попыток - PullRequest
Новая
       41

Node.js ЗАПРОС броска ECONNREFUSED после нескольких попыток

0 голосов
/ 25 января 2019

Я использую следующий код: 

async function validateMOData(data, callback) {
    success('Validation started');
    let a = 0;
    let i = data.length;
    console.log('length of array', i);
    while (i--) {
        a = a + 1;
        console.log('Loop Count', a);
        console.log(data[i]);
        let result;
        try {
            result = await checkValidity(data[i]);
            if ((JSON.parse(result.body)).isValid === false) {
                createErrorLog(data[i].MemberId, data[i].MemberAgreementId, (JSON.parse(result.body)).responseMessage, (JSON.parse(result.body)).responseCode, 'x', data[i].CsvFileName)
                deleteFaultyData(data[i].Id);
                data.splice(i, 1);
            }
        } catch (err) {
            console.log(err);
        }
    }
    success('validation ended');
    callback(data);
}
function checkValidity(record) {
    return new Promise((resolve, reject) => {
        let validityCheckUrl = `${constants.USER_INTERFACE.SERVER_URL_PREFIX}validateMemberData/?memberId=${record.MemberId}&memberAgreementId=${record.MemberAgreementId}`;
        request({ url: validityCheckUrl, pool: { maxSockets: 10 } }, (error, response, body) => {
            if (error) {
                reject(error);
            } else {
                resolve(response, body);
            }
        });
    });

}

После нескольких итераций в цикле while метод checkValidity начинает выдавать следующую ошибку: 

{ Error: connect ECONNREFUSED IP:port
at Object._errnoException (util.js:1022:11)
at _exceptionWithHostPort (util.js:1044:20)
at TCPConnectWrap.afterConnect [as oncomplete] (net.js:1198:14)
code: 'ECONNREFUSED',
errno: 'ECONNREFUSED',
syscall: 'connect',
address: 'IP',
port: port }

Эта ошибка возникает не в первом запросе, а после нескольких запросов. Кто-нибудь может помочь? Я что-то пропустил?

NOte : этот код запускается на AWS lambda, и checkValidity подключается к серверу Node.js, развернутому в EC2

1 Ответ

0 голосов
/ 25 января 2019

То, что я думаю, это то, что вы не поместили чек, чтобы проверить, что i в отрицательном или в простых словах, нет условия разрыва здесь внутри try 

try {
      ***********************
        result = await checkValidity(data[i]);
        if ((JSON.parse(result.body)).isValid === false) {
            createErrorLog(data[i].MemberId, data[i].MemberAgreementId, (JSON.parse(result.body)).responseMessage, (JSON.parse(result.body)).responseCode, 'x', data[i].CsvFileName)
            deleteFaultyData(data[i].Id);
            data.splice(i, 1);
        }
    } catch (err) {
        console.log(err);
    }

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

...