Skip to content

Instantly share code, notes, and snippets.

@marcelog
Last active April 12, 2018 20:19
Show Gist options
  • Star 6 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save marcelog/dafb53e9cf319b16d932 to your computer and use it in GitHub Desktop.
Save marcelog/dafb53e9cf319b16d932 to your computer and use it in GitHub Desktop.
quick UDP Logstash logging from nodejs
var util = require('util');
var dgram = require('dgram');
function logstashUDP(host, port, type, message, fields, callback) {
var client = dgram.createSocket('udp4');
var logObject = {
'@timestamp': (new Date).toISOString(),
type: type,
message: message,
fields: fields
};
var m = new Buffer(JSON.stringify(logObject));
client.send(m, 0, m.length, port, host, function(err, bytes) {
client.close();
callback(err);
});
}
logstashUDP('127.0.0.1', 10001, 'js', 'hello world', {'level': 'debug'}, function(err) {
if(err) {
console.log('Error logging: %s', util.inspect(err));
}
});
@cuthbeorht
Copy link

How do we specify an index?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment