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唯一確定一個數據源