Как контролировать производительность приложений на базе Neo4j с Ruxit

За последние несколько лет Neo4j стал стандартом для эффективного моделирования графических данных.

Кроме того, использование Node.js в построении гибкой сервисной инфраструктуры поверх графовых баз данных Neo4j и обслуживании необходимых HTML и статических ресурсов позволяет разработчикам создавать великолепные приложения.

Как и в случае с другими технологиями, модель данных и дизайн сервиса предопределяют, насколько хорошо ваше приложение работает в производстве. Но что, если вы уже запускаете приложение в работе и понимаете, что в некоторых случаях оно работает медленно?

Если ваше приложение состоит из десятков различных сервисных вызовов, разбросанных по множеству HTML и асинхронных элементов JavaScript, то такие узкие места производительности чрезвычайно трудно найти.

В этой статье я объясню, как отслеживать пример приложения Node.js, используя базовую модель данных графа, находящуюся в базе данных Neo4j, в режиме реального времени.

Пример мониторинга производительности приложения Neo4j

В качестве первого шага мы автоматически обнаружим служебные зависимости в вашем приложении. После этого мы сможем отслеживать загрузку каждой из ваших служб и время отклика ваших приложений и запросов на обслуживание.

Наш пример приложения визуализирует топологию приложений, как показано в следующем запросе Neo4j Cypher .

Чтобы визуализировать этот график в рамках нашего приложения Node.js для общественной аудитории, мы определили несколько услуг ( apprelations,  hostrelationsи  apps) , которые возвращают узлы приложения и хоста в виде JSON полезных нагрузок.

В этом примере импортируется экспресс-инфраструктура, которая обслуживает статическое содержимое, например HTML-страницу,  appgraph.html которая отображает результат с помощью JavaScript.

var neo4j = require('node-neo4j');
var express = require('express');
var app = express();

app.use(express.static('public'));

app.get('/apprelations', function (req, res) {
db = new neo4j('http://127.0.0.1:7474');
db.cypherQuery("MATCH (n:APPLICATION)-[r]-b RETURN n,b", function(err, result){
if(err) throw err;
// some processing
var rdata = { 'nodes': nodes, 'edges': edges};
res.send(rdata);
});
});

app.get('/hostrelations', function (req, res) {
db = new neo4j('http://127.0.0.1:7474');
db.cypherQuery("MATCH (n:HOST)-[r]-b RETURN n,b", function(err, result){
if(err) throw err;
// some processing
var rdata = { 'nodes': nodes, 'edges': edges};
res.send(rdata);
});
});

app.get('/apps', function (req, res) {
db = new neo4j('http://127.0.0.1:7474');
db.cypherQuery("MATCH (n:APPLICATION) RETURN n", function(err, result){
if(err) throw err;
// some processing
var rdata = { 'nodes': nodes, 'edges': []};
res.send(rdata);
});
});

var server = app.listen(8080, function () {
  var host = server.address().address;
  var port = server.address().port;
  console.log('Example app listening at http://%s:%s', host, port);
});