1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
package sls
import (
"github.com/aliyun/aliyun-log-go-sdk/producer"
"github.com/gogf/gf/frame/g"
"gitlab.jxhh.com/stbz/library.git/logs"
"time"
)
const (
ProjectDefault = "order"
ProjectDis = "dis"
ProjectApi = "api-system"
ProjectMessage = "message-system"
LogstoreDefault = "post_msg"
LogstoreOrder = "orders"
LogstoreDefaultErr = "go_error"
LogstoreDisErr = "dis_err"
LogstoreMessage = "push_msg"
TopicDefault = "topic"
TopicCloud = "shopApi"
)
var producerInstance *producer.Producer
func init() {
producerConfig := producer.GetDefaultProducerConfig()
producerConfig.Endpoint = g.Cfg().GetString("aliLog.Endpoint")
producerConfig.AccessKeyID = g.Cfg().GetString("aliLog.AccessKeyID")
producerConfig.AccessKeySecret = g.Cfg().GetString("aliLog.AccessKeySecret")
producerInstance = producer.InitProducer(producerConfig)
producerInstance.Start()
}
func Createsls(project, logstore, topic,realIP string, addLogMap map[string]string) (err error) {
sls := producer.GenerateLog(uint32(time.Now().Unix()), addLogMap)
err = producerInstance.SendLog(project, logstore, topic, realIP, sls)
if logs.CheckErr(err, "sls") {
return
}
return
}
func Close() {
producerInstance.SafeClose() // 安全关闭
}