Wie handhabe ich den asynchronen Datenabruf innerhalb einer Schleife in MongoDB?

Aufgetretenes Problem: Asynchroner Datenabruf innerhalb einer Schleife

Im angegebenen Code wird versucht, Daten aus mehreren MongoDB-Abfragen innerhalb einer Schleife abzurufen und die Ergebnisse zusammenzustellen in ein einzelnes Datenarray. Beim Versuch, diese Daten als Antwort zurückzugeben, tritt jedoch ein Problem auf.

Ursache des Problems

Das Problem ergibt sich aus der asynchronen Natur von MongoDB-Abfragen. Wenn eine Abfrage ausgeführt wird, gibt die Funktion nicht sofort das Ergebnis zurück, sondern initiiert stattdessen die Aufgabe und kehrt sofort zurück. Aus diesem Grund wird finalData, das die aggregierten Ergebnisse speichern soll, als undefiniert zurückgegeben: Die Funktion wird beendet, bevor die Abfragen abgeschlossen sind und ihre Daten sammeln.

Lösung: Embracing Promises

Um dieses Problem zu beheben, Wir müssen Versprechen nutzen, die die asynchrone Programmierung erleichtern, indem sie eine strukturierte Möglichkeit bieten, den Fluss asynchroner Aufgaben zu bewältigen. Mit Versprechen können wir eine Funktion definieren, die ausgeführt wird, wenn die asynchrone Aufgabe abgeschlossen ist.

Versprechen implementieren

So implementieren Sie Versprechen:

1. Identifizieren Sie asynchrone Funktionen : Bestimmen Sie, welche Funktionen im Code asynchron sind, da sie in Versprechen verpackt werden müssen. In diesem Fall sind der forEach-Rückruf und Prayer.find asynchron.
2. Asynchrone Funktionen umschließen: Erstellen Sie für Funktionen, die keine Versprechen nativ zurückgeben, Wrapper, die dies tun. In diesem Fall verwenden wir Q.nbind, um Prayer.find in eine Versprechen-zurückgebende Funktion zu verpacken.
3. Rückruffunktionen verketten: Verwenden Sie .then, um Rückruffunktionen zu verketten, die ausgeführt werden, wenn die Versprechen ist gelöst. Führen Sie in der Rückruffunktion alle erforderlichen Vorgänge aus und geben Sie das Ergebnis zurück.

Endgültige Lösung

Unter Berücksichtigung dieser Konzepte lautet die modifizierte getPrayerInCat-Funktion wie folgt:

function getPrayerInCat(data) {
    var promises = data.map(function(data2) {
        var id = data2.id;
        return find({ prayerCat: id })
            .then(function(prayer) {
                if (!prayer)
                    data2.prayersCount = 0;
                else
                    data2.prayersCount = prayer.length;
                return data2;
            });
    });
    return Q.all(promises);
}

Das obige ist der detaillierte Inhalt vonWie handhabe ich den asynchronen Datenabruf innerhalb einer Schleife in MongoDB?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!