MongoDB - Fout:opdracht getMore mislukt:cursor niet gevonden

Na het instellen van de noCursorTimeout optie, moet u ofwel de cursor handmatig sluiten met cursor.close() of door de resultaten van de cursor uit te putten.

Omdat u alle documenten in de cursor wilt verwerken, hoeft u deze niet handmatig te sluiten, maar het is nog steeds mogelijk dat er iets anders misgaat in uw code en er een fout wordt gegenereerd voordat u klaar bent, waardoor de cursor open blijft .

Als je deze aanpak toch wilt gebruiken, gebruik dan een try-catch om ervoor te zorgen dat u de cursor sluit als er iets misgaat voordat u alle documenten gebruikt.

Opmerking Ik beschouw dit niet als een slechte oplossing (daarom de 👍), omdat het zelfs als een slechte gewoonte wordt beschouwd...:

• Het is een functie die door de bestuurder wordt ondersteund. Als het zo erg was, omdat er alternatieve manieren zijn om time-outproblemen te omzeilen, zoals uitgelegd in de andere oplossingen, wordt dit niet ondersteund.

• Er zijn manieren om het veilig te gebruiken, het is alleen een kwestie van extra voorzichtig zijn.

• Ik neem aan dat je dit soort zoekopdrachten niet regelmatig uitvoert, dus de kans dat je overal cursors open laat staan, is klein. Als dit niet het geval is, en je moet echt altijd met deze situaties omgaan, dan is het logisch om noCursorTimeout niet te gebruiken. .

3. 👍 Probeer het opnieuw wanneer de cursor verloopt

Kortom, u plaatst uw code in een try-catch en wanneer je de foutmelding krijgt, krijg je een nieuwe cursor die de documenten overslaat die je al hebt verwerkt:

let processed = 0;
let updated = 0;

while(true) {
    const cursor = db.snapshots.find().sort({ _id: 1 }).skip(processed);

    try {
        while (cursor.hasNext()) {
            const doc = cursor.next();

            ++processed;

            if (doc.stream && doc.roundedDate && !doc.sid) {
                db.snapshots.update({
                    _id: doc._id
                }, { $set: {
                    sid: `${ doc.stream.valueOf() }-${ doc.roundedDate }`
                }});

                ++updated;
            } 
        }

        break; // Done processing all, exit outer loop
    } catch (err) {
        if (err.code !== 43) {
            // Something else than a timeout went wrong. Abort loop.

            throw err;
        }
    }
}

Merk op dat u de resultaten moet sorteren om deze oplossing te laten werken.

Met deze aanpak minimaliseert u het aantal verzoeken aan de server door de maximaal mogelijke batchgrootte van 16 MB te gebruiken, zonder dat u van tevoren hoeft te raden hoeveel documenten u in 10 minuten kunt verwerken. Daarom is het ook robuuster dan de vorige aanpak.

4. 👎 De resultaten in batches handmatig opvragen

In principe gebruik je skip(), limit() en sort() om meerdere zoekopdrachten uit te voeren met een aantal documenten waarvan je denkt dat je ze in 10 minuten kunt verwerken.

Ik beschouw dit als een slechte oplossing omdat de bestuurder al de mogelijkheid heeft om de batchgrootte in te stellen, dus er is geen reden om dit handmatig te doen, gebruik gewoon oplossing 1 en vind het wiel niet opnieuw uit.

Het is ook vermeldenswaard dat het dezelfde nadelen heeft als oplossing 1,

5. 👎 Verkrijg alle documenten voordat de cursor verloopt

Waarschijnlijk duurt het even voordat uw code is uitgevoerd vanwege de verwerking van de resultaten, dus u kunt eerst alle documenten ophalen en ze vervolgens verwerken:

const results = new Array(db.snapshots.find());

Hiermee worden alle batches één voor één opgehaald en wordt de cursor gesloten. Vervolgens kunt u door alle documenten in results bladeren en doe wat je moet doen.

Als je echter time-outproblemen hebt, is de kans groot dat je resultatenset vrij groot is, dus het is misschien niet het meest aan te raden om alles in het geheugen te halen.

Opmerking over snapshot-modus en dubbele documenten

Het is mogelijk dat sommige documenten meerdere keren worden geretourneerd als tussenliggende schrijfbewerkingen ze verplaatsen vanwege een toename in documentgrootte. Om dit op te lossen, gebruikt u cursor.snapshot() . Uit de documenten: