'use strict';
const Bluebird = require('bluebird');
/* Тут какой-то Ваш код */
Bluebird.map(items, async function(url) {
try {
const response = await fetch(url);
if (response.status === 200) {
const buffer = await response.buffer();
/* Что-то делаете с буффером */
}
await Bluebird.delay(1000); // Можно добавить задержку после каждого успешного запроса
} catch(err) {
console.error(err);
}
}, {
concurrency: 3 // Указываете во сколько потоков выполнять запросы
}).catch(console.error);
'use strict';
const { MongoClient } = require('mongodb');
const client = new MongoClient('mongodb://localhost:27017/');
(async function() {
await client.connect();
const result = await client.db('world').collection('cyti').find().toArray();
console.log('City:', result);
})().catch(console.error);
export const sendHttpRequest = async (id: string, token: string) => {
try {
await getProductId(id, token);
return getContractData(id, token);
}
catch (e) {
console.error(e.message);
throw e;
}
};
async function getProductId(id, token) {
try {
const variables = {};
const options = {};
const req = await fetch(url, options);
const res = await req.json();
if (res.data.entityObject.Produkt) {
idProduct = res.data.entityObject.Produkt.ID;
} else {
throw new Error('Some error ...');
// Или же: return Promise.reject(new Error('Some error ...'));
}
}
catch (e) {
console.error(e.message);
throw e;
}
}