opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-21 14:19:49 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(cloudmon): report influxdb data

Browse Source
This commit is contained in:
ioito
2022-05-19 14:36:43 +08:00
parent 2a0deea6e9
commit 5b26d491b7
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/cloudmon/collectors/common/multiCloudMonUtils.go
+3 -2
View File
@@ -636,7 +636,7 @@ func cloudproviderRunfunc(ctx context.Context, factory ICloudReportFactory, prov
session *mcclient.ClientSession) {
opt := o.Options
group, _ := errgroup.WithContext(ctx)
for i, _ := range ResMonTypeList {
for i := range ResMonTypeList {
resType := ResMonTypeList[i]
group.Go(func() error {
log.Errorf("cloudprovider: %s,operator: %s start report().", provider.Name, resType)
@@ -658,7 +658,8 @@ func CustomizeRunFunc(ctx context.Context, factory ICloudReportFactory, provider
opt := o.Options
err := factory.NewCloudReport(provider, session, &opt.ReportOptions, "").Report()
if err != nil {
log.Errorf("provider: %s report metric err: %v", provider.Name, err)
// provider maybe nil
log.Errorf("provider: %v report metric err: %v", provider, err)
return
}
log.Errorf("operator: %s report() end.", factory.GetId())
pkg/util/influxdb/metrics.go
+3 -1
View File
@@ -50,10 +50,12 @@ func (m *SMetricData) Line() string {
line := strings.Builder{}
line.WriteString(m.Name)
keys := map[string]bool{}
for i := range m.Tags {
if len(m.Tags[i].Key) > 0 && len(m.Tags[i].Value) > 0 {
if _, ok := keys[m.Tags[i].Key]; !ok && len(m.Tags[i].Key) > 0 && len(m.Tags[i].Value) > 0 {
line.WriteByte(',')
line.WriteString(m.Tags[i].String())
keys[m.Tags[i].Key] = true
}
}
line.WriteByte(' ')