add sls monitor api

Author: syzh

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 Object', 
+    rangeEnd: 'end Time Object'
+}
+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

src/client.js

@@ -176,12 +176,106 @@ 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)
+  }
+
+  async getScfMetrics(region, rangeTime, period, funcName, ns, version) {
+    // const cred = new Credential(credentials.secretId, credentials.secretKey);
+    // const client = new MonitorClient(cred, region || 'ap-guangzhou');
+    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'];
+
+    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) => {
+            for (var i = 0; i < results.length; i++) {
+                const response = results[i].Response;
+                const metric = {
+                    type: response.MetricName,
+                    title: response.MetricName,
+                    values: [],
+                    total: 0
+                }
+
+                response.DataPoints[0].Timestamps.forEach((val, i) => {
+                    if (!metric.values[i]) {
+                        metric.values[i] = {
+                            timestamp: val
+                        }
+                    } else {
+                        metric.values[i].timestamp = val
+                    }
+
+                    if (response.DataPoints[0].Values[i] != undefined) {
+                        metric.values[i].value = response.DataPoints[0].Values[i]
+                        metric.total = Math.round(metric.total + metric.values[i].value)
+                    }
+
+                })
+                result.metrics.push(metric)
+            }
+            resolve(result)
+            
+        }).catch((error) => {
+            reject(error)
+        })
+    })
+  }
+}
+
 module.exports = {
   ScfClient,
   TagClient,
   CamClient,
   CnsClient,
   ApigwClient,
   DomainClient,
-  CosClient
+  CosClient,
+  SlsMonitor
 }

src/index.js

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