日志记录LogRecord操作

更新时间：2025-11-14

推送LogRecord

支持批量推送日志记录到 BLS 平台，日志记录的格式可以是 TEXT，也可以是 JSON 格式。如果是 TEXT，则不对日志进行解析；如果是 JSON 格式，可以自动发现 JSON 字段（仅支持首层字段发现，暂不支持嵌套类型字段的自动发现）。

如果既想上传日志原文，又想上传解析出的具体字段，可以使用 JSON 格式进行上传，并在 JSON 中包含日志原文(使用 @raw 作为key，日志原文作为 value)。 BLS 解析到 @raw 的时候，会将其内容作为日志原文处理。

通过以下代码，可以批量推送JSON日志记录到指定日志集的指定日志流中。

1// 推送JSON格式日志记录
2pushLogRecordRequest := PushLogRecordRequest{
3    Project:       "default",
4    LogStoreName:  "test,
5    LogStreamName: "json-logStream",
6    LogType:       "JSON",
7    LogRecords: []api.LogRecord{
8        {
9            Message:   "{\"@raw\": \"raw text\", \"level\": \"info\"}",
10            Timestamp: time.Now().UnixMilli(),
11        },
12    },
13}
14// 指定logRecord类型为JSON，并将日志记录推送到日志集demo中的日志流json-logStream中
15// 若没有该日志流，则自动创建
16err = BLS_CLIENT.PushLogRecordV2(pushLogRecordRequest)
17if err != nil {
18  fmt.Println("Push logRecords failed: ", err)
19} else {
20  fmt.Println("Push logRecords success")
21}

提示：

详细的参数配置及限制条件，可以参考BLS API 文档PushLogRecord

查看指定LogRecord

通过以下代码，查看指定日志流中的日志记录，您可以获取最近的日志记录或使用时间范围进行过滤

1pullLogRecordRequest := PullLogRecordRequest{
2    Project:       "default",
3    LogStoreName:  "test",
4    StartDateTime: time.Now().Add(-10 * time.Minute).UTC().Format("2006-01-02T15:04:05Z"),
5    EndDateTime:   time.Now().UTC().Format("2006-01-02T15:04:05Z"),
6}
7res, err := BLS_CLIENT.PullLogRecordV2(pullLogRecordRequest)
8if err != nil {
9  fmt.Println("Pull logRecord failed: ", err)
10} else {
11  fmt.Println("LogRecords result: ", res)
12}

提示：

详细的参数配置及限制条件，可以参考BLS API 文档PullLogRecord

查询指定LogRecord

用户通过提交 Query 检索或分析指定日志集中的数据，每次只能查询一个日志集的内容。

Query 语句支持三种格式，形如:

match 检索语句：需要开启全文索引或者字段索引，可以根据条件检索日志内容，例如 match method:GET and status >= 400
SQL语句：执行 SQL 语句，例如 select * limit 10
match 检索语句 | SQL 语句：需要开启全文索引或者字段索引，在符合检索条件的结果集上执行 SQL 语句，检索语句和 SQL 语句通过竖线分隔，例如 match method:GET and status >= 400 | select host, count(*) group by host

查询相关限制如下：

每个账户支持最多的查询并发数是 15 个
限制返回的结果集大小不超过 1MB 或 1000 条记录。

检索语法请参考检索语法

SQL 语句中可以不包括 from 子句，语法详情可以参考 SQL 语法

通过以下代码，您可以在指定日志集中查询满足条件的日志记录。

1queryLogRecordRequest := QueryLogRecordRequest{
2    Project:       "default",
3    LogStoreName:  "test",
4    Query:         "match *",
5    StartDateTime: time.Now().Add(-20 * time.Second).UTC().Format("2006-01-02T15:04:05Z"),
6    EndDateTime:   time.Now().UTC().Format("2006-01-02T15:04:05Z"),
7}
8res, err := BLS_CLIENT.QueryLogRecordV2(queryLogRecordRequest)
9if err != nil {
10  fmt.Println("Query logRecord failed: ", err)
11} else {
12  fmt.Println("LogRecords result: ", res)
13}

提示：

详细的参数配置及限制条件，可以参考BLS API 文档QueryLogRecord

日志流LogStream操作

日志投递LogShipper操作

日志服务 BLS

日志服务 BLS

日志记录LogRecord操作

推送LogRecord

查看指定LogRecord

查询指定LogRecord