Помощь в архитектуре репликации при использовании ArangoDB

Первоначальная мысль об этом:

Вы можете обернуть операции вставки / обновления / удаления в определенную коллекцию (коллекции) в собственном API. Вместо использования обычных маршрутов HTTP POST, PUT / PATCH, DELETE, которые ArangoDB предоставляет для документов, вы можете писать свои собственные маршруты внутри ArangoDB. Для этого у ArangoDB есть фреймворк Foxx.

Например, вы можете создать свой собственный маршрут вставки. Внутри маршрута вы можете выполнить любой код JavaScript. Например, вот простая оболочка вставки, которая по ширине вставляет данные в коллекцию mydata:

controller.post('/my-insert', function (req, res) {
  var document = req.body();

  try {
    var result = db.mydata.save(doc);
    // TODO: send off data to external server etc.

    res.json(result); // send back result to original client
  }
  catch (err) {
    // TODO: handle and report error
  }
});

В приведенном выше примере данные хранятся в локальной коллекции, а ответ отправляется обратно клиенту. Однако вы можете выполнить дополнительный код JavaScript после операции сохранения. Таким образом, вы можете отправлять данные на другой сервер оттуда.

Вы можете сделать то же самое для обновления и удаления маршрутов. Это решение требует, чтобы все ваши операции использовали настраиваемые маршруты, и вы не изменяете данные с помощью обычных API-интерфейсов документов. Использование обычных API-интерфейсов, конечно, по-прежнему будет работать, но не приведет к срабатыванию настраиваемых действий.

Интересные вопросы заключаются в том, можете ли вы принять блокировку потока при «отправке на другой серверный вызов» и что вы будете делать, если отправка данных на другой сервер не удалась по какой-либо причине.