Как справиться с асинхронностью в Nodejs?

У меня есть случай, когда у меня есть много данных, которые мне нужно отсортировать по разным сегментам. Если уже существует корзина для определенного типа данных, вставьте ее туда, но если обнаруженный тип данных новый, мне нужно создать для него новую корзину, которая требует запроса БД. Теоретически это работает нормально. Но у меня проблема в том, что запросы к БД должны выполняться до продолжения цикла, чтобы будущие данные можно было вставить в это ведро. Как я могу приостановить цикл до завершения функции?

Я пробовал цикл и подход обратного вызова, и я получаю поток управления, который ищу, но данные слишком велики, и я переполняю стек. Есть ли другой способ решить эту проблему?

Обновлено: добавлен код с обещаниями, как предлагали люди. На самом деле он работает хорошо, но просто останавливается на точке данных 8428. Насколько я могу судить, эта точка данных не является особенной, и все сегменты были созданы в этот момент, поэтому новый сегмент не создается. Это просто останавливается. Любые идеи? Может быть, это как я звоню next (), и мне не хватает дела?

async function sortData(data, images, i) {
    let uuidList = [];
    //This loop will wait for each next() to pass the next iteration
    for (var j = 0; j < data.length; ++j) { 
        await new Promise(next=> {
            let pos = uuidList.map(function(e) { return e.uuid; }).indexOf(data[j].uuid);
            if (pos < 0){
                Instance_Type.findInstance(data[j]._instance_type, function(err, instance){
                    /* add new bucket here */
                    if (itemsProcessed == images.length) {
                        processBuckets(uuidList, threshold, function(){
                            console.info("Bucket finished");
                            dataPackage.push({
                                imageName: images[i].name,
                                uuidList: uuidList,
                            });
                            ++itemsProcessed;
                            if (itemsProcessed == images.length){
                                console.info("Rendering!");
                                res.render('data', {
                                    dataPackage: dataPackage
                                });
                            }
                        });
                    }
                    next();
                });
            } else {
                /*push to existing bucket here*/
                if (itemsProcessed == images.length) {
                    processBuckets(uuidList, threshold, function(){
                        console.info("Bucket finished");
                        dataPackage.push({
                            imageName: images[i].name,
                            uuidList: uuidList,
                        });
                        ++itemsProcessed;
                        console.info(itemsProcessed);
                        if (itemsProcessed == images.length){
                            console.info("Rendering!");
                            res.render('data', {
                                dataPackage: dataPackage
                            });
                        }
                    });
                }
                next();
            }

        })       
    }
}