|
|
@@ -2,6 +2,7 @@ package services
|
|
|
|
|
|
import (
|
|
|
"eta/eta_api/models"
|
|
|
+ "eta/eta_api/services/binlog"
|
|
|
"eta/eta_api/services/data"
|
|
|
"eta/eta_api/utils"
|
|
|
"fmt"
|
|
|
@@ -50,8 +51,8 @@ func Task() {
|
|
|
|
|
|
// TODO:监听这里需要找下达梦的方案，主流程先跑起来再处理
|
|
|
// 监听binlog
|
|
|
- if utils.MYSQL_DATA_BINLOG_URL != "" {
|
|
|
- //go binlog.ListenMysql()
|
|
|
+ if utils.MYSQL_DATA_BINLOG_URL != "" && utils.DbDriverName == `mysql` {
|
|
|
+ go binlog.ListenMysql()
|
|
|
}
|
|
|
|
|
|
//go edbmonitor.HandleEdbMonitorEdbInfo()
|
