node.js - node - socket.io example

la mejor práctica para la sincronización de datos en nodejs

Question

Estoy tratando de hacer algo de integración entre dos sistemas, y tengo algunos problemas cuando se trata de sincronizar datos.

Estoy usando nodejs y la base de datos es mongodb o firebase .

El escenario se describe a continuación:

• systemA con dbA
• systemB con dbB

Haz lo siguiente:

1. systemA envía una solicitud (POST o PUT lo que sea) al sistemaB, el body es así:

   { ..... fieldA1: valueA1, fieldA2: valueA2 ..... }

2. entonces el sistemaB necesita actualizar varios campos (campoB1, campoB2) en dbB de acuerdo con los datos del sistema A, como este:

   fieldB1: valueA1

   fieldB2: valueA2

3. después de que se fieldB1 actualizado con éxito tanto fieldB1 como fieldB2 , ejecute más lógica

Estoy usando async para controlar el proceso asincrónico. Mi código para implementar estos 3 pasos:

async.waterfall([
  function (callback) {
    //get valueA1 of fieldA1 and valueA2 of fieldA2
  },

  async.parallel([
    function (callback) {
      //set valueA1 to fieldB1
    },

    function (callback) {
      //set valueA2 to fieldB2
    }
  ], function (err, result) {
      //more logic here
  })
], function (err, result) {
  //more logic here
})

Dado que fieldB1 y fieldB2 deben actualizarse al mismo tiempo , cualquier situación al no actualizar fieldB1 o fieldB2 dará lugar a inconsistencia de datos, que no es el resultado correcto.

Sin embargo, async.parallel no puede garantizar que cualquier falla de actualización revertirá o evitará que la actualización de los demás sea correcta. ¿Hay alguna forma de mantener idealmente la coherencia de los datos de AMBOS cuando se actualizan fieldB1 y fieldB2 ?

Answer 1

Me resulta difícil mapear tu código a la API de Firebase. Pero lo que está describiendo parece que se puede lograr al usar transacciones o actualizaciones de ubicaciones múltiples .

Cubrí este tipo de actualizaciones en profundidad en el pasado en: Cómo escribir datos desnormalizados en Firebase