MongoDB - Errore:comando getMore non riuscito:cursore non trovato

Dopo aver impostato il noCursorTimeout opzione, devi chiudere il cursore manualmente con cursor.close() o esaurendo i risultati del cursore.

Poiché vuoi elaborare tutti i documenti nel cursore, non avresti bisogno di chiuderlo manualmente, ma è comunque possibile che qualcos'altro vada storto nel tuo codice e venga generato un errore prima che tu abbia finito, lasciando così aperto il cursore .

Se vuoi ancora usare questo approccio, usa un try-catch per assicurarti di chiudere il cursore se qualcosa va storto prima di consumare tutti i suoi documenti.

Nota che non la considero una cattiva soluzione (quindi il 👍), in quanto anche pensata sia considerata una cattiva pratica...:

• È una funzionalità supportata dal driver. Se fosse così grave, poiché ci sono modi alternativi per aggirare i problemi di timeout, come spiegato nelle altre soluzioni, questo non sarà supportato.

• Ci sono modi per usarlo in sicurezza, è solo questione di essere più cauti con esso.

• Presumo che tu non stia eseguendo questo tipo di query regolarmente, quindi le possibilità che inizi a lasciare i cursori aperti ovunque sono basse. Se questo non è il caso, e hai davvero bisogno di affrontare queste situazioni tutto il tempo, allora ha senso non usare noCursorTimeout .

3. 👍 Riprova quando il cursore scade

Fondamentalmente, inserisci il tuo codice in un try-catch e quando ricevi l'errore, ottieni un nuovo cursore che salta i documenti che hai già elaborato:

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;
        }
    }
}

Nota che devi ordinare i risultati affinché questa soluzione funzioni.

Con questo approccio, riduci al minimo il numero di richieste al server utilizzando la dimensione batch massima possibile di 16 MB, senza dover indovinare quanti documenti sarai in grado di elaborare in 10 minuti in anticipo. Pertanto, è anche più robusto dell'approccio precedente.

4. 👎 Interroga manualmente i risultati in batch

Fondamentalmente, usi skip(), limit() e sort() per eseguire più query con un numero di documenti che pensi di poter elaborare in 10 minuti.

Considero questa una cattiva soluzione perché il conducente ha già la possibilità di impostare la dimensione del batch, quindi non c'è motivo di farlo manualmente, basta usare la soluzione 1 e non reinventare la ruota.

Inoltre, vale la pena ricordare che presenta gli stessi inconvenienti della soluzione 1,

5. 👎 Ottieni tutti i documenti prima della scadenza del cursore

Probabilmente il tuo codice sta impiegando del tempo per essere eseguito a causa dell'elaborazione dei risultati, quindi potresti prima recuperare tutti i documenti e poi elaborarli:

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

Questo recupererà tutti i batch uno dopo l'altro e chiuderà il cursore. Quindi, puoi scorrere tutti i documenti all'interno di results e fai quello che devi fare.

Tuttavia, se riscontri problemi di timeout, è probabile che il tuo set di risultati sia piuttosto grande, quindi estrarre tutto in memoria potrebbe non essere la cosa più consigliabile da fare.

Nota sulla modalità snapshot e sui documenti duplicati

È possibile che alcuni documenti vengano restituiti più volte se le operazioni di scrittura intermedie li spostano a causa dell'aumento delle dimensioni del documento. Per risolvere questo problema, usa cursor.snapshot() . Dai documenti: