diff options
| -rw-r--r-- | package-lock.json | 5 | ||||
| -rw-r--r-- | package.json | 1 | ||||
| -rw-r--r-- | worker.js | 10 |
3 files changed, 15 insertions, 1 deletions
diff --git a/package-lock.json b/package-lock.json index e0ca984..b0d47ac 100644 --- a/package-lock.json +++ b/package-lock.json @@ -553,6 +553,11 @@ } } }, + "winston-datadog": { + "version": "1.1.0", + "resolved": "https://registry.npmjs.org/winston-datadog/-/winston-datadog-1.1.0.tgz", + "integrity": "sha512-f3r1dsqXrK9o5nBRKFWaROf5QkoqJHGY6k0RMuwm4L+Oaab0JnQPGPkVxvJi9E1ylffGOrGFF/d9YCv2IP+IVg==" + }, "winston-loggly-bulk": { "version": "2.0.0", "resolved": "https://registry.npmjs.org/winston-loggly-bulk/-/winston-loggly-bulk-2.0.0.tgz", diff --git a/package.json b/package.json index 3e7bd2d..f3f32ed 100644 --- a/package.json +++ b/package.json @@ -9,6 +9,7 @@ "request": "^2.81.0", "request-promise": "^4.2.1", "winston": "^2.3.1", + "winston-datadog": "^1.1.0", "winston-loggly-bulk": "^2.0.0" }, "devDependencies": {}, @@ -6,6 +6,7 @@ const amqp = require("amqplib"), Promise = require("bluebird"), winston = require("winston"), loggly = require("winston-loggly-bulk"), + datadog = require("winston-datadog"), request = require("request-promise"), api = require("../orm/api"); @@ -13,7 +14,8 @@ const MADGLORY_TOKEN = process.env.MADGLORY_TOKEN, QUEUE = process.env.QUEUE || "grab", PROCESS_QUEUE = process.env.PROCESS_QUEUE || "process", RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", - LOGGLY_TOKEN = process.env.LOGGLY_TOKEN; + LOGGLY_TOKEN = process.env.LOGGLY_TOKEN, + DATADOG_TOKEN = process.env.DATADOG_TOKEN; if (MADGLORY_TOKEN == undefined) throw "Need an API token"; const logger = new (winston.Logger)({ @@ -34,6 +36,12 @@ if (LOGGLY_TOKEN) json: true }); +// datadog integration +if (DATADOG_TOKEN) + logger.add(new datadog({ + api_key: DATADOG_TOKEN + }), null, true); + amqp.connect(RABBITMQ_URI).then(async (rabbit) => { process.once("SIGINT", rabbit.close.bind(rabbit)); |