本文共 36085 字，大约阅读时间需要 120 分钟。
今天就来聊聊go里面如何绘制echarts图，
需求：使用go来生成自动化巡检报告，数据库的性能采集也是通过go来实现的，这里就不多说，那如何能够直观的展示监控数据呢，当然前面我有写过flask +python+vue 的监控系统：
今天我要做的是，不通过监控系统，直接把想要的数据展示出来，生成html文件，这里主要就是介绍golang 中 go-echarts 如何使用 ，闲话少说，直接上图（部分图）
那上面的是如何实现的呢，直接上代码
package mainimport ( "database/sql" "fmt" "github.com/go-echarts/go-echarts/charts" _ "github.com/go-sql-driver/mysql" "log" "os" "strconv" "strings" "time")const ( mysqlHost ="xxxx" //mysql主机ip mysqlPort="xxx" //mysql端口 mysqlUser="xxx" //mysql登录账号 mysqlPassword="xxx" //mysql登录账号密码 mysqlDbname="xxx" //mysql数据库名字 mysqlCharset="utf8" //mysql字符集)func checkErr(info string,err error){ if err != nil{ nowTime := time.Now().Format("2006-01-02 15:04:05") msg := fmt.Sprintf("mysql is erro:%v !", err) msgError := fmt.Sprintf("Problem!! %s %s %s", info, msg, nowTime) //sendMess(msgError) log.Println(msgError) }}func Query(db *sql.DB,dbInfo string,query string)(result map[int]map[string]string) { rows,err := db.Query(query) checkErr(dbInfo,err) defer rows.Close() cols,_ :=rows.Columns() //返回所有列 vals :=make([][]byte,len(cols)) //这里表示一行所有列的值，用[]byte表示 scans :=make([]interface{},len(cols)) //这里表示一行填充数据 for k,_:=range vals{ scans[k] = &vals[k] } i :=0 result = make(map[int]map[string]string) for rows.Next(){ rows.Scan(scans...) //填充数据 row :=make(map[string]string) //每行数据 for k,v := range vals { //把vals中的数据复制到row中 key :=cols[k] //fmt.Println(string(v)) //这里把[]byte数据转成string row[key] = string(v) } result[i] = row i++ } rows.Close() return result}func stringToInt(s string)int{ toInit,err :=strconv.Atoi(s) checkErr("dbInfo",err) return toInit}func stringToInt64(s string) int64{ toInit64,err :=strconv.ParseInt(s, 10, 64) checkErr("dbInfo",err) return toInit64}func main() { dbInfo := fmt.Sprintf("%s:%s", mysqlHost, mysqlPort) //system/oracle@10.0.1.60:1521/pig mysqlDsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=%s", mysqlUser, mysqlPassword, mysqlHost, mysqlPort, mysqlDbname, mysqlCharset) //log.Println(dbDsn) //打开连接 db, err := sql.Open("mysql", mysqlDsn) checkErr(dbInfo, err) ping := db.Ping() checkErr(dbInfo, ping) //lineBar:=charts.NewKLine() //lineBar.SetGlobalOptions(charts.TitleOpts{Title:"当前连接数"}) dbSql:="select * from (select distinct f_id,f_ip,f_class,f_port,f_role,f_version,f_startup_time,\"oracle\" f_type from t_oracle_instances order by f_class)a union all select * from (select distinct f_id,f_ip,f_class,f_port,f_role,f_version,f_startup_time,\"mysql\" f_type from t_mysql_instances order by f_class,f_role desc) b;" dbList := Query(db, dbInfo, dbSql) p1 := charts.NewPage() //p2:=charts.NewPage() nowTime, _ := time.Parse("2006-01-02 15:04:05", time.Now().Format("2006-01-02 15:04:05")) endTime := time.Now() startTime := endTime.AddDate(0, 0, -1) endUinxTime := endTime.Unix() startUnixTime := startTime.Unix() for i := 0; i < len(dbList); i++ { if dbList[i]["f_type"] == "oracle" { runTime, _ := time.Parse("2006-01-02 15:04:05", dbList[i]["f_startup_time"]) diffTime := nowTime.Sub(runTime) diffDay := fmt.Sprintf("%v天", int(diffTime.Hours()/24)) oracleSql := fmt.Sprintf("select f_check_time ,f_database_role,f_archivelog,f_db_size,f_db_file_size,f_session_total,f_session_actives,f_session_waits,f_processes,f_dg_stats,f_dg_delay,f_buffer_hit,f_library_hit,f_latch_hit,f_in_memory_sort_hit,f_buffer_nowait_hit,f_redo_nowait_ratio,f_sga_pct,f_pga_pct,f_db_block_gets,f_consistent_gets,f_db_block_changes,f_redo_writes,f_physical_reads_direct,f_physical_writes_direct,f_opened_cursors_current,f_user_commits,f_user_rollbacks from t_oracle_monitor_status where f_instances_id=%v and f_check_time BETWEEN %v and %v", dbList[i]["f_id"], startUnixTime, endUinxTime) result := Query(db, dbInfo, oracleSql) var xTime []string var dbSize []string var dbFileSize []string var sessionTotal []string var sessionActives []string var sessionWaits []string var processes []string var bufferHit []string var sgaPct []string var pgaPct []string var userCommit []string var userRollback []string var timeDiff int var dgDelay []string if len(result) <0 { for j := 0; j < len(result)-1; j++ { if dbList[i]["f_role"] == "0" { if result[j+1]["f_dg_delay"] == "-1" { dgDelay = append(dgDelay, "null") } else { dgDelay = append(dgDelay, result[j+1]["f_dg_delay"]) } } timeDiff = stringToInt(result[j+1]["f_check_time"]) - stringToInt(result[j]["f_check_time"]) if result[j+1]["f_db_size"] == "-1" { dbSize = append(dbSize, "null") } else { dbSize = append(dbSize, result[j+1]["f_db_size"]) } if result[j+1]["f_db_file_size"] == "-1" { dbFileSize = append(dbFileSize, "null") } else { dbFileSize = append(dbFileSize, result[j+1]["f_db_file_size"]) } if result[j+1]["f_session_total"] == "-1" { sessionTotal = append(sessionTotal, "null") } else { sessionTotal = append(sessionTotal, result[j+1]["f_session_total"]) } if result[j+1]["f_session_actives"] == "-1" { sessionActives = append(sessionActives, "null") } else { sessionActives = append(sessionActives, result[j+1]["f_session_actives"]) } if result[j+1]["f_session_waits"] == "-1" { sessionWaits = append(sessionWaits, "null") } else { sessionWaits = append(sessionWaits, result[j+1]["f_session_waits"]) } if result[j+1]["f_processes"] == "-1" { processes = append(processes, "null") } else { processes = append(processes, result[j+1]["f_processes"]) } if result[j+1]["f_buffer_hit"] == "-1" { bufferHit = append(bufferHit, "null") } else { bufferHit = append(bufferHit, result[j+1]["f_buffer_hit"]) } if result[j+1]["f_sga_pct"] == "-1" { sgaPct = append(sgaPct, "null") } else { sgaPct = append(sgaPct, result[j+1]["f_sga_pct"]) } if result[j+1]["f_pga_pct"] == "-1" { pgaPct = append(pgaPct, "null") } else { pgaPct = append(pgaPct, result[j+1]["f_pga_pct"]) } if result[j+1]["f_user_commits"] == "-1" || result[j]["f_user_commits"] == "-1" { userCommit = append(userCommit, "null") } else { commitValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_user_commits"]))-float64(stringToInt(result[j]["f_user_commits"])))/float64(timeDiff)), 64) userCommit = append(userCommit, fmt.Sprintf("%v", commitValue)) } if result[j+1]["f_user_rollbacks"] == "-1" || result[j]["f_user_rollbacks"] == "-1" { userRollback = append(userRollback, "null") } else { rollbackValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_user_rollbacks"]))-float64(stringToInt(result[j]["f_user_rollbacks"])))/float64(timeDiff)), 64) userRollback = append(userRollback, fmt.Sprintf("%v", rollbackValue)) } xTime = append(xTime, time.Unix(stringToInt64(result[j]["f_check_time"]), 0).Format("2006-01-02 15:04:05")) } //var hostInfo[] string var isRole []string if dbList[i]["f_role"] == "1" { isRole = append(isRole, "主库") } else { isRole = append(isRole, "从库") } hostJs := " | 类型 | 产品线 | 主机 | 端口 | 版本 | 主从 | 运行时间 | 开始时间 | 结束时间 |
" hostJs += fmt.Sprintf(" | %v | %v | %v | %v | %v | %v | %v | %v | %v |
", "oracle", dbList[i]["f_class"], dbList[i]["f_ip"], dbList[i]["f_port"], dbList[i]["f_version"], isRole[0], diffDay, startTime.Format("2006-01-02 15:04:05"), endTime.Format("2006-01-02 15:04:05")) hostJs += "
" hostBar := charts.NewBar() //echarts=append(echarts, hostBar) //log.Println(hostBar) //log.Println(echarts) hostBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) //hostBar.Width = "100%" hostBar.Height = "100px" hostBarChartID := fmt.Sprintf("%v_%v_%v_serverInfo", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) hostBar.ChartID = hostBarChartID //js:=fmt.Sprintf("let id = document.getElementById('%v'); let code=';\n let data=%v;for(let i=0;i!=data.length;i++){\n if (i==0){\n code+=''+data[i]+'';\n }else if(i==data.length-1){\n code+=''+data[i]+'';\n }else{\n code+=''+data[i]+'';\n }\n }\n id.innerHTML=code+'
';",hostBarChartID,hostInfo) hostBar.AddJSFuncs(fmt.Sprintf("document.getElementById('%v').innerHTML='%v';", hostBarChartID, hostJs)) //sessionLineBar := charts.NewLine() sessionLineBar := charts.NewLine() sessionLineBar.SetGlobalOptions(charts.TitleOpts{Title: "连接数(单位:个)"}) sessionLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) sessionLineBar.ChartID = fmt.Sprintf("%v_%v_%v_sessionBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) sessionLineBar.TextStyle.FontSize = 18 sessionLineBar.Height = "300px" //sessionLineBar.Width = "100%" sessionLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) var markPoints = []charts.SeriesOptser{ charts.MPNameTypeItem{Name: "最大值", Type: "max"}, charts.MPNameTypeItem{Name: "平均值", Type: "average"}, charts.MPNameTypeItem{Name: "最小值", Type: "min"}, charts.MPStyleOpts{Label: charts.LabelTextOpts{Show: true}}, } sessionLineBar.AddXAxis(xTime). AddYAxis("会话总数", sessionTotal, markPoints...). AddYAxis("会话活动数", sessionActives, markPoints...). AddYAxis("等待会话数", sessionWaits, markPoints...) //processLineBar := charts.NewLine() processLineBar := charts.NewLine() processLineBar.SetGlobalOptions(charts.TitleOpts{Title: "进程数(单位:个)"}) processLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) processLineBar.ChartID = fmt.Sprintf("%v_%v_%v_processBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) processLineBar.Height = "300px" processLineBar.TextStyle.FontSize = 18 //processLineBar.Width = "100%" processLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) processLineBar.AddXAxis(xTime).AddYAxis("进程数", processes, markPoints...) //主从延迟 dgDelayLineBar := charts.NewLine() dgDelayLineBar.SetGlobalOptions(charts.TitleOpts{Title: "延迟时间(单位：秒)"}) dgDelayLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) dgDelayLineBar.ChartID = fmt.Sprintf("%v_%v_%v_dgdelayBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) dgDelayLineBar.Height = "300px" //dgDelayLineBar.Width = "100%" dgDelayLineBar.TextStyle.FontSize = 18 dgDelayLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) dgDelayLineBar.AddXAxis(xTime).AddYAxis("延迟时间", dgDelay, markPoints...) //dbSizeLineBar := charts.NewLine() dbSizeLineBar := charts.NewLine() dbSizeLineBar.SetGlobalOptions(charts.TitleOpts{Title: "数据库大小(单位:G)"}) dbSizeLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) dbSizeLineBar.ChartID = fmt.Sprintf("%v_%v_%v_dbsizeBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) dbSizeLineBar.Height = "300px" dbSizeLineBar.TextStyle.FontSize = 18 //dbSizeLineBar.Width = "100%" dbSizeLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) dbSizeLineBar.AddXAxis(xTime). AddYAxis("数据库大小", dbSize, markPoints...). AddYAxis("数据库文件大小", dbFileSize, markPoints...) tablespaceSql := fmt.Sprintf("select * from t_oracle_tablespace where f_instances_id=%v and f_check_time=(select max(f_check_time) from t_oracle_tablespace where f_instances_id=%v) group by f_tablespace_name order by f_used_rate desc", dbList[i]["f_id"], dbList[i]["f_id"]) tablespaceResult := Query(db, dbInfo, tablespaceSql) var tablespaceName []string var tablespaceUsedRate []string //var Results [][] string tablespaceTable := "
| 实例名 | 主机 | 端口 | 表空间名称 | 总大小(M) | 已用空间(M) | 可用空间(M) | 使用率(%) | 监控时间 |
" for k := 0; k < len(tablespaceResult); k++ { //var Result [] string //Result=append(Result,fmt.Sprintf("'%v','%v','%v','%v','%vM','%vM','%vM','%v%%','%v'", //dbList[i]["f_class"],dbList[i]["f_ip"],dbList[i]["f_port"],tablespaceResult[k]["f_tablespace_name"], //tablespaceResult[k]["f_max_size"],tablespaceResult[k]["f_used"], //stringToInt(tablespaceResult[k]["f_max_size"])-stringToInt(tablespaceResult[k]["f_used"]), //tablespaceResult[k]["f_used_rate"], // time.Unix(stringToInt64(tablespaceResult[k]["f_check_time"]), 0).Format("2006-01-02 15:04:05"))) //Results=append(Results,Result) tablespaceTable += fmt.Sprintf(" | %v | %v | %v | %v | %vM | %vM | %vM | %v%% | %v |
", dbList[i]["f_class"], dbList[i]["f_ip"], dbList[i]["f_port"], tablespaceResult[k]["f_tablespace_name"], tablespaceResult[k]["f_max_size"], tablespaceResult[k]["f_used"], stringToInt(tablespaceResult[k]["f_max_size"])-stringToInt(tablespaceResult[k]["f_used"]), tablespaceResult[k]["f_used_rate"], time.Unix(stringToInt64(tablespaceResult[k]["f_check_time"]), 0).Format("2006-01-02 15:04:05")) tablespaceName = append(tablespaceName, tablespaceResult[k]["f_tablespace_name"]) tablespaceUsedRate = append(tablespaceUsedRate, tablespaceResult[k]["f_used_rate"]) } tablespaceTable += "
" //展示tablespace 详细信息 //tablespaceBar := charts.NewBar() tablespaceBar := charts.NewBar() tablespaceBar.SetGlobalOptions(charts.TitleOpts{Title: "表空间使用率(单位:%)"}) tablespaceBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) tablespaceBar.ChartID = fmt.Sprintf("%v_%v_%v_tablespaceBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) tablespaceBar.Height = "300px" tablespaceBar.TextStyle.FontSize = 18 //tablespaceBar.Width = "100%" tablespaceBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) //bar.AddXAxis(nameItems).AddYAxis("商家A",[]int{20,30,40,10,24,60}).AddYAxis("商家B",[]int{35,14,25,60,44,23}) tablespaceBar.AddXAxis(tablespaceName).AddYAxis("表空间使用率", tablespaceUsedRate) //tablespaceBar.SetGlobalOptions(charts.YAxisOpts{Type:"value",AxisLabel: charts.LabelTextOpts{Formatter: "{value}"}}) //tablespaceBar.SetGlobalOptions(charts.GlobalOptser()) //LabelTextOpts{Show:true,Color: "blue",Position: "top",Formatter: "%"} tablespaceBar.SetSeriesOptions(charts.LabelTextOpts{Show: true, Position: "top", Formatter: "{c}" + "%"}) //tablespaceInfo:=charts.NewBar() tablespaceInfo := charts.NewBar() tablespaceInfo.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) //tablespaceInfo.Width = "100%" tablespaceInfo.Height = "400px" tablespaceChartID := fmt.Sprintf("%v_%v_%v_tablespaceInfo", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) tablespaceInfo.ChartID = tablespaceChartID tablespaceJs := fmt.Sprintf("document.getElementById('%v').innerHTML='%v';", tablespaceChartID, tablespaceTable) tablespaceInfo.AddJSFuncs(tablespaceJs) sgaPgaLineBar := charts.NewLine() sgaPgaLineBar.SetGlobalOptions(charts.TitleOpts{Title: "sga/pga使用率(单位:%)"}) sgaPgaLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) sgaPgaLineBar.ChartID = fmt.Sprintf("%v_%v_%v_sgapgaBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) sgaPgaLineBar.Height = "300px" //sgaPgaLineBar.Width = "100%" sgaPgaLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) sgaPgaLineBar.TextStyle.FontSize = 18 sgaPgaLineBar.AddXAxis(xTime). AddYAxis("sga", sgaPct, markPoints...). AddYAxis("pga", pgaPct, markPoints...) bufferHitLineBar := charts.NewLine() bufferHitLineBar.SetGlobalOptions(charts.TitleOpts{Title: "buffer hit(命中率)(单位:%)"}) bufferHitLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) bufferHitLineBar.ChartID = fmt.Sprintf("%v_%v_%v_bufferhitBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) bufferHitLineBar.Height = "300px" bufferHitLineBar.TextStyle.FontSize = 18 //bufferHitLineBar.Width = "100%" bufferHitLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) bufferHitLineBar.AddXAxis(xTime). AddYAxis("buff_hit", bufferHit, markPoints...) transactionLineBar := charts.NewLine() transactionLineBar.SetGlobalOptions(charts.TitleOpts{Title: "Transactions(单位:次/s)"}) transactionLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) transactionLineBar.ChartID = fmt.Sprintf("%v_%v_%v_transactionBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) transactionLineBar.Height = "300px" //transactionLineBar.Width = "100%" transactionLineBar.TextStyle.FontSize = 18 transactionLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) transactionLineBar.AddXAxis(xTime). AddYAxis("user_commits", userCommit, markPoints...). AddYAxis("user_rollbacks", userRollback, markPoints...) p1.Add( hostBar, sessionLineBar, processLineBar, ) if dbList[i]["f_role"] == "0" { p1.Add(dgDelayLineBar) } p1.Add( dbSizeLineBar, tablespaceBar, tablespaceInfo, sgaPgaLineBar, bufferHitLineBar, transactionLineBar, ) //log.Println(p) } } if dbList[i]["f_type"] == "mysql"{ //nowTime,_:=time.Parse("2006-01-02 15:04:05", time.Now().Format("2006-01-02 15:04:05")) //runTime,_:=time.Parse("2006-01-02 15:04:05",dbList[i]["f_startup_time"]) //diffTime:=nowTime.Sub(runTime) //diffDay:=fmt.Sprintf("%v天",int(diffTime.Hours()/24)) diffDay:=dbList[i]["f_startup_time"]+"天" mysqlSql := fmt.Sprintf("select * from t_mysql_monitor_status where f_instances_id=%v and f_check_time BETWEEN %v and %v", dbList[i]["f_id"],startUnixTime,endUinxTime) result := Query(db, dbInfo, mysqlSql) var xTime []string var dgDelay [] string var threadsRunning [] string var threadsConnecteds [] string var threadsCached [] string var comInsert [] string var comUpdate [] string var comDelete [] string var comSelect [] string var qps [] string var tps [] string var slowQueries [] string var bufferPoolHit [] string var bytesReceived [] string var bytesSent [] string var timeDiff int if len(result) >0 { for j := 0; j < len(result)-1; j++ { xTime = append(xTime, time.Unix(stringToInt64(result[j]["f_check_time"]), 0).Format("2006-01-02 15:04:05")) if dbList[i]["f_role"] == "0" { if result[j+1]["f_delay"] == "-1" { dgDelay = append(dgDelay, "null") } else { dgDelay = append(dgDelay, result[j+1]["f_delay"]) } } timeDiff = stringToInt(result[j+1]["f_check_time"]) - stringToInt(result[j]["f_check_time"]) if result[j+1]["f_threads_running"] == "-1" { threadsRunning = append(threadsRunning, "null") } else { threadsRunning = append(threadsRunning, result[j+1]["f_threads_running"]) } if result[j+1]["f_threads_connected"] == "-1" { threadsConnecteds = append(threadsConnecteds, "null") } else { threadsConnecteds = append(threadsConnecteds, result[j+1]["f_threads_connected"]) } if result[j+1]["f_threads_cached"] == "-1" { threadsCached = append(threadsCached, "null") } else { threadsCached = append(threadsCached, result[j+1]["f_threads_cached"]) } if result[j+1]["f_com_insert"] == "-1" || result[j]["f_com_insert"] == "-1" { comInsert = append(comInsert, "null") } else { comInsertValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_com_insert"]))-float64(stringToInt(result[j]["f_com_insert"])))/float64(timeDiff)), 64) comInsert = append(comInsert, fmt.Sprintf("%v", comInsertValue)) } if result[j+1]["f_com_update"] == "-1" || result[j]["f_com_update"] == "-1" { comUpdate = append(comUpdate, "null") } else { comUpdateValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_com_update"]))-float64(stringToInt(result[j]["f_com_update"])))/float64(timeDiff)), 64) comUpdate = append(comUpdate, fmt.Sprintf("%v", comUpdateValue)) } if result[j+1]["f_com_delete"] == "-1" || result[j]["f_com_delete"] == "-1" { comDelete = append(comDelete, "null") } else { comDeleteValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_com_delete"]))-float64(stringToInt(result[j]["f_com_delete"])))/float64(timeDiff)), 64) comDelete = append(comDelete, fmt.Sprintf("%v", comDeleteValue)) } if result[j+1]["f_com_select"] == "-1" || result[j]["f_com_select"] == "-1" { comSelect = append(comSelect, "null") } else { comSelectValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_com_select"]))-float64(stringToInt(result[j]["f_com_select"])))/float64(timeDiff)), 64) comSelect = append(comSelect, fmt.Sprintf("%v", comSelectValue)) } if result[j+1]["f_queries"] == "-1" || result[j]["f_queries"] == "-1" { qps = append(qps, "null") } else { qpsValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_queries"]))-float64(stringToInt(result[j]["f_queries"])))/float64(timeDiff)), 64) qps = append(qps, fmt.Sprintf("%v", qpsValue)) } if result[j+1]["f_com_commit"] == "-1" || result[j]["f_com_commit"] == "-1" || result[j+1]["f_com_rollback"] == "-1" || result[j]["f_com_rollback"] == "-1" { tps = append(tps, "null") } else { tpsValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", ((float64(stringToInt(result[j+1]["f_com_commit"]))-float64(stringToInt(result[j]["f_com_commit"])))+(float64(stringToInt(result[j+1]["f_com_rollback"]))-float64(stringToInt(result[j]["f_com_rollback"]))))/float64(timeDiff)), 64) tps = append(tps, fmt.Sprintf("%v", tpsValue)) } if result[j+1]["f_slow_queries"] == "-1" || result[j]["f_slow_queries"] == "-1" { slowQueries = append(slowQueries, "null") } else { slowQueriesValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_slow_queries"]))-float64(stringToInt(result[j]["f_slow_queries"])))/float64(timeDiff)), 64) slowQueries = append(slowQueries, fmt.Sprintf("%v", slowQueriesValue)) } if result[j+1]["f_buffer_pool_hit"] == "-1" { bufferPoolHit = append(bufferPoolHit, "null") } else { bufferPoolHit = append(bufferPoolHit, result[j+1]["f_buffer_pool_hit"]) } if result[j+1]["f_bytes_received"] == "-1" || result[j]["f_bytes_received"] == "-1" { bytesReceived = append(bytesReceived, "null") } else { bytesReceivedValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_bytes_received"]))-float64(stringToInt(result[j]["f_bytes_received"])))/float64(timeDiff)/float64(1024)), 64) bytesReceived = append(bytesReceived, fmt.Sprintf("%v", bytesReceivedValue)) } if result[j+1]["f_bytes_sent"] == "-1" || result[j]["f_bytes_sent"] == "-1" { bytesSent = append(bytesSent, "null") } else { bytesSentValue, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", (float64(stringToInt(result[j+1]["f_bytes_sent"]))-float64(stringToInt(result[j]["f_bytes_sent"])))/float64(timeDiff)/float64(1024)), 64) bytesSent = append(bytesSent, fmt.Sprintf("%v", bytesSentValue)) } } var isRole []string if dbList[i]["f_role"] == "1" { isRole = append(isRole, "主库") } else { isRole = append(isRole, "从库") } hostJs := "
| 类型 | 产品线 | 主机 | 端口 | 版本 | 主从 | 运行时间 | 开始时间 | 结束时间 |
" hostJs += fmt.Sprintf(" | %v | %v | %v | %v | %v | %v | %v | %v | %v |
", "mysql", dbList[i]["f_class"], dbList[i]["f_ip"], dbList[i]["f_port"], dbList[i]["f_version"], isRole[0], diffDay, startTime.Format("2006-01-02 15:04:05"), endTime.Format("2006-01-02 15:04:05")) hostJs += "
" hostBar := charts.NewBar() //echarts=append(echarts, hostBar) //log.Println(hostBar) //log.Println(echarts) hostBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) //hostBar.Width = "100%" hostBar.Height = "100px" hostBarChartID := fmt.Sprintf("%v_%v_%v_serverInfo", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) hostBar.ChartID = hostBarChartID //js:=fmt.Sprintf("let id = document.getElementById('%v'); let code=';\n let data=%v;for(let i=0;i!=data.length;i++){\n if (i==0){\n code+=''+data[i]+'';\n }else if(i==data.length-1){\n code+=''+data[i]+'';\n }else{\n code+=''+data[i]+'';\n }\n }\n id.innerHTML=code+'
';",hostBarChartID,hostInfo) hostBar.AddJSFuncs(fmt.Sprintf("document.getElementById('%v').innerHTML='%v';", hostBarChartID, hostJs)) var mysqlDelay []string maxConnections := stringToInt(result[len(result)-1]["f_max_connections"]) threadsConnected := stringToInt(result[len(result)-1]["f_threads_connected"]) openTables := stringToInt(result[len(result)-1]["f_open_tables"]) tableOpenCache := stringToInt(result[len(result)-1]["f_table_open_cache"]) openFilesLimit := stringToInt(result[len(result)-1]["f_open_files_limit"]) openFiles := stringToInt(result[len(result)-1]["f_open_files"]) connPie := charts.NewPie() connPie.SetGlobalOptions(charts.TitleOpts{Title: "连接池使用"}) connPie.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) connPieId := fmt.Sprintf("%v_%v_%v_connPie", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) connPie.ChartID = connPieId connPie.Height = "200px" //connPie.MarginLeft="200px" connPie.Width = "300px" //connPie.Border="1px solid #ccc" //connPieJs:=fmt.Sprintf("document.getElementById('%v').style.cssText='%v';document.getElementById('%v').parentNode.style.cssText='%v';",connPieId,"width:28%;margin-left:50px;",connPieId,"float:left;width:40%") connPieJs := fmt.Sprintf("document.getElementById('%v').style.cssText='%v';", connPieId, "border:1px solid #ccc;width:28%;margin-left:0px;") connPie.AddJSFuncs(connPieJs) connPie.Trigger = "item" connPie.Formatter = "{a} {b} : {c} ({d}%)" connPie.SetGlobalOptions(charts.LegendOpts{Bottom: "20", Left: "10", Orient: "vertical"}) connPie.Add("连接池使用", map[string]interface{}{"可用连接": maxConnections - threadsConnected, "已用连接": threadsConnected}, charts.LabelTextOpts{Show: true, Position: "inside", Formatter: "{d}%"}, ) tablePie := charts.NewPie() tablePie.SetGlobalOptions(charts.TitleOpts{Title: "表缓存数"}) tablePie.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) tablePieId := fmt.Sprintf("%v_%v_%v_tablePie", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) tablePie.ChartID = tablePieId tablePie.Height = "200px" tablePie.Width = "300px" //connPie.Border="1px solid #ccc" //tablePieJs:=fmt.Sprintf("document.getElementById('%v').style.cssText='%v';document.getElementById('%v').parentNode.style.cssText='%v';",tablePieId,"border:1px solid #ccc;width:28%;margin-top:-200px;",tablePieId,"float:left;width:47%;margin:-47px") tablePieJs := fmt.Sprintf("document.getElementById('%v').style.cssText='%v';", tablePieId, "border:1px solid #ccc;width:28%;margin-top:-200px;") tablePie.AddJSFuncs(tablePieJs) tablePie.Trigger = "item" tablePie.Formatter = "{a} {b} : {c} ({d}%)" tablePie.SetGlobalOptions(charts.LegendOpts{Bottom: "20", Left: "10", Orient: "vertical"}) tablePie.Add("表缓存使用", map[string]interface{}{"可用表缓存": tableOpenCache - openTables, "已打开表数": openTables}, charts.LabelTextOpts{Show: true, Position: "inside", Formatter: "{d}%"}, ) filePie := charts.NewPie() filePie.SetGlobalOptions(charts.TitleOpts{Title: "打开文件数"}) filePie.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) filePieId := fmt.Sprintf("%v_%v_%v_filePie", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) filePie.ChartID = filePieId filePie.Height = "200px" filePie.Width = "300px" //connPie.Border="1px solid #ccc" //filePieJs:=fmt.Sprintf("document.getElementById('%v').style.cssText='%v';document.getElementById('%v').parentNode.style.cssText='%v';",filePieId,"border:1px solid #ccc;width:28%;margin-top:-200px;margin-right:50px;",filePieId,"float:left;width:23%;margin:-23px") filePieJs := fmt.Sprintf("document.getElementById('%v').style.cssText='%v';", filePieId, "border:1px solid #ccc;width:28%;margin-top:-200px;margin-right:0px;") filePie.AddJSFuncs(filePieJs) filePie.Trigger = "item" filePie.Formatter = "{a} {b} : {c} ({d}%)" filePie.SetGlobalOptions(charts.LegendOpts{Bottom: "20", Left: "10", Orient: "vertical"}) filePie.Add("打开文件数", map[string]interface{}{"可用文件句柄": openFilesLimit - openFiles, "已打开文件数": openFiles}, charts.LabelTextOpts{Show: true, Position: "inside", Formatter: "{d}%"}, ) var markPoints = []charts.SeriesOptser{ charts.MPNameTypeItem{Name: "最大值", Type: "max"}, charts.MPNameTypeItem{Name: "平均值", Type: "average"}, charts.MPNameTypeItem{Name: "最小值", Type: "min"}, charts.MPStyleOpts{Label: charts.LabelTextOpts{Show: true}}, } threadLineBar := charts.NewLine() threadLineBar.SetGlobalOptions(charts.TitleOpts{Title: "连接数(单位:个)"}) threadLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) threadLineBar.ChartID = fmt.Sprintf("%v_%v_%v_threadBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) threadLineBar.Height = "300px" //threadLineBar.Width = "100%" threadLineBar.TextStyle.FontSize = 18 threadLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) threadLineBar.TextStyle.FontSize = 18 threadLineBar.AddXAxis(xTime). AddYAxis("threads_running", threadsRunning, markPoints...). AddYAxis("threads_connect", threadsConnecteds, markPoints...). AddYAxis("threads_cached", threadsCached, markPoints...) //主从延迟 dgDelayLineBar := charts.NewLine() dgDelayLineBar.SetGlobalOptions(charts.TitleOpts{Title: "延迟时间(单位：秒)"}) dgDelayLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) dgDelayLineBar.ChartID = fmt.Sprintf("%v_%v_%v_dgdelayBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) dgDelayLineBar.Height = "300px" //dgDelayLineBar.Width = "100%" dgDelayLineBar.TextStyle.FontSize = 18 dgDelayLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) dgDelayLineBar.AddXAxis(xTime).AddYAxis("延迟时间", dgDelay, markPoints...) //qps qpsLineBar := charts.NewLine() qpsLineBar.SetGlobalOptions(charts.TitleOpts{Title: "QPS(单位：次/秒)"}) qpsLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) qpsLineBar.ChartID = fmt.Sprintf("%v_%v_%v_qpsBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) qpsLineBar.Height = "300px" qpsLineBar.TextStyle.FontSize = 18 //qpsLineBar.Width = "100%" qpsLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) qpsLineBar.AddXAxis(xTime). AddYAxis("qps", qps, markPoints...) //tps tpsLineBar := charts.NewLine() tpsLineBar.SetGlobalOptions(charts.TitleOpts{Title: "TPS(单位：次/秒)"}) tpsLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) tpsLineBar.ChartID = fmt.Sprintf("%v_%v_%v_tpsBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) tpsLineBar.Height = "300px" //tpsLineBar.Width = "100%" tpsLineBar.TextStyle.FontSize = 18 tpsLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) tpsLineBar.AddXAxis(xTime). AddYAxis("tps", tps, markPoints...) //dml dmlLineBar := charts.NewLine() dmlLineBar.SetGlobalOptions(charts.TitleOpts{Title: "DML(单位：次/秒)"}) dmlLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) dmlLineBar.ChartID = fmt.Sprintf("%v_%v_%v_dmlBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) dmlLineBar.Height = "300px" dmlLineBar.TextStyle.FontSize = 18 //dmlLineBar.Width = "100%" dmlLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) dmlLineBar.AddXAxis(xTime). AddYAxis("insert", comInsert, markPoints...). AddYAxis("delete", comDelete, markPoints...). AddYAxis("update", comUpdate, markPoints...). AddYAxis("select", comSelect, markPoints...) //慢查 slowQueriesLineBar := charts.NewLine() slowQueriesLineBar.SetGlobalOptions(charts.TitleOpts{Title: "慢查数(单位：个/秒)"}) slowQueriesLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) slowQueriesLineBar.ChartID = fmt.Sprintf("%v_%v_%v_slowqueriesBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) slowQueriesLineBar.Height = "300px" slowQueriesLineBar.TextStyle.FontSize = 18 //slowQueriesLineBar.Width = "100%" slowQueriesLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) slowQueriesLineBar.AddXAxis(xTime). AddYAxis("slow_queries", slowQueries, markPoints...) //innodb buffer pool hit bufferPoolHitLineBar := charts.NewLine() bufferPoolHitLineBar.SetGlobalOptions(charts.TitleOpts{Title: "Innodb_buffer_pool_hit(单位：%)"}) bufferPoolHitLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) bufferPoolHitLineBar.ChartID = fmt.Sprintf("%v_%v_%v_bufferpoolhitBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) bufferPoolHitLineBar.Height = "300px" bufferPoolHitLineBar.TextStyle.FontSize = 18 //bufferPoolHitLineBar.Width = "100%" bufferPoolHitLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) bufferPoolHitLineBar.AddXAxis(xTime). AddYAxis("Innodb_buffer_pool_hit", bufferPoolHit, markPoints...) //流量 bytesLineBar := charts.NewLine() bytesLineBar.SetGlobalOptions(charts.TitleOpts{Title: "流量(单位：MB)"}) bytesLineBar.SetGlobalOptions(charts.InitOpts{AssetsHost: "http://49.233.181.63/assets/"}) bytesLineBar.ChartID = fmt.Sprintf("%v_%v_%v_bytesBar", strings.Replace(dbList[i]["f_ip"], ".", "", -1), dbList[i]["f_class"], dbList[i]["f_port"]) bytesLineBar.Height = "300px" bytesLineBar.TextStyle.FontSize = 18 // bytesLineBar.Width = "100%" bytesLineBar.SetGlobalOptions(charts.ToolboxOpts{Show: true}) bytesLineBar.AddXAxis(xTime). AddYAxis("bytes_received", bytesReceived, markPoints...). AddYAxis("bytes_sent", bytesSent, markPoints...) p1.Add( hostBar, connPie, filePie, tablePie, threadLineBar, ) if dbList[i]["f_role"] == "0" { p1.Add(dgDelayLineBar) } p1.Add( qpsLineBar, tpsLineBar, dmlLineBar, slowQueriesLineBar, bufferPoolHitLineBar, bytesLineBar, ) for j := 0; j < len(result)-1; j++ { if dbList[i]["f_role"] == "0" { if result[j+1]["f_dg_delay"] == "-1" { mysqlDelay = append(mysqlDelay, "null") } else { mysqlDelay = append(mysqlDelay, result[j+1]["f_dg_delay"]) } } //mysqlTimeDiff :=stringToInt(result[j+1]["f_check_time"])-stringToInt(result[j]["f_check_time"]) } } } } htmlName:=fmt.Sprintf("databases_report_%v.html",time.Now().Format("2006_01_02")) f1, err1 := os.Create(htmlName) checkErr(dbInfo, err1) p1.Render(f1)}
转载地址：http://mzhji.baihongyu.com/