feat: agent

agent/agent.go

@@ -263,12 +263,12 @@ func (a *Agent) collectAndSend(ctx context.Context, buf *bytes.Buffer, r *ring.R
 	}
 
 	body.Profile = pf
-	body.SendTime = time.Now().UnixNano()
+	body.SendTime = time.Now().Unix()
 	pp, err := gprofile.ParseData(buf.Bytes())
 	if err != nil {
 		return fmt.Errorf("fail to parse profile[%s] data: %w", profileType.String(), err)
 	}
-	body.CreateTime = pp.TimeNanos
+	body.CreateTime = pp.TimeNanos / 1e9
 
 	req := a.c.NewRequest().Post().WithPath("/v1/profile").WithJSONBody(&body)
 	resp, err := a.c.Do(ctx, req)

script/tablestore.go

@@ -0,0 +1,23 @@
+package script
+
+import (
+	"github.com/aliyun/aliyun-tablestore-go-sdk/v5/tablestore"
+	"github.com/xiaojiaoyu100/profiler/collector/env"
+	"go.uber.org/zap"
+	"golang.org/x/tools/go/ssa/interp/testdata/src/fmt"
+)
+
+func InitOTS(env *env.Env) {
+	createTableReq := tablestore.CreateTableRequest{
+		TableMeta:          nil,
+		TableOption:        nil,
+		ReservedThroughput: nil,
+		StreamSpec:         nil,
+		IndexMetas:         nil,
+	}
+	_, err := env.TablestoreClient().Client.CreateTable(&createTableReq)
+	if err != nil {
+		env.Logger().Info(fmt.Sprintf("fail to create table %s", env.TablestoreClient().TableName), zap.Error(err))
+		return
+	}
+}