全部产品
业务实时监控服务 ARMS

SDK for Java

更新时间:2017-09-11 10:26:12   分享:   

本文为 Java 示例。

引入 POM 依赖

  1. <dependency>
  2. <groupId>com.aliyun.openservices</groupId>
  3. <artifactId>aliyun-log</artifactId>
  4. <version>0.6.6</version>
  5. </dependency>

开始一个 Java 程序

  1. ```java
  2. public class LogstashForJavaDemo {
  3. public static void main(String[] args) throws LogException {
  4. DateFormat dateFormat = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  5. /**
  6. * endpoint: 数据写入存储所在区域
  7. * project,logstore: 构成基本数据存储目标
  8. * accessKeyId,accessKeySecret: 构成访问密钥
  9. *
  10. * 注意: 请用户根据实际情况填写
  11. */
  12. String endpoint = "cn-hangzhou.log.aliyuncs.com";
  13. String project = "proj-arms-7dd6ecb06d21e02aed9eeb56b79e9f";
  14. String logstore = "logstore-56f96ec5546fb6555ef97dd057acb4e9";
  15. String accessKeyId = "uamEirofbYdTLexL";
  16. String accessKeySecret = "PBjsdr2dggBoYBrrprc9w02tX9UxBH";
  17. int logGroupSize = 10;// 建议100-2000,每个batch发送数据上限
  18. List<String> examples = new ArrayList<String>();
  19. examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=男装&区域=杭州&eventTeyp=1&性别=1&价格=2140|");
  20. examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=家居&区域=上海&eventTeyp=3&性别=0&价格=8305|");
  21. examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=食品&区域=深圳&eventTeyp=3&性别=1&价格=7121|");
  22. examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=男装&区域=上海&eventTeyp=3&性别=1&价格=2917|");
  23. examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=食品&区域=上海&eventTeyp=1&性别=1&价格=4285|");
  24. examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=男装&区域=杭州&eventTeyp=3&性别=1&价格=7864|");
  25. examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=女装&区域=杭州&eventTeyp=5&性别=0&价格=2983|");
  26. examples.add("|c0a895e114526786450161001d1ed9|9|EADS|BIZ-MONITOR|0|类目=食品&区域=深圳&eventTeyp=5&性别=1&价格=3201|");
  27. // 构建一个客户端实例
  28. Client client = new Client(endpoint, accessKeyId, accessKeySecret);
  29. // 连续发送10个数据包,每个数据包有10条日志
  30. long currentTime = System.currentTimeMillis();
  31. String formatedTime = dateFormat.format(new Date(currentTime));
  32. for (int i = 0; i < 10; i++) {
  33. Vector<LogItem> logGroup = new Vector<LogItem>();
  34. for (int j = 0; j < logGroupSize; j++) {
  35. LogItem logItem = new LogItem();
  36. logItem.PushBack("content", formatedTime + examples.get(j % examples.size()) + UUID.randomUUID());
  37. logGroup.add(logItem);
  38. }
  39. PutLogsRequest req = new PutLogsRequest(project, logstore, "", "", logGroup);
  40. client.PutLogs(req);
  41. }
  42. System.out.println("send data success");
  43. }
  44. }
  45. ```

重要参数说明

参数 说明
endpoint 数据写入区域(endpoint 列表)
accessKeyId 写入数据时的秘钥 id
accessKeySecret 写入数据时的秘钥密码
project 写入数据的 project id
logstore 写入数据的 logstore id

注意:

  • ARMS 颁发的 accessKeyId,accessKeySecret 非用户阿里云 AK/SK,需要从 ARMS 获取,请查阅读获取方式
  • project id 和 logstore id 唯一确定一个数据源。
本文导读目录
本文导读目录
以上内容是否对您有帮助?