832      阿里云  技术社区[云栖]

API 数据源__准备数据源_用户指南_业务实时监控服务 ARMS-阿里云

用户可以通过API SDK直接推送数据到 ARMS,从而实现 ARMS 日志流入。

创建 SDKPush 数据源

• 入口

• 授权

ARMS会为用户创建一个AK/SK，用户可以通过这对AK/SK向ARMS中推送数据，请妥善保管。

• 获取ak/sk

• 创建SDKPush数据源

• 数据源使用

在程序中向 SDKPush 数据源推送数据

• 引入 POM 依赖

    <dependency>
      <groupId>com.aliyun.openservices</groupId>
      <artifactId>aliyun-log</artifactId>
      <version>0.6.6</version>
    </dependency>

• SDK 推送数据示例

    int logGroupSize = 1000;//建议100-2000，每个batch发送数据上限
    String accessKeyId = "XXX"; //填写ARMS中获取AK
    String accessKeySecret = "XXX"; //填写ARMS中获取SK
    String endpoint = "XXX";//如cn-qingdao.log.aliyuncs.com
    String project = "XXX"; //例如proj-arms-e4de52c26fca9d24aac2c99392427f2
    String logstore = "XXX";//例如logstore-5071ab07abf2f5af138ba151fcbad2;
    DateFormat dateFormat = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    List<String> examples = new ArrayList<String>();
    examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=男装&区域=杭州&eventTeyp=1&性别=1&价格=2140|");
    examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=家居&区域=上海&eventTeyp=3&性别=0&价格=8305|");
    examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=食品&区域=深圳&eventTeyp=3&性别=1&价格=7121|");
    examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=男装&区域=上海&eventTeyp=3&性别=1&价格=2917|");
    examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=食品&区域=上海&eventTeyp=1&性别=1&价格=4285|");
    examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=男装&区域=杭州&eventTeyp=3&性别=1&价格=7864|");
    examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=女装&区域=杭州&eventTeyp=5&性别=0&价格=2983|");
    examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=食品&区域=深圳&eventTeyp=5&性别=1&价格=3201|");
    // 构建一个客户端实例
    Client client = new Client(endpoint, accessKeyId, accessKeySecret);
    // 连续发送10个数据包，每个数据包有10条日志
    long count = 0;
    long total = 0;
    long beg_time = System.currentTimeMillis();
    for (;;) {
          long currentTime = System.currentTimeMillis();
          String formatedTime = dateFormat.format(new Date(currentTime));
          Vector<LogItem> logGroup = new Vector<LogItem>();
        for (int i = 0; i < logGroupSize; i++) {
            LogItem logItem = new LogItem((int) (new Date().getTime() / 1000));
            logItem.PushBack("content", formatedTime + examples.get(i%examples.size()) + UUID.randomUUID());
    l        ogGroup.add(logItem);
        }
    count = count + logGroupSize;
    long dis = (currentTime - beg_time)/1000;
    if( dis >= 30){
          total = total + count;
          beg_time = currentTime;
          count = 0;
     }
            PutLogsRequest req2 = new PutLogsRequest(project, logstore,"","", logGroup);
            client.PutLogs(req2);

• 重要参数说明

注意：project id和logstore id唯一确定一个数据源