aws-cloudwatch-logs/index.js at master · StayDistributed/aws-cloudwatch-logs · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
module.exports = function (config) {

  var cloudwatchlogs = config.cloudwatchlogs,
      logGroupName = config.logGroupName || '/aws-cloudwatch-logs/default';

  return {

    log: function (eventName, message, done) {

      var logCallback = done || function () {},
          d = new Date(),
          logStreamName = config.logStreamName || ([d.getFullYear(), d.getMonth()+1, d.getDate()].join('/') + ' ' + eventName);

      cloudwatchlogs.describeLogStreams({
        logGroupName: logGroupName,
        logStreamNamePrefix: logStreamName
      }, function (err, data) {
        if (err || !data) return logCallback(err);

        if (data.logStreams && data.logStreams[0]) {

          cloudwatchlogs.putLogEvents({
            logEvents: [{
              message: JSON.stringify(message),
              timestamp: (new Date).getTime()
            }],
            logGroupName: logGroupName,
            logStreamName: logStreamName,
            sequenceToken: data.logStreams[0].uploadSequenceToken
          }, logCallback);

        } else {

          cloudwatchlogs.createLogStream({
            logGroupName: logGroupName,
            logStreamName: logStreamName
          }, function (err, data) {
            if (err) return logCallback(err);

            cloudwatchlogs.putLogEvents({
              logEvents: [{
                message: JSON.stringify(message),
                timestamp: (new Date).getTime()
              }],
              logGroupName: logGroupName,
              logStreamName: logStreamName
            }, logCallback);
          });

        }

      });

    }
  }

};