From a0953fecca27de6a92b1b1ebad3e47ad177c9570 Mon Sep 17 00:00:00 2001 From: zhangxin Date: Tue, 30 Aug 2022 12:19:59 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89=E8=B0=83=E8=AF=95=E4=BB=A3?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dao/etl/implments/ETCDServiceClient.dao.impl.go | 2 +- services/etl/implments/Extract.service.impl.go | 8 -------- 2 files changed, 1 insertion(+), 9 deletions(-) diff --git a/dao/etl/implments/ETCDServiceClient.dao.impl.go b/dao/etl/implments/ETCDServiceClient.dao.impl.go index eb2e86f..39b9afa 100644 --- a/dao/etl/implments/ETCDServiceClient.dao.impl.go +++ b/dao/etl/implments/ETCDServiceClient.dao.impl.go @@ -126,7 +126,7 @@ func (impl *ETCDServiceImplement) ListenLeaseRespChan() { for { select { case <-impl.CTX.Done(): - fmt.Println("context 结束运行") + //fmt.Println("context 结束运行") return case leaseKeepResp := <-impl.KeepAliveChan: if leaseKeepResp == nil { diff --git a/services/etl/implments/Extract.service.impl.go b/services/etl/implments/Extract.service.impl.go index c1bd230..6518d62 100644 --- a/services/etl/implments/Extract.service.impl.go +++ b/services/etl/implments/Extract.service.impl.go @@ -107,14 +107,6 @@ func (impl *ExtractServiceImplement) StandardExtract(task *model.TaskHead) (err func (impl *ExtractServiceImplement) ExtractByShell(shellLi []model.Shell, task *model.TaskHead, recordDao dal.RecordDao, batchId string, sourceDsn string, targetDsn string) (err error) { for _, shell := range shellLi { shellPath := path.Join(global.ShellPath, shell.ShellName) - //fmt.Println("------------------------------------------------------------------") - //fmt.Println("shellPath:", shellPath) - //fmt.Println("sourceDsn:", sourceDsn) - //fmt.Println("targetDsn:", targetDsn) - //fmt.Println("global.DatabaseDsn:", global.DatabaseDsn) - //fmt.Println("global.MongoDsn:", global.MongoDsn) - //fmt.Println("strconv.Itoa(task.TaskId):", strconv.Itoa(task.TaskId)) - //fmt.Println("----------------------------------------------") cmd := exec.Command(shellPath, sourceDsn, targetDsn, global.DatabaseDsn, global.MongoDsn, strconv.Itoa(task.TaskId)) buf, err := cmd.Output() if err != nil {