如何使CloudWatch代理和指标筛选器报告维度

Question

建立

在EC2实例上运行的CloudWatch Agent会将审核日志报告给CloudWatch.CloudWatch中的度量标准筛选器会在报告日志时创建成功登录,登录失败等指标.

问题

通过度量标准筛选器创建的度量标准不会分配维度,因此我无法通过InstanceId查询CloudWatch获取一组度量标准统计信息.这非常有用,因为我想知道每台计算机的审核指标而不是每个日志组.

评论

使用该put-metric-data命令可以轻松附加尺寸.我可以使用InstanceId的维度标记指标,然后使用仅检索这些指标get-metric-statistics.使用度量标准过滤器+ CloudWatch代理设置无法实现此类功能吗？什么是可能的解决方法？

Answer 1

因此，您需要做的是创建一个 lambda，将事件源设置为您要为其创建指标的日志组。我创建了度量对象来检查每个日志的某些模式。下面的代码是您需要执行的操作的要点。我不得不撕掉一些不适用的东西。如果有人尝试，请告诉我是否有问题。

我创建了一个 lambda（注意指标数组）：

var zlib = require('zlib');
var Q = require('q');
var cloudwatchAgent = require('cloudwatchAgent');

var metrics = [
{
    "name": "SuccessfulLogins",
    "patterns": ["session opened for user", "successful logon"],
    "dimensionName":"HostName",
    "namespace":"UserStats"
}];

exports.handler = function (event, context) {
var payload = new Buffer(event.awslogs.data, 'base64');

zlib.gunzip(payload, function (e, result) {
if (e) {
  context.fail(e);
} else {
  result = JSON.parse(result.toString('utf-8'));
  console.log('Decoded payload: ', JSON.stringify(result));

metrics.forEach(function (metric) {
        promises.push(cloudwatchAgent.processMetric(metric, result.logStream, result.logEvents));
  });

Q.all(promises).fail(function (error) {
        context.fail('Error processing log events: ' + error);
  }).done(function () {
        context.succeed('Successfully processed log events.');
  });
  }
 });
};

该 lambda 调用此函数：

var sdk = require('aws-sdk');
var Q = require('q');
var cloudwatch = new sdk.CloudWatch();

function processMetric(metric, streamName, logs) {
console.log('Checking metric ' + metric.name + ' against these patterns:' + metric.patterns.toString());
var deferred = Q.defer();
var value = 0;

logs.forEach(function (logEvent) {
metric.patterns.forEach(function(pattern) {
    if(logEvent.message.toLowerCase().indexOf(pattern) > -1) {
    value++;
    }
});
});

var params = {
  MetricData: [{
      MetricName: metric.name,
      Dimensions: [{
          Name: metric.dimensionName,
          Value: streamName
        }],
      Timestamp: new Date(),
      Value: value
    }],
  Namespace: metric.namespace
};

cloudwatch.putMetricData(params, function (err, data) {
  if (err) {
    console.log(err, err.stack);
    deferred.reject(err);
  } else {
    console.log('Successfully created metric for ' + metric.name + ' with value ' + value);
    deferred.resolve(data);
  }
});

return deferred.promise;
}

module.exports.processMetric = processMetric;