diff --git a/consume/canal_user_relate_consume.go b/consume/canal_user_relate_consume.go
index 5d2d69f..0e6e8f5 100644
--- a/consume/canal_user_relate_consume.go
+++ b/consume/canal_user_relate_consume.go
@@ -62,7 +62,7 @@ func handleCancalUserRelateConsume(msg []byte) error {
 	if masterId != "15763466" {
 		return nil
 	}
-	engine := db.DBs["123456"]
+	engine := db.DBs[masterId]
 	//
 
 	if canalMsg.Type == md.CanalMsgInsertSqlType {