connect/utils/zlog/write_sls_test.go

package zlog

import (
	"log"
	"testing"
	"time"

	sls "github.com/aliyun/aliyun-log-go-sdk"
	"google.golang.org/protobuf/proto"
)

func New() {
	// 日志服务的服务入口。此处以杭州为例，其它地域请根据实际情况填写。
	Endpoint := "cn-shanghai.log.aliyuncs.com"

	// 本示例从环境变量中获取AccessKey ID和AccessKey Secret。
	AccessKeyId := "LTAI5tMWjYSHsq3S57pyu2JX"
	AccessKeySecret := "08aBmJYTtW1VJX1sffUmFwSNvJnN58"
	// RAM用户角色的临时安全令牌。此处取值为空，表示不使用临时安全令牌。
	SecurityToken := ""
	// 创建日志服务Client。
	provider := sls.NewStaticCredentialsProvider(AccessKeyId, AccessKeySecret, SecurityToken)
	client := sls.CreateNormalInterfaceV2(Endpoint, provider)

	project, err := client.GetProject("w303b-test")
	logStore, err := client.GetLogStore("w303b-test", "user")
	if err != nil {
		log.Fatalln(err)
	}

	logs := []*sls.Log{
		{
			Time: proto.Uint32(uint32(time.Now().Unix())),
			Contents: []*sls.LogContent{
				{Key: proto.String("level"), Value: proto.String("info")},
				{Key: proto.String("msg"), Value: proto.String("hello aliyun log service.")},
			},
		},
	}

	lg := &sls.LogGroup{
		Topic:  proto.String("test"),
		Source: proto.String("203.0.113.10"),
		Logs:   logs,
	}
	client.PutLogs(project.Name, logStore.Name, lg)
}

func TestNew(t *testing.T) {
	New()
}