日志服务提供多语言SDK,且都支持日志服务消费接口。本文介绍普通消费日志的SDK示例及控制台的消费预览功能。

SDK消费

本示例中,创建一个PullLogsDemo.java文件,并调用接口读取日志数据,完成普通消费的演示。示例如下:
import com.aliyun.openservices.log.Client;
import com.aliyun.openservices.log.common.Consts;
import com.aliyun.openservices.log.common.LogGroupData;
import com.aliyun.openservices.log.exception.LogException;
import com.aliyun.openservices.log.request.PullLogsRequest;
import com.aliyun.openservices.log.response.PullLogsResponse;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

public class PullLogsDemo {
    //日志服务的服务入口。更多信息,请参见服务入口。此处以杭州为例,其它地域请根据实际情况填写。
    private static final String endpoint = "cn-hangzhou.log.aliyuncs.com";
    //阿里云访问密钥AccessKey。更多信息,请参见访问密钥。阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维。
    private static final String accessKeyId = "your_access_id";
    private static final String accessKeySecret = "your_access_key";
    //Project名称。
    private static final String project = "your_project";
    //Logstore名称。
    private static final String logStore = "your_logstore";

    public static void main(String[] args) throws Exception{

        //创建日志服务Client。
        Client client = new Client(endpoint, accessKeyId, accessKeySecret);
        //查询Logstore的Shard数量。
        int shardCount = client.GetLogStore(project, logStore).GetLogStore().GetShardCount();
        System.out.println(String.format("%s has %d shards", logStore, shardCount));

        // 从头开始消费,获取游标。(如果是从尾部开始消费,使用Consts.CursorMode.END)
        List<String> cursors = new ArrayList<String>(shardCount);
        for (int i = 0; i < shardCount; i++) {
            cursors.add(i, client.GetCursor(project, logStore, i, Consts.CursorMode.BEGIN).GetCursor());
        }
        // 按照Shard进行日志消费。
        try{
            do {
                for (int i = 0; i < shardCount; i++) {
                    // 从每个Shard中获取日志。
                    PullLogsRequest request = new PullLogsRequest(project, logStore, i, 1000, cursors.get(i));
                    PullLogsResponse response = client.pullLogs(request);
                    // 日志都在日志组(LogGroup)中,按照逻辑拆分即可。
                    List<LogGroupData> logGroups = response.getLogGroups();
                    System.out.println(String.format("Get %d logGroup from logStore:%s:\tShard:%d", logGroups.size(), logStore, i));
                    // 打印完成后,移动游标。
                    cursors.set(i, response.getNextCursor());
                }
                TimeUnit.SECONDS.sleep(3);
            } while (true);
        }catch (LogException e) {
            System.out.println("error code :" + e.GetErrorCode());
            System.out.println("error message :" + e.GetErrorMessage());
            throw e;
        }

    }
}
更多关于日志服务SDK的信息请参见日志服务SDK参考

消费预览

消费预览也是一种日志消费。日志服务控制台提供消费预览功能,帮助您通过控制台直接预览Logstore中的部分日志数据。

  1. 登录日志服务控制台
  2. 在Project列表区域,单击目标Project。
  3. 日志存储 > 日志库页签中,单击目标Logstore。
  4. 选择目标Logstore右侧的日志预览 > 消费预览
  5. 消费预览页面,选择指定预览的Shard与时间段,单击预览
    消费预览页面向您展示指定时间区间开始的10个数据包的日志数据。xiaofei