-
-
Notifications
You must be signed in to change notification settings - Fork 1
/
example.go
79 lines (67 loc) 路 1.76 KB
/
example.go
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package main
import (
"fmt"
"log"
"os"
"time"
"log/slog"
slogparquet "github.com/samber/slog-parquet"
"github.com/thanos-io/objstore/providers/s3"
)
func main() {
bucket, err := s3.NewBucketWithConfig(
slogparquet.NewLogger(),
s3.Config{
Endpoint: os.Getenv("AWS_S3_ENDPOINT"),
Region: os.Getenv("AWS_S3_REGION"),
AccessKey: os.Getenv("AWS_ACCESS_KEY"),
SecretKey: os.Getenv("AWS_SECRET_KEY"),
Bucket: os.Getenv("AWS_S3_BUCKET"),
PartSize: 16 * 1024 * 1024, // 16MB
},
"samber/slog-parquet",
)
if err != nil {
log.Fatal(err)
}
buffer := slogparquet.NewParquetBuffer(bucket, "logs", 10*1024*1024)
logger := slog.New(slogparquet.Option{Level: slog.LevelDebug, Buffer: buffer}.NewParquetHandler())
logger = logger.
With("environment", "dev").
With("release", "v1.0.0")
// log error
logger.
With("category", "sql").
With("query.statement", "SELECT COUNT(*) FROM users;").
With("query.duration", 1*time.Second).
With("error", fmt.Errorf("could not count users")).
Error("caramba!")
// log user signup
logger.
With(
slog.Group("user",
slog.String("id", "user-123"),
slog.Time("created_at", time.Now()),
),
).
Info("user registration")
buffer.Flush(true)
bucket.Close()
// logger := slog.New(slogparquet.Option{Level: slog.LevelDebug, Buffer: buffer}.NewParquetHandler())
// logger = logger.With("release", "v1.0.0")
// for i := 0; i < 10_000_000; i++ {
// logger.
// With(
// slog.Group("user",
// slog.String("id", "user-123"),
// slog.Time("created_at", time.Now().AddDate(0, 0, -1)),
// ),
// ).
// With("a", i).
// With("environment", "dev").
// With("error", fmt.Errorf("an error")).
// Error("A message")
// }
// buffer.Flush(true)
// bucket.Close()
}