如何彙總AWS SQS ApproximalNumberOfMessages

Question

如果給定X個SQS隊列，我如何將ApproximateNumberOfMessages集合到一個CloudWatch度量標準中？

我想根據隊列中有多少個消息來自動擴展組規模。使用多個CloudWatch警報（每個隊列一個）會導致問題，因爲一個隊列將爲空而其他隊列爲「滿」。

Answer 1

我實現這一目標的方式是將AWS Lambda與Node.js結合使用。我添加了一個CloudWatch事件觸發器來每分鐘運行一次lambda函數。這將查詢sqs隊列，然後創建一個自定義CloudWatch指標，然後您可以使用該指標用於自動縮放組。

var AWS = require('aws-sdk'); 
var sqs = new AWS.SQS(); 
var cloudWatch = new AWS.CloudWatch(); 

var queueUrls = ['https://sqs.REGION.amazonaws.com/ACCOUNT-NUMBER/queueUrl1','https://sqs.REGION.amazonaws.com/ACCOUNT-NUMBER/queueUrl2']; 

exports.handler = (event, context, callback) => { 
    var fn = function (url) { 
     return new Promise(resolve => { 
      var sqsParams = { 
       AttributeNames: ['ApproximateNumberOfMessages'], 
       QueueUrl: url 
      }; 

      sqs.getQueueAttributes(sqsParams, function(err,data){ 
       if(err) 
       { 
        console.log(err,err.stack); 
        context.fail(err); 
       } 
       else 
       { 
        resolve({name: url.split('/').pop(), messageCount: parseInt(data.Attributes.ApproximateNumberOfMessages)}); 
       } 
      }); 
     }); 
    }; 

    var actions = queueUrls.map(fn); 
    Promise.all(actions).then(function(queues) { 
     var messageCount = queues.map(function(m){return m.messageCount;}); 
     var queueNames = queues.map(function(n){return n.name;}).join(); 

     var metricParams = { 
      MetricData:[{ 
       MetricName: 'ApproximateNumberOfMessages', 
       Dimensions:[{ 
        Name: 'QueueName', 
        Value: queueNames 
       }], 
       Unit: 'Count', 
       StatisticValues: { 
        Maximum: Math.max.apply(Math, messageCount), 
        Minimum: Math.min.apply(Math, messageCount), 
        SampleCount: queues.length, 
        Sum: messageCount.reduce((pv, cv) => pv+cv, 0) 
       } 
      }], 
      Namespace: 'AWS/SQS' 
     }; 
     cloudWatch.putMetricData(metricParams, function(err, metricData){ 
      if(err) console.log(err,err.stack); 
      else console.log(metricData); 
     }); 
    }); 
}; 

此代碼顯然可以優化處理超過2個隊列，甚至能夠從異步瀑布受益。

編輯：更新爲使用承諾。

EDIT2：CloudWatch的連接隊列名稱度量標準