Size: a a a
ВС
ВС
1
ВС
1
MD
ro
MD
MD
I
¿
I
GS
const https = require('https');
const source = 'https://www1.nyc.gov/assets/planning/download/zip/data-maps/open-data/nyc_pluto_19v2_csv.zip';
const consoleMemory = () => {
const m = process.memoryUsage();
for (const key of Reflect.ownKeys(m)) {
m[key] = ~~(m[key] / 1024 / 1024);
}
console.log(m);
}
const getDataStream = () => {
return new Promise((resolve) => {
https.get(source, resolve);
});
}
const main = () => new Promise(async (resolve) => {
const dataStream = await getDataStream();
let c = 0;
dataStream.on('data', (data) => {
c++;
if (c % 1000) return;
consoleMemory();
});
dataStream.on('end', resolve);
});
(async () => {
consoleMemory();
await main();
await new Promise(res => setTimeout(res, 5000));
consoleMemory();
})();R
const https = require('https');
const source = 'https://www1.nyc.gov/assets/planning/download/zip/data-maps/open-data/nyc_pluto_19v2_csv.zip';
const consoleMemory = () => {
const m = process.memoryUsage();
for (const key of Reflect.ownKeys(m)) {
m[key] = ~~(m[key] / 1024 / 1024);
}
console.log(m);
}
const getDataStream = () => {
return new Promise((resolve) => {
https.get(source, resolve);
});
}
const main = () => new Promise(async (resolve) => {
const dataStream = await getDataStream();
let c = 0;
dataStream.on('data', (data) => {
c++;
if (c % 1000) return;
consoleMemory();
});
dataStream.on('end', resolve);
});
(async () => {
consoleMemory();
await main();
await new Promise(res => setTimeout(res, 5000));
consoleMemory();
})();{ rss: 18, heapTotal: 4, heapUsed: 2, external: 1 }
{ rss: 35, heapTotal: 7, heapUsed: 4, external: 9 }
{ rss: 29, heapTotal: 8, heapUsed: 3, external: 2 }
{ rss: 42, heapTotal: 8, heapUsed: 3, external: 14 }
{ rss: 26, heapTotal: 4, heapUsed: 2, external: 1 }
{ rss: 38, heapTotal: 4, heapUsed: 2, external: 13 }
{ rss: 52, heapTotal: 4, heapUsed: 3, external: 26 }
{ rss: 36, heapTotal: 4, heapUsed: 2, external: 11 }
{ rss: 50, heapTotal: 4, heapUsed: 3, external: 24 }
{ rss: 34, heapTotal: 4, heapUsed: 2, external: 9 }
{ rss: 48, heapTotal: 4, heapUsed: 3, external: 22 }
{ rss: 32, heapTotal: 4, heapUsed: 2, external: 7 }R
const https = require('https');
const source = 'https://www1.nyc.gov/assets/planning/download/zip/data-maps/open-data/nyc_pluto_19v2_csv.zip';
const consoleMemory = () => {
const m = process.memoryUsage();
for (const key of Reflect.ownKeys(m)) {
m[key] = ~~(m[key] / 1024 / 1024);
}
console.log(m);
}
const getDataStream = () => {
return new Promise((resolve) => {
https.get(source, resolve);
});
}
const main = () => new Promise(async (resolve) => {
const dataStream = await getDataStream();
let c = 0;
dataStream.on('data', (data) => {
c++;
if (c % 1000) return;
consoleMemory();
});
dataStream.on('end', resolve);
});
(async () => {
consoleMemory();
await main();
await new Promise(res => setTimeout(res, 5000));
consoleMemory();
})();GS
MD
{ rss: 19, heapTotal: 5, heapUsed: 2, external: 1 }
{ rss: 39, heapTotal: 8, heapUsed: 4, external: 10 }
{ rss: 49, heapTotal: 8, heapUsed: 3, external: 6 }
{ rss: 49, heapTotal: 8, heapUsed: 4, external: 18 }
{ rss: 62, heapTotal: 8, heapUsed: 4, external: 30 }
{ rss: 75, heapTotal: 8, heapUsed: 5, external: 43 }
{ rss: 68, heapTotal: 4, heapUsed: 2, external: 4 }
{ rss: 67, heapTotal: 4, heapUsed: 3, external: 10 }
{ rss: 74, heapTotal: 4, heapUsed: 3, external: 22 }
{ rss: 76, heapTotal: 4, heapUsed: 2, external: 8 }
{ rss: 76, heapTotal: 4, heapUsed: 3, external: 20 }
{ rss: 76, heapTotal: 4, heapUsed: 2, external: 7 }
{ rss: 76, heapTotal: 4, heapUsed: 3, external: 13 }GS
АП
const https = require('https');
const source = 'https://www1.nyc.gov/assets/planning/download/zip/data-maps/open-data/nyc_pluto_19v2_csv.zip';
const consoleMemory = () => {
const m = process.memoryUsage();
for (const key of Reflect.ownKeys(m)) {
m[key] = ~~(m[key] / 1024 / 1024);
}
console.log(m);
}
const getDataStream = () => {
return new Promise((resolve) => {
https.get(source, resolve);
});
}
const main = () => new Promise(async (resolve) => {
const dataStream = await getDataStream();
let c = 0;
dataStream.on('data', (data) => {
c++;
if (c % 1000) return;
consoleMemory();
});
dataStream.on('end', resolve);
});
(async () => {
consoleMemory();
await main();
await new Promise(res => setTimeout(res, 5000));
consoleMemory();
})();