node mysql processlist

watcher.js

process.on('uncaughtException', function (err) {
	console.error(err.stack);
	process.exit(1);
})

var Promise = require("bluebird");

var knex = require('knex')({
	client: 'mysql',
	connection: {
		host     : 'example.org',
		user     : 'some_user',
		password : 'some_pass',
		database : 'some_db',
		charset  : 'utf8'
	}
});


function log_processlist() {
	knex.raw('SHOW FULL PROCESSLIST').spread(function(processlist) {
		return processlist;
	}).map(function(item) {
		return {
//			id: item.Id,
			time: item.Time,
			state: item.State,
			command: item.Command,
			db: item.db,
			info: item.Info,
		};
	}).filter(function(item) {
		return item.command == 'Query' && item.time > 1;
	}).each(function(item) {
		console.log( JSON.stringify(item) );
	}).then(function(items) {
		if (items.length) {
			console.log('');
		}
	});
}

setInterval(log_processlist, 1000);