|
|
@@ -4,6 +4,7 @@ import (
|
|
|
"eta/eta_api/models"
|
|
|
"eta/eta_api/services/binlog"
|
|
|
"eta/eta_api/services/data"
|
|
|
+ edbmonitor "eta/eta_api/services/edb_monitor"
|
|
|
"eta/eta_api/utils"
|
|
|
"fmt"
|
|
|
"strings"
|
|
|
@@ -53,12 +54,12 @@ func Task() {
|
|
|
// 监听binlog
|
|
|
if utils.MYSQL_DATA_BINLOG_URL != "" && utils.DbDriverName == `mysql` {
|
|
|
go binlog.ListenMysql()
|
|
|
- }
|
|
|
|
|
|
- //go edbmonitor.HandleEdbMonitorEdbInfo()
|
|
|
+ go edbmonitor.HandleEdbMonitorEdbInfo()
|
|
|
|
|
|
- // 监听数据源binlog写入es
|
|
|
- //go binlog.HandleDataSourceChange2Es()
|
|
|
+ // 监听数据源binlog写入es
|
|
|
+ go binlog.HandleDataSourceChange2Es()
|
|
|
+ }
|
|
|
|
|
|
// TODO:数据修复
|
|
|
//FixNewEs()
|
