引入 POM 依赖
<dependency>
<groupId>com.aliyun.openservices</groupId>
<artifactId>aliyun-log</artifactId>
<version>0.6.6</version>
</dependency>
开始一个 Java 程序
```java
public class LogstashForJavaDemo {
public static void main(String[] args) throws LogException {
DateFormat dateFormat = new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
/**
* endpoint: 数据写入存储所在区域
* project,logstore: 构成基本数据存储目标
* accessKeyId,accessKeySecret: 构成访问密钥
*
* 注意: 请用户根据实际情况填写
*/
String endpoint = "cn-hangzhou.log.aliyuncs.com";
String project = "proj-arms-7dd6ecb06d21e02aed9eeb56b79e9f";
String logstore = "logstore-56f96ec5546fb6555ef97dd057acb4e9";
String accessKeyId = "uamEirofbYdTLexL";
String accessKeySecret = "PBjsdr2dggBoYBrrprc9w02tX9UxBH";
int logGroupSize = 10;// 建议100-2000,每个batch发送数据上限
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 currentTime = System.currentTimeMillis();
String formatedTime = dateFormat.format(new Date(currentTime));
for (int i = 0; i < 10; i++) {
Vector<LogItem> logGroup = new Vector<LogItem>();
for (int j = 0; j < logGroupSize; j++) {
LogItem logItem = new LogItem();
logItem.PushBack("content", formatedTime + examples.get(j % examples.size()) + UUID.randomUUID());
logGroup.add(logItem);
}
PutLogsRequest req = new PutLogsRequest(project, logstore, "", "", logGroup);
client.PutLogs(req);
}
System.out.println("send data success");
}
}
```
重要参数说明
参数 说明
endpoint 数据写入区域(endpoint 列表)
accessKeyId 写入数据时的秘钥 id
accessKeySecret 写入数据时的秘钥密码
project 写入数据的 project id
logstore 写入数据的 logstore id
注意:
ARMS 颁发的 accessKeyId,accessKeySecret 非用户阿里云 AK/SK,需要从 ARMS 获取,请查阅读获取方式。
project id 和 logstore id 唯一确定一个数据源。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。