Merge pull request #1 from serverless-tencent/develop

add get metrics api

Author: anycodes

README.md

@@ -40,3 +40,21 @@ cosClient.getService(function(err, data) {
 ```
 
 参考地址：https://cloud.tencent.com/document/product/436/8629
+
+## Scf 监控接口
+
+```
+const { slsMonitor } = require('./src/index')
+
+const slsClient = new slsMonitor(secret)
+
+const rangeTime = {
+    rangeStart: 'begin Time string rfc3339 format', // 2018-09-22T19:51:23+08:00
+    rangeEnd: 'end Time string rfc3339 format' // 2018-09-22T19:51:23+08:00
+}
+const period = 3600
+const ret = await slsClient.getScfMetrics('ap-guangzhou', rangeTime, period, 'funcName', 'default', '$latest')
+console.log(ret)
+```
+
+参考地址: https://cloud.tencent.com/document/product/248/31649

package.json

@@ -18,13 +18,10 @@
   "author": "Dfounderliu",
   "license": "Apache",
   "dependencies": {
-    "configstore": "3.1.2",
-    "dot-qs": "0.2.0",
-    "mime-types": "2.1.24",
-    "object-assign": "3.0.0",
-    "xml2js": "0.4.19",
     "caseless": "0.12.0",
     "combined-stream": "1.0.6",
+    "configstore": "3.1.2",
+    "dot-qs": "0.2.0",
     "extend": "3.0.2",
     "forever-agent": "0.6.1",
     "form-data": "2.3.2",
@@ -33,13 +30,17 @@
     "is-typedarray": "1.0.0",
     "isstream": "0.1.2",
     "json-stringify-safe": "5.0.1",
+    "mime-types": "2.1.24",
+    "moment": "^2.24.0",
     "oauth-sign": "0.9.0",
+    "object-assign": "3.0.0",
     "performance-now": "2.1.0",
     "qs": "6.5.2",
     "safe-buffer": "5.1.2",
     "tough-cookie": "2.5.0",
     "tunnel-agent": "0.6.0",
-    "uuid": "3.3.2"
+    "uuid": "3.3.2",
+    "xml2js": "0.4.19"
   },
   "devDependencies": {
     "babel-eslint": "9.0.0",

src/client.js

@@ -4,6 +4,7 @@ const dotQs = require('dot-qs')
 const request = require('../lib/request/index')
 const crypto = require('crypto')
 const cos = require('../lib/cos/cos')
+const util = require('util')
 
 var defaults = {
   signatureMethod: 'HmacSHA1',
@@ -200,6 +201,104 @@ class DomainClient {
 
 class CosClient extends cos {}
 
+class SlsMonitor {
+  constructor(credentials = {}) {
+    this.credentials = credentials
+  }
+
+  async request(data) {
+    return await new TencentCloudClient(this.credentials, {
+      host: 'monitor.tencentcloudapi.com',
+      path: '/'
+    }).doCloudApiRequest(data)
+  }
+
+  aggregationByDay(responses) {
+    const len = responses.length
+    for (var i = 0; i < len; i++) {
+      const result = responses[i]
+      const tlen = result.Response.DataPoints[0].Timestamps.length
+      const values = result.Response.DataPoints[0].Values
+      let total = values[0]
+
+      const newTimes = []
+      const newValues = []
+      for (var n = 0; n < tlen; n++) {
+        if (n > 0 && !(n % 24)) {
+          newTimes.push(result.Response.DataPoints[0].Timestamps[n])
+          const v = total / 24
+          newValues.push(parseFloat((v.toFixed(2)), 10))
+          total = values[n]
+        } else {
+          total += values[n]
+        }
+      }
+      result.Response.DataPoints[0].Timestamps = newTimes
+      result.Response.DataPoints[0].Values = newValues
+    }
+  }
+
+  async getScfMetrics(region, rangeTime, period, funcName, ns, version) {
+    const client = new TencentCloudClient(this.credentials, {
+      host: 'monitor.tencentcloudapi.com',
+      path: '/'
+    })
+    const req = {
+      Action: 'GetMonitorData',
+      Version: '2018-07-24',
+    }
+
+    const metrics = ['Duration', 'Invocation', 'Error', 'ConcurrentExecutions', 'ConfigMem', 'FunctionErrorPercentage', 'Http2xx', 'Http432', 'Http433', 'Http434', 'Http4xx', 'Mem', 'MemDuration', 'Syserr'];
+
+    let aggrFlag = false
+    if (period == 86400) {
+      period = 3600 // day
+      aggrFlag = true
+    }
+    const result = {
+        rangeStart: rangeTime.rangeStart,
+        rangeEnd: rangeTime.rangeEnd,
+        metrics: []
+    }
+    
+    const requestHandlers = []
+    for (var i = 0; i < metrics.length; i++) {
+        req.Namespace = 'qce/scf_v2';
+        req.MetricName = metrics[i];
+        req.Period = period;
+        req.StartTime = rangeTime.rangeStart;
+        req.EndTime = rangeTime.rangeEnd;
+        req.Instances = [{ 
+            Dimensions: [
+                {
+                    Name: 'functionName',
+                    Value: funcName,
+                },
+                {
+                    Name: 'version',
+                    Value: version || '$latest',
+                },
+                {
+                    Name: 'namespace',
+                    Value: ns,
+                }
+            ]
+        }];
+        requestHandlers.push(client.doCloudApiRequest(req)) 
+    }
+    return new Promise((resolve, reject)=> {
+        Promise.all(requestHandlers).then((results) => {
+          if (aggrFlag) 
+            this.aggregationByDay(results)
+
+          resolve(results)
+        }).catch((error) => {
+            reject(error)
+        })
+    })
+  }
+}
+
 module.exports = {
   ScfClient,
   TagClient,
@@ -209,5 +308,6 @@ module.exports = {
   ApigwClient,
   DomainClient,
   CosClient,
+  SlsMonitor,
   TcbClient
 }

src/index.js

@@ -7,5 +7,6 @@ module.exports = {
   apigw: require('./client').ApigwClient,
   domain: require('./client').DomainClient,
   cos: require('./client').CosClient,
+  slsMonitor: require('./client').SlsMonitor,
   tcb: require('./client').TcbClient
 }