¿
А если без фреймворков, то как вытащить буфер файла из запроса?Везде одни примеры на экспресе и какой то библиотеке для мультипарт запросов.
Size: a a a
2020 February 26
NS
Кто работал с Moleculer, можно в двух словах о нем, подводные камни и тп. Ничего плохого нагуглить не могу 🤔
ПА
for (const file of files) {
await processFile(folder, file).catch(err => {
console.error(err.message);
process.exit(-1);
});
}
подскажите, как перебрать циклом files дожидаясь выполнения processFileПА
пробовал for await (...) тоже не то, он не ждет, просто перебирает files и запускает processFile ну и конечно нода падает по утечке памяти. Я заменил processFile сделал там setTimeout с возвращением resolve() через 5 секунд, сразу увидел, что for цикл не ждет await
NS
Попов Алексей
пробовал for await (...) тоже не то, он не ждет, просто перебирает files и запускает processFile ну и конечно нода падает по утечке памяти. Я заменил processFile сделал там setTimeout с возвращением resolve() через 5 секунд, сразу увидел, что for цикл не ждет await
странно, а если .кетч на трай кетч поменять?
ПА
странно, а если .кетч на трай кетч поменять?
Хмм... а не это у меня косяк.....
BB
А что это за функция processFile?
ПА
А что это за функция processFile?
const processFile = async (folder, file) => {
return new Promise((resolve, reject) => {
const input = fs.createReadStream(path.join(folder, file), { encoding : 'utf8' });
const rl = readline.createInterface({input});
rl.on('line', async line => await processData(line));
rl.on('error', _ => err => reject(new Error(err)));
rl.on('close', _ => resolve());
});
};ПА
т.е. мне надо, чтобы отрабатывалось каждый rl.on('line', async line => await processData(line)); и после того как все строки обработались, функция rl.on('close', _ => resolve()); отдала и for продолжил цикл, а так получается, что processFile сразу резолвит
ПА
пробовал
rl.on('line', async line => {
rl.pause();
await processData(line);
rl.resume();
});
но чет не помогает
rl.on('line', async line => {
rl.pause();
await processData(line);
rl.resume();
});
но чет не помогает
ПА
const processData = async (line) => {
return new Promise(async (resolve, reject) => {
console.log('bar');
setTimeout(()=>{
resolve();
}, 3000);
});
};
const processFile = async (folder, file) => {
return new Promise((resolve, reject) => {
const input = fs.createReadStream(path.join(folder, file), { encoding : 'utf8' });
const rl = readline.createInterface({input});
rl.on('line', async line => {
rl.pause();
await processData(line);
rl.resume();
});
rl.on('error', _ => err => reject(new Error(err)));
rl.on('close', _ => resolve());
});
};будет хреначить в консоле bar не дожиаясь таймаута и resolve()
ПА
rl.on('line', async line => {
rl.pause();
setTimeout(_=>{
console.log(line);
rl.resume();
}, 1000);
});
вообще сразу выводит line не ждет 1сек
rl.pause();
setTimeout(_=>{
console.log(line);
rl.resume();
}, 1000);
});
вообще сразу выводит line не ждет 1сек
ПА
Как построчно в потоке читать файл (файл очень огромный), каждая строка обрабатывается (куча регулярок и т.д.) после чего выполняет процедуру из sql и после этого метод должен получить следующую строку. Естественно он мне сейчас в processData(line) хреначит все строки, там метод не успевает все сделать и короче все падает в утечке памяти
S🛸
Попов Алексей
const processFile = async (folder, file) => {
return new Promise((resolve, reject) => {
const input = fs.createReadStream(path.join(folder, file), { encoding : 'utf8' });
const rl = readline.createInterface({input});
rl.on('line', async line => await processData(line));
rl.on('error', _ => err => reject(new Error(err)));
rl.on('close', _ => resolve());
});
};Зачем async функция возращается промис
ПА
Зачем async функция возращается промис
чтобы по завершению считывания она делала resolve
ПА
Зачем async функция возращается промис
это ведь асинхроная операция
S🛸
Попов Алексей
чтобы по завершению считывания она делала resolve
Зачем делать resolve?
ПА
Зачем делать resolve?
так у меня ведь в for вызывается она
S🛸
Почему бы не сделать await?
ПА
Почему бы не сделать await?
так я так и сделал