Wie führe ich eine atomare benutzerdefinierte Aktualisierung eines Mongodb-Dokuments durch?

Question

Ich bin mir bewusst, dass MongoDB kann atomare Updates mit findOneAndModify tun, aber dies erlaubt nur grundlegende Operationen wie Set oder Inkrement.

Was ich brauche, ist eine benutzerdefinierte Funktion anzuwenden mein Dokument zu transformieren:

const updateDoc = async (event) => { 
    const oldState = await db.collection(collectionName).findOne({ name }); 
    const newState = customFunction(oldState, event); 
    await db.collection(collectionName).replaceOne({ name }, newState); 
} 

Diese Funktion wird durch ein System aufgerufen werden, die für einen aufgelösten Versprechen warten nicht weiter zu arbeiten: es können mehrere sein synchrone Anrufe.

Gibt es eine Möglichkeit updateDoc neu zu schreiben, um es atomar zu machen, so dass, wenn wir das tun:

updateDoc(event1); // note the absence of await 
updateDoc(event2); 

Wir können sicher sein, dass die gespeicherte doc customFunction(customFunction(initState, event1), event2) sein wird?

Dank

Answer 1

Eine mögliche Lösung wäre eine Aufgabe Warteschlange sein, dass ein Update nach dem anderen shedules:

class Scheduler { 
    constructor(){ 
    this.running = false; 
    this.queue = []; 
    } 

    add(el){ 
    this.queue.push(el); 
    if(!this.running) this.run(); 
    } 

    async run(){ 
    this.running = true; 
    while(this.queue.length) await this.queue.shift(); 
    this.running = false; 
} 
} 

Verwendbar wie folgt aus:

const dbTasks = new Sheduler(); 

const updateDoc = async (event) => dbTasks.add(_ => { 
    const oldState = await db.collection(collectionName).findOne({ name }); 
    const newState = customFunction(oldState, event); 
    await db.collection(collectionName).replaceOne({ name }, newState); 
}); 

updateDoc(evt1); 
updateDoc(evt2);