From f60f6b7bd328e22aad9e496033af91a56ab3106f Mon Sep 17 00:00:00 2001 From: Dery Rahman Ahaddienata Date: Mon, 11 Nov 2024 19:01:12 +0700 Subject: [PATCH 1/2] feat: print log error --- mc2mc/internal/logger/logger.go | 5 +++++ mc2mc/main.go | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/mc2mc/internal/logger/logger.go b/mc2mc/internal/logger/logger.go index 6fd17f8..f0099f1 100644 --- a/mc2mc/internal/logger/logger.go +++ b/mc2mc/internal/logger/logger.go @@ -16,3 +16,8 @@ func NewLogger(logLevel string) (*slog.Logger, error) { writter := slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{Level: level}) return slog.New(writter), nil } + +func NewDefaultLogger() *slog.Logger { + l, _ := NewLogger("INFO") + return l +} diff --git a/mc2mc/main.go b/mc2mc/main.go index 83962aa..cf8cb69 100644 --- a/mc2mc/main.go +++ b/mc2mc/main.go @@ -5,14 +5,19 @@ import ( "os" _ "github.com/aliyun/aliyun-odps-go-sdk/sqldriver" + "github.com/goto/transformers/mc2mc/internal/logger" ) func main() { + // initiate default logger + l := logger.NewDefaultLogger() + // mc2mc is the main function to execute the mc2mc transformation // which reads the configuration, sets up the client and executes the query. // It also handles graceful shutdown by listening to os signals. // It returns error if any. if err := mc2mc(); err != nil { + l.Error(fmt.Sprintf("error: %s", err.Error())) fmt.Printf("error: %+v\n", err) os.Exit(1) } From 82553f875489585c386b590f34f33aac8df95e38 Mon Sep 17 00:00:00 2001 From: Dery Rahman Ahaddienata Date: Wed, 20 Nov 2024 13:29:30 +0700 Subject: [PATCH 2/2] chore: bump ali version --- mc2mc/go.mod | 2 +- mc2mc/go.sum | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/mc2mc/go.mod b/mc2mc/go.mod index 2653635..36f0390 100644 --- a/mc2mc/go.mod +++ b/mc2mc/go.mod @@ -3,7 +3,7 @@ module github.com/goto/transformers/mc2mc go 1.22.3 require ( - github.com/aliyun/aliyun-odps-go-sdk v0.3.8 + github.com/aliyun/aliyun-odps-go-sdk v0.3.15 github.com/pkg/errors v0.9.1 github.com/stretchr/testify v1.9.0 go.opentelemetry.io/otel v1.30.0 diff --git a/mc2mc/go.sum b/mc2mc/go.sum index 261e4e9..7536c64 100644 --- a/mc2mc/go.sum +++ b/mc2mc/go.sum @@ -14,8 +14,8 @@ github.com/alibabacloud-go/debug v1.0.1 h1:MsW9SmUtbb1Fnt3ieC6NNZi6aEwrXfDksD4QA github.com/alibabacloud-go/debug v1.0.1/go.mod h1:8gfgZCCAC3+SCzjWtY053FrOcd4/qlH6IHTI4QyICOc= github.com/alibabacloud-go/tea v1.2.2 h1:aTsR6Rl3ANWPfqeQugPglfurloyBJY85eFy7Gc1+8oU= github.com/alibabacloud-go/tea v1.2.2/go.mod h1:CF3vOzEMAG+bR4WOql8gc2G9H3EkH3ZLAQdpmpXMgwk= -github.com/aliyun/aliyun-odps-go-sdk v0.3.8 h1:IUMwvosuHiY02/xEAGw6zFOKv1HR84B3HmDGmMrbo/U= -github.com/aliyun/aliyun-odps-go-sdk v0.3.8/go.mod h1:t/tgF/iN5aAs/gLL7sEI8/qdax4NuFCKEjO3OJbHZqI= +github.com/aliyun/aliyun-odps-go-sdk v0.3.15 h1:HkWki3g7G0xEAyxSAChqSDxLw8NCl7PFc8KxcECXReQ= +github.com/aliyun/aliyun-odps-go-sdk v0.3.15/go.mod h1:t/tgF/iN5aAs/gLL7sEI8/qdax4NuFCKEjO3OJbHZqI= github.com/aliyun/credentials-go v1.3.10 h1:45Xxrae/evfzQL9V10zL3xX31eqgLWEaIdCoPipOEQA= github.com/aliyun/credentials-go v1.3.10/go.mod h1:Jm6d+xIgwJVLVWT561vy67ZRP4lPTQxMbEYRuT2Ti1U= github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY=