krrrr38/koa_pm2_prometheus.js

## koa_pm2_prometheus.js
var http = require('http');
var Koa = require('koa');
var Router = require('koa-router');

var app = new Koa();
var router = new Router();

const instanceId = parseInt(process.env.NODE_APP_INSTANCE || 0);
const client = require('prom-client');
client.collectDefaultMetrics();
client.register.setDefaultLabels({ instanceId: instanceId });

const appRequestSummary = new client.Summary({
  name: 'app_request',
  help: 'app_request',
  labelNames: ['method', 'name', 'type'],
  percentiles: [0.5, 0.75, 0.90, 0.95, 0.99, 1.0]
});

app.use(async (ctx, next) => {
  const start = Date.now();
  await next().then(data => {
    const ms = Date.now() - start;
    const routeName = ctx._matchedRouteName || 'unknown';
    appRequestSummary.labels(ctx.method, routeName, 'success').observe(ms);
  }).catch(err => {
    const ms = Date.now() - start;
    const routeName = ctx._matchedRouteName || 'unknown';
    appRequestSummary.labels(ctx.method, routeName, 'failure').observe(ms);
    throw err;
  });
});

router.get('index', '/', (ctx, next) => {
  ctx.body = 'Hello Koa';
});
router.get('fail', '/fail', (ctx, next) => {
  throw new Error("errorrrrrr");
});
// router.get('metrics', '/metrics', (ctx, next) => {
//   ctx.set('Content-Type', client.register.contentType);
//   ctx.body = client.register.metrics();
// });

app
    .use(router.routes())
    .use(router.allowedMethods());

const metricsPort = 9010 + instanceId;
console.log("start server: 3000, metrics server: " + metricsPort);

http.createServer((req, res) => {
  res.setHeader('Content-Type', client.register.contentType);
  res.write(client.register.metrics());
  res.end();
}).listen(metricsPort);
app.listen(3000);
	var http = require('http');
	var Koa = require('koa');
	var Router = require('koa-router');

	var app = new Koa();
	var router = new Router();

	const instanceId = parseInt(process.env.NODE_APP_INSTANCE \|\| 0);
	const client = require('prom-client');
	client.collectDefaultMetrics();
	client.register.setDefaultLabels({ instanceId: instanceId });

	const appRequestSummary = new client.Summary({
	name: 'app_request',
	help: 'app_request',
	labelNames: ['method', 'name', 'type'],
	percentiles: [0.5, 0.75, 0.90, 0.95, 0.99, 1.0]
	});

	app.use(async (ctx, next) => {
	const start = Date.now();
	await next().then(data => {
	const ms = Date.now() - start;
	const routeName = ctx._matchedRouteName \|\| 'unknown';
	appRequestSummary.labels(ctx.method, routeName, 'success').observe(ms);
	}).catch(err => {
	const ms = Date.now() - start;
	const routeName = ctx._matchedRouteName \|\| 'unknown';
	appRequestSummary.labels(ctx.method, routeName, 'failure').observe(ms);
	throw err;
	});
	});

	router.get('index', '/', (ctx, next) => {
	ctx.body = 'Hello Koa';
	});
	router.get('fail', '/fail', (ctx, next) => {
	throw new Error("errorrrrrr");
	});
	// router.get('metrics', '/metrics', (ctx, next) => {
	// ctx.set('Content-Type', client.register.contentType);
	// ctx.body = client.register.metrics();
	// });

	app
	.use(router.routes())
	.use(router.allowedMethods());

	const metricsPort = 9010 + instanceId;
	console.log("start server: 3000, metrics server: " + metricsPort);

	http.createServer((req, res) => {
	res.setHeader('Content-Type', client.register.contentType);
	res.write(client.register.metrics());
	res.end();
	}).listen(metricsPort);
	app.listen(3000);