support tdmysql/eip

Author: shitoumomo

README.md

@@ -30,6 +30,8 @@ PostgreSQL|QCE/POSTGRES|[指标详情](https://cloud.tencent.com/document/produc
 CKafka 实例|QCE/CKAFKA|[指标详情](https://cloud.tencent.com/document/product/248/45121)
 Memcached |QCE/MEMCACHED|指标详情说明文档(待上线)
 Lighthouse |QCE/LIGHTHOUSE|指标详情说明文档(待上线)
+分布式数据库 TDSQL MySQL 实例|QCE/TDMYSQL|[指标详情](https://cloud.tencent.com/document/product/248/54401)
+弹性公网 IP|QCE/LB|[指标详情](https://cloud.tencent.com/document/product/248/45099)
 
 `后续会有更多的产品支持`
 

configs/qcloud-eip-product.yml

@@ -0,0 +1,17 @@
+credential:
+  access_key: "access_key"
+  secret_key: "secret_key"
+  region: "region"
+
+rate_limit: 15                #云监控拉数据接口最大限制, 20/秒, 1200/分钟, https://cloud.tencent.com/document/product/248/31014
+
+products:
+  - namespace: QCE/LB        #指标详情: https://cloud.tencent.com/document/product/248/45099
+    all_metrics: true
+    only_include_instances: ['eip-xxxx']
+    extra_labels: [AddressName]
+    #all_instances: true
+    #only_include_metrics: []
+    #statistics_types: [last]
+    #period_seconds: 60
+    #metric_name_type: 2

configs/qcloud-es-product.yml

@@ -6,7 +6,7 @@ credential:
 rate_limit: 10              #云监控拉数据接口最大限制, 20/秒, 1200/分钟, https://cloud.tencent.com/document/product/248/31014
 
 products:
-  - namespace: QCE/ES        #指标详情: https://cloud.tencent.com/document/product/248/45129
+  - namespace: QCE/CES        #指标详情: https://cloud.tencent.com/document/product/248/45129
     all_metrics: true
     all_instances: true
     extra_labels: [InstanceName]

configs/qcloud-tdmysql-product.yml

@@ -0,0 +1,17 @@
+credential:
+  access_key: "access_key"
+  secret_key: "secret_key"
+  region: "region"
+
+rate_limit: 15                #云监控拉数据接口最大限制, 20/秒, 1200/分钟, https://cloud.tencent.com/document/product/248/31014
+
+products:
+  - namespace: QCE/TDMYSQL        #指标详情: https://cloud.tencent.com/document/product/248/54401
+    all_metrics: true
+    only_include_instances: [ 'tdsqlshard-xxxx' ]
+    extra_labels: [ InstanceName ]
+    #all_instances: true
+    #only_include_metrics: []
+    #statistics_types: [last]
+    #period_seconds: 60
+    #metric_name_type: 2

pkg/client/client.go

@@ -10,6 +10,7 @@ import (
 	"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile"
 	cvm "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cvm/v20170312"
 	dc "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dc/v20180410"
+	dcdb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dcdb/v20180411"
 	es "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/es/v20180416"
 	lh "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/lighthouse/v20200324"
 	mariadb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mariadb/v20170312"
@@ -186,3 +187,12 @@ func NewKafkaClient(conf *config.TencentConfig) (*kafka.Client, error) {
 	cpf := profile.NewClientProfile()
 	return kafka.NewClient(credential, conf.Credential.Region, cpf)
 }
+
+func NewDCDBClient(conf *config.TencentConfig) (*dcdb.Client, error) {
+	credential := common.NewCredential(
+		conf.Credential.AccessKey,
+		conf.Credential.SecretKey,
+	)
+	cpf := profile.NewClientProfile()
+	return dcdb.NewClient(credential, conf.Credential.Region, cpf)
+}

pkg/collector/handler_dcdb.go

@@ -0,0 +1,43 @@
+package collector
+
+import (
+	"github.com/go-kit/kit/log"
+	"github.com/tencentyun/tencentcloud-exporter/pkg/metric"
+)
+
+const (
+	DcdbNamespace     = "QCE/TDMYSQL"
+	DcdbInstanceidKey = "InstanceId"
+)
+
+func init() {
+	registerHandler(DcdbNamespace, defaultHandlerEnabled, NewDcdbHandler)
+}
+
+type dcdbHandler struct {
+	baseProductHandler
+}
+
+func (h *dcdbHandler) GetNamespace() string {
+	return DcdbNamespace
+}
+
+func (h *dcdbHandler) IsMetricVaild(m *metric.TcmMetric) bool {
+	// ignore node/shard metric, bug for cloud monitor if filter dim
+	if len(m.Meta.SupportDimensions) != 1 {
+		return false
+	}
+	return true
+}
+
+func NewDcdbHandler(c *TcProductCollector, logger log.Logger) (handler ProductHandler, err error) {
+	handler = &dcdbHandler{
+		baseProductHandler{
+			monitorQueryKey: DcdbInstanceidKey,
+			collector:       c,
+			logger:          logger,
+		},
+	}
+	return
+
+}

pkg/collector/handler_eip.go

@@ -0,0 +1,41 @@
+package collector
+
+import (
+	"github.com/go-kit/kit/log"
+	"github.com/tencentyun/tencentcloud-exporter/pkg/metric"
+)
+
+const (
+	EIPNamespace     = "QCE/LB"
+	EIPInstanceidKey = "eip"
+)
+
+func init() {
+	registerHandler(EIPNamespace, defaultHandlerEnabled, NewEIPHandler)
+}
+
+type eipHandler struct {
+	baseProductHandler
+}
+
+func (h *eipHandler) GetNamespace() string {
+	return EIPNamespace
+}
+func (h *eipHandler) IsMetricVaild(m *metric.TcmMetric) bool {
+	// ignore node/shard metric, bug for cloud monitor if filter dim
+	if len(m.Meta.SupportDimensions) != 1 {
+		return false
+	}
+	return true
+}
+func NewEIPHandler(c *TcProductCollector, logger log.Logger) (handler ProductHandler, err error) {
+	handler = &eipHandler{
+		baseProductHandler{
+			monitorQueryKey: EIPInstanceidKey,
+			collector:       c,
+			logger:          logger,
+		},
+	}
+	return
+
+}

pkg/collector/product.go

@@ -84,6 +84,10 @@ func (c *TcProductCollector) LoadMetricsByProductConf() error {
 			level.Warn(c.logger).Log("msg", "Create metric fail", "err", err, "Namespace", c.Namespace, "name", mname)
 			continue
 		}
+		if nm == nil {
+			// maybe some metric not support
+			continue
+		}
 		c.MetricMap[nm.Meta.MetricName] = nm
 
 		// 获取该指标下的所有实例纬度查询或自定义纬度查询
@@ -164,7 +168,8 @@ func (c *TcProductCollector) createMetricWithProductConf(mname string, pconf con
 		}
 		// 指标过滤
 		if !c.handler.IsMetricVaild(nm) {
-			return nil, fmt.Errorf("metric not support")
+			// ignore invalid metric
+			return nil, nil
 		}
 		err = c.handler.ModifyMetric(nm)
 		if err != nil {

pkg/config/config.go

@@ -53,7 +53,9 @@ var (
 		"postgres":      "QCE/POSTGRES",
 		"memcached":     "QCE/MEMCACHED",
 		"lighthouse":    "QCE/LIGHTHOUSE",
-		"ckafka":         "QCE/CKAFKA",
+		"ckafka":        "QCE/CKAFKA",
+		"tdmysql":       "QCE/TDMYSQL",
+		"lb":            "QCE/LB", // for eip
 	}
 
 	SupportStatisticsTypes = map[string]bool{

pkg/instance/instance_dcdb.go

@@ -0,0 +1,34 @@
+package instance
+
+import (
+	"fmt"
+	"reflect"
+
+	sdk "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dcdb/v20180411"
+)
+
+type DcdbTcInstance struct {
+	baseTcInstance
+	meta *sdk.DCDBInstanceInfo
+}
+
+func (ins *DcdbTcInstance) GetMeta() interface{} {
+	return ins.meta
+}
+
+func NewDcdbTcInstance(instanceId string, meta *sdk.DCDBInstanceInfo) (ins *DcdbTcInstance, err error) {
+	if instanceId == "" {
+		return nil, fmt.Errorf("instanceId is empty ")
+	}
+	if meta == nil {
+		return nil, fmt.Errorf("meta is empty ")
+	}
+	ins = &DcdbTcInstance{
+		baseTcInstance: baseTcInstance{
+			instanceId: instanceId,
+			value:      reflect.ValueOf(*meta),
+		},
+		meta: meta,
+	}
+	return
+}