Java API 서비스 미터링 개발 가이드

Table of Contents
1.​개요​
​문서 개요​
​목적​
​범위​
​참고자료​
2.​JAVA API 서비스 미터링 개발가이드​
​개요​
​개발 환경 구성​
​CF-Abacus 설치​
​샘플 API 서비스 개발​
​gradle 프로젝트를 생성​
​샘플 API 서비스 형상​
​의존성 및 프로퍼티의 설정​
​MeteringAuthService 클래스​
​MeteringService 클래스​
​SampleApiJavaServiceController 클래스​
​API 서비스 연동 샘플 애플리케이션​
​API 서비스 연동 샘플 애플리케이션 인터페이스 항목​
​미터링/등급/과금 정책​
​미터링 정책​
​등급 정책​
​과금 정책​
​정책 등록​
​배포​
​파스-타 플랫폼 로그인​
​API 서비스 브로커 생성​
​API 서비스 애플리케이션 배포 및 서비스 등록​
​API 서비스 연동 샘플 애플리케이션 배포 및 서비스 연결​
​API 및 CF-Abacus 연동 테스트​
​샘플 코드​
1. 개요
1.1. 문서 개요
1.1.1. 목적
본 문서(Java API 서비스 미터링 적용개발 가이드)는 파스-타 플랫폼 프로젝트의 미터링 플러그인과 Java API 미터링 서비스 애플리케이션을 연동시켜 API 서비스를 미터링 하는 방법에 대해 기술 하였다.
1.1.2. 범위
본 문서의 범위는 파스-타 플랫폼 프로젝트의 JAVA API 서비스 애플리케이션에 대한 미터링 방법에 대한 개발과 CF-Abacus 연동에 대한 내용으로 한정되어 있다.
본 문서는 API 미터링 서비스 애플리케이션을 Java 언어로 작성 하는 것에 대해 기술 한다.
본 문서는 API 서비스 고유의 비즈니스 로직은 구현 하지 않으며, API 서비스 호출 시의 미터링을 하는 기능만 구현 한다.
본 문서에서 언급 하는 “API 서비스를 사용하는 애플리케이션”은 별도로 제공 하는 Node.js API 미터링 개발 가이드를 참고 하여 개발 한다.
1.1.3. 참고 자료
​https://docs.cloudfoundry.org/devguide/​
​https://github.com/cloudfoundry-incubator/cf-abacus​
2. JAVA API 서비스 미터링 개발가이드
2.1 개요
API 서비스 애플리케이션을 Java 언어로 작성 한다. API 서비스는 서비스 요청을 처리함과 동시에 API 사용 내역을 CF-ABACUS에 전송하는 애플리케이션을 작성 한다.
기능
설명
​
Runtime
미터링/등급/과금 정책
API 서비스 제공자가 제공하는 서비스에 대한 각종 정책 정의 정보. JSON 형식으로 되었으며, 해당 정책을 CF-ABACUS에 등록하면 정책에 정의한 내용에 따라 API 사용량을 집계 한다.
 정책은 서비스 제공자가 정의해야 하며, JSON 스키마는 다음을 참조한다.
 https://github.com/cloudfoundry-incubator/cf-abacus/blob/master/doc/api.md
서비스 브로커 API
Cloud Controller와 Service Broker 사이의 규약으로써 서비스 브로커 API 개발에 대해서는 다음을 참조한다.
 https://github.com/OpenPaaSRnD/Documents/blob/master/Development-Guide/ServicePack_develope_guide.md#11
​
서비스 API
서비스 제공자가 제공하는 API 서비스 기능 및 API 사용량을 CF-ABACUS에 전송하는 기능으로 구성되었다.
​
대시보드
서비스를 제공하기 위한 인증, 서비스 모니터링 등을 위한 대시보드 기능으로 서비스 제공자가 개발해야 한다.
​
CF-ABACUS
CF-ABACUS 핵심 기능으로써 수집한 사용량 정보를 집계한다.
 CF-ABACUS은 CF 설치 후, CF에 마이크로 서비스 형태로 설치한다. 자세한 사항은 다음을 참조한다.
 https://github.com/cloudfoundry-incubator/cf-abacus
​
※ 본 개발 가이드는 API 서비스 개발에 대해서만 기술하며, 다른 컴포넌트의 개발 또는 설치에 대해서 링크한 사이트를 참조한다.
2.2 개발환경 구성
Java 애플리케이션 개발을 위해 다음과 같은 환경으로 개발환경을 구성 한다.
CF release: v226 이상
java version "1.8.0_101"
springBootVersion : 1.3.0.BUILD-SNAPSHOT
gradle 2.14
Spring Tool Suite 혹은 Eclipse
2.2.1 CF-Abacus 설치
별도 제공하는 Abacus 설치 가이드를 참고하여 CF-Abacus를 설치한다.
2.3 샘플 API 서비스 개발
샘플 api 서비스는 서비스 요청이 있는 경우, 해당 요청에 대한 응답 처리와 api 서비스 요청에 대한 미터링 정보를 CF-ABACUS에 전송하는 처리를 한다.
2.3.1 gradle 프로젝트를 생성
프로젝트 디렉터리를 생성하고, gradle 프로젝트로 초기화 한다
1
$ mkdir sample_api_java_service // 프로젝트 디렉토리
2
$ cd sample_api_java_service/
3
~/sample_api_java_service $ gradle init --type java-library // gradle 초기화
4
: wrapper
5
: init
6
​
7
BUILD SUCCESSFU
8
​
9
Total time: 2.435 secs
10
​
11
This build could be faster, please consider using the Gradle Daemon: 
12
https://docs.gradle.org/2.14/userguide/gradle_daemon.html
Copied!
2.3.2 샘플 API 서비스 형상
의존성 및 프로퍼티 형상 설명
파일
목적
build.gradle
애플리케이션에 필요한 의존성 정보를 기술
.gitignore
Git을 통한 형상 관리 시, 형상 관리를 할 필요가 없는 파일 또는 디렉토리를 설정한다.
manifest.yml
애플리케이션을 파스-타 플랫폼에 배포 시 적용하는 애플리케이션에 대한 환경 설정 정보 
 애플리케이션의 이름, 배포 경로, 인스턴스 수 등을 정의할 수 있다.
gradlew
Linux 환경에서 사용하는 gradlew 빌드 실행 파일 
 gradle 초기화 시 자동 생성 된다.
gradlew.bat
Window 환경에서 사용하는 gradle 빌드 실행 파일 
 gradle 초기화 시 자동 생성 된다.
settings.gradle
gradlew 실행 시 적용하는 환경 설정 파일  
 gradle 초기화 시 자동 생성 된다.
Java 파일 형상 설명
파일
목적
MeteringConfig
애플리케이션 구동 시 metering.properties를 로드 한다
MeteringAuthService
파스-타 플랫폼 상의 UAA 서버에서 abacus-usage-collector 에 대한 접근 권한 토큰을 취득하여 리턴 한다.
MeteringService
API 서비스 사용 요청 이 SampleApiJavaServiceController 에서 처리 될 때 API 서비스 처리에 대해 미터링이 적용된 사용량 보고서를 abacus-usage-collector 에 리포팅 한다.
SampleApiJavaServiceApplication
SpringBoot이 구동할 때, SpringBoot애플리케이션에 필요한 context 객체 들을 로드 한다.
SampleApiJavaServiceController
API 서비스 사용 요청을 처리하는 REST Controller.
 본 샘플 애플리케이션에서는 API 서비스 고유의 비즈니스 로직은 구현 하지 않았으며, API 사용량을 abacus-collector에 전송하는 기능만 수행 한다.
application.properties
SpringBoot이 구동할 때, spring 에 필요한 property
metering.properties
API 사용량을 abacus-collector 전송 시에 설정 할 property 들이 정의 되어 있다.
2.3.3 의존성 및 프로퍼티의 설정
build.gradle
샘플 Api 서비스 애플리케이션이 사용하는 의존성에 대해 기술한다.
1
    중략..
2
​
3
    dependencies {
4
​
5
        // https://mvnrepository.com/artifact/org.springframework/spring-test
6
        compile group: 'org.springframework', name: 'spring-test', version: '2.5'
7
​
8
        providedRuntime("org.springframework.boot:spring-boot-starter-tomcat:${springBootVersion}")
9
        compile("org.springframework.boot:spring-boot-starter-web:${springBootVersion}")
10
​
11
        // 미터링 사용량 객체 생성 dependency
12
        compile("org.json:json:20160212")    // Json object 생성시
13
        compile("com.sun.jersey:jersey-bundle:1.18.1") ")    // https connection 생성시
14
        compile("com.googlecode.json-simple:json-simple:1.1") // json parse 
15
        compile("commons-codec:commons-codec:1.5") // https connection 생성시
16
    }    
17
​
18
    후략..
Copied!
manifest.yml
앱을 CF에 배포할 때 필요한 설정 정보 및 앱 실행 환경에 필요한 설정 정보를 기술 한다.
```yml applications:
name: sample-api-node-service  # 애플리케이션 이름
memory: 512M # 애플리케이션 메모리 사이즈
instances: 1 # 애플리케이션 인스턴스 개수
host: sample-api-java-service
path: ./build/libs/sample_api_java_service.jar # 배포될 애플리케이션의 위치
env:
  SPRING_PROFILES_ACTIVE : cloud
```
metering.properties
API 서비스의 사용량 정보를 abacus-collector에 전송 할 때, 필요한 설정 정보 및 계정 정보를 기술 한다.
1
    # abacus usage collector RESTAPI 의 주소
2
​
3
    abacus.collector = https://abacus-usage-collector.<CF도메인/v1/metering/collected/usage
4
​
5
    # abacus usage collector 가 secured 모드 true / 아닐 경우 false
6
​
7
    abacus.secured = true
8
​
9
    # 파스-타 플랫폼의 uaa server
10
​
11
    uaa.server = https://uaa.<CF도메인>
12
​
13
    # abacus usage collector RESTAPI 계정 정보 및 사용권한 (UAA server에 미리 설정)
14
​
15
    uaa.client.id = <abacus.usage.read/write scope 권한을 가진 ID>
16
​
17
    uaa.client.secret = <abacus.usage.read/write scope 권한을 가진 ID 비밀번호>
18
​
19
    uaa.client.scope = abacus.usage.object-storage.write,abacus.usage.object-storage.read
Copied!
2.3.4 MeteringAuthService 클래스
UAA 서버 URL 및 계정 정보를 참조 하여, UAA token 을 취득하여 리턴 한다.
1
public String getUaacTokenHTTPS () throws MalformedURLException {
2
​
3
    String authToken = "";
4
    String urlStr = authServer + "/oauth/token?grant_type=client_credentials&scope=" + encodeURIComponent(scope);
5
    StringBuffer sb = new StringBuffer();
6
​
7
    try {
8
​
9
        TrustManager[] trustAllCerts = new TrustManager[] { new X509TrustManager() {
10
            public java.security.cert.X509Certificate[] getAcceptedIssuers() {
11
                return null;
12
            }
13
​
14
            public void checkClientTrusted(X509Certificate[] certs, String authType) {
15
            }
16
​
17
            public void checkServerTrusted(X509Certificate[] certs, String authType) {
18
            }
19
        } };
20
​
21
        SSLContext sc = SSLContext.getInstance("SSL");
22
        sc.init(null, trustAllCerts, new java.security.SecureRandom());
23
        HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
24
        URL url = new URL(urlStr);
25
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
26
        conn.setRequestMethod("GET");
27
        conn.setDoInput(true);
28
        String authHeader = getAuthKey(clientId, clientSecret);
29
        conn.setRequestProperty("authorization", authHeader);
30
​
31
        InputStreamReader in = new InputStreamReader((InputStream) conn.getContent());
32
        BufferedReader br = new BufferedReader(in);
33
​
34
        String line;
35
        while ((line = br.readLine()) != null) {
36
            sb.append(line).append("\n");
37
        }
38
​
39
        authToken= parseAuthToken(sb.toString());
40
​
41
        br.close();
42
        in.close();
43
        conn.disconnect();
44
​
45
    } catch (Exception e) {
46
        System.out.println(e.toString());
47
    }
48
​
49
    return authToken;
50
}
Copied!
metering.properties 에서 취득한 계정 정보를 BASE64 로 인코딩 한다.
1
public String getAuthKey(String id, String secret) throws Exception {    
2
    String authKey = "";     
3
    try {    
4
        String encodedConsumerKey = URLEncoder.encode(id, "UTF-8");
5
        String encodedConsumerSecret = URLEncoder.encode(secret, "UTF-8");
6
        String fullKey = encodedConsumerKey + ":" + encodedConsumerSecret;
7
        byte[] encodedBytes = Base64.encodeBase64(fullKey.getBytes());        
8
        authKey = "Basic " + new String(encodedBytes);    
9
    } catch (Exception e) {
10
        e.printStackTrace();            
11
        throw e;
12
    }    
13
    return authKey;
14
}
Copied!
UAA SEVER 에서 리턴 받은 JSON 오브젝트 에서 access_token 을 추출한다.
1
private String parseAuthToken(String jsonStr) throws ParseException{        
2
    String barerStr;        
3
    JSONParser jsonParser = new JSONParser();
4
    JSONObject jsonObject = (JSONObject) jsonParser.parse(jsonStr);
5
    barerStr = (String) jsonObject.get("access_token");        
6
    return barerStr;
7
}
Copied!
2.3.5 MeteringService 클래스
abacus-collector의 Auth 설정 정보에 따라, 전송 방식에 대한 분기 처리를 한다.
1
public void reportUsageData(String orgId, String spaceId, String appId, String planId) throws Exception {
2
    JSONObject serviceUsage = buildServiceUsage(orgId, spaceId, appId, planId);
3
​
4
    if (SECURED.equals(abacusSecured)) {
5
        reportUsageDataHTTPS(serviceUsage);
6
    } else {
7
        reportUsageDataHTTP(serviceUsage);
8
    }
9
}
Copied!
API 사용량을 Abacus-collector에 전송하기 위해, CF 또는 인증 서버로부터 토큰을 취득하여 HTTP header에 설정하고 HTTPS Connection을 생성 한다.
1
public void reportUsageDataHTTPS(JSONObject serviceUsage) throws Exception {
2
    StringBuffer sb = new StringBuffer();
3
    try {
4
        TrustManager[] trustAllCerts = new TrustManager[] { new X509TrustManager() {
5
            public java.security.cert.X509Certificate[] getAcceptedIssuers() {
6
                return null;
7
            }
8
​
9
            public void checkClientTrusted(X509Certificate[] certs, String authType) {
10
            }  // 인증서를 생성 한다.
11
​
12
            public void checkServerTrusted(X509Certificate[] certs, String authType) {
13
            }
14
        } };
15
​
16
        SSLContext sc = SSLContext.getInstance("SSL");
17
        sc.init(null, trustAllCerts, new java.security.SecureRandom());
18
        HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
19
​
20
        URL url = new URL(collectorUrl);
21
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
22
        conn.setRequestMethod("POST");
23
        conn.setDoInput(true);
24
        conn.setDoOutput(true);
25
        conn.setUseCaches(false);
26
​
27
        conn.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
28
​
29
        String bareStr = "bearer " + meteringAuthService.getUaacTokenHTTPS();
30
        conn.setRequestProperty("Authorization", bareStr);
31
​
32
        byte[] out = serviceUsage.toString().getBytes(StandardCharsets.UTF_8);
33
​
34
        DataOutputStream dout = new DataOutputStream(conn.getOutputStream());
35
        dout.write(out);
36
        dout.close();
37
​
38
        InputStreamReader in = new InputStreamReader((InputStream) conn.getInputStream());
39
        BufferedReader br = new BufferedReader(in);
40
​
41
        String line;
42
        while ((line = br.readLine()) != null) {
43
            sb.append(line).append("\n");
44
        }
45
​
46
        System.out.println(sb.toString());
47
        System.out.println(serviceUsage + " was repoerted.");
48
​
49
        br.close();
50
        in.close();
51
        conn.disconnect();
52
​
53
    } catch (Exception e) {
54
        Exception se = new Exception(e);
55
        throw se;
56
    }
57
}
Copied!
API 사용량을 Abacus-collector에 전송하기 위한 HTTP header를 설정하고 HTTP Connection을 생성 한다.
1
public void reportUsageDataHTTP(JSONObject serviceUsage) throws Exception {
2
​
3
    try {
4
        URL url = new URL(collectorUrl);
5
        URLConnection con = url.openConnection();
6
        HttpURLConnection http = (HttpURLConnection) con;
7
        http.setRequestMethod("POST"); // PUT is another valid option
8
        http.setDoOutput(true);
9
        http.setDoInput(true);
10
        http.setUseCaches(false);
11
​
12
        byte[] out = serviceUsage.toString().getBytes(StandardCharsets.UTF_8);
13
        int length = out.length;
14
​
15
        http.setFixedLengthStreamingMode(length);
16
        http.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
17
        http.connect();
18
​
19
        try (OutputStream os = http.getOutputStream()) {
20
            os.write(out);
21
        }
22
​
23
    } catch (IOException e) {
24
        e.printStackTrace();
25
        throw new Exception(e);
26
    }
27
}
Copied!
Abacus-collector에 전송 할 API 서비스 사용량 JSON을 생성 한다.
1
private JSONObject buildServiceUsage (String orgId, String spaceId, String appId, String planId)
2
        throws JSONException {
3
​
4
    LocalDateTime now = LocalDateTime.now();
5
    Timestamp timestamp = Timestamp.valueOf(now);
6
​
7
    JSONObject jsonObjectUsage = new JSONObject ();
8
​
9
    jsonObjectUsage.put ("start", timestamp.getTime());
10
    jsonObjectUsage.put ("end", timestamp.getTime());
11
    jsonObjectUsage.put ("organization_id", orgId);
12
    jsonObjectUsage.put ("space_id", spaceId);
13
    jsonObjectUsage.put ("consumer_id", "app:" + appId);
14
    jsonObjectUsage.put ("resource_id", RESOURCE_ID);
15
    jsonObjectUsage.put ("plan_id", planId);
16
    jsonObjectUsage.put ("resource_instance_id", appId);
17
​
18
    JSONArray measuredUsageArr = new JSONArray ();
19
    JSONObject measuredUsage1 = new JSONObject ();
20
    JSONObject measuredUsage2 = new JSONObject ();
21
    JSONObject measuredUsage3 = new JSONObject ();
22
​
23
    int quantity = 0;
24
​
25
    if (STANDARD_PLAN_ID.equals(planId)) {
26
        quantity = PLAN_STANDARD_QUANTITY;
27
    } else if (EXTRA_PLAN_ID.equals(planId)) {
28
        quantity = PLAN_EXTRA_QUANTITY;
29
    }
30
​
31
    measuredUsage1.put ("measure", MEASURE_1);
32
    measuredUsage1.put ("quantity", quantity);
33
    measuredUsageArr.put(measuredUsage1);
34
    measuredUsage2.put ("measure", MEASURE_2);
35
    measuredUsage2.put ("quantity", 1);
36
    measuredUsageArr.put(measuredUsage2);
37
    measuredUsage3.put ("measure", MEASURE_3);
38
    measuredUsage3.put ("quantity", 0);
39
    measuredUsageArr.put(measuredUsage3);
40
​
41
    jsonObjectUsage.put ("measured_usage", measuredUsageArr);
42
    return jsonObjectUsage;
43
}    
Copied!
API 서비스 미터링 전송 항목 (전송 리포트 JSON 상세)
항목명
유형
설명
예시
​
start
UNIX
Timestamp
API처리 시작 시각
1396421450000
end
UNIX
Timestamp
API처리 응답 시각
1396421451000
space_id
String
API를 호출한 앱의 영역 ID
d98b5916-3c77-44b9-ac12-04456df23eae
​
resource_id
String
API 자원 ID
sample_api
​
plan_id
String
API 미터링 Plan ID
basic
​
resource_instance_id
String
API를 호출한 앱 ID
d98b5916-3c77-44b9-ac12-04d61c7a4eae
​
measured_usage
Array
미터링 항목
-
​
measure
String
미터링 대상 명
api_calls
​
quantity
Number
해당 API 요청에 대한 API 처리 횟수
10
​
※ JSON 변환 예제
1
{
2
  "start": 1396421450000,
3
  "end": 1396421451000,
4
  "organization_id": "us-south:54257f98-83f0-4eca-ae04-9ea35277a538",
5
  "space_id": "d98b5916-3c77-44b9-ac12-04456df23eae",
6
  "consumer_id": "app:d98b5916-3c77-44b9-ac12-045678edabae",
7
  "resource_id": "sample_api",
8
  "plan_id": "basic",
9
  "resource_instance_id": "d98b5916-3c77-44b9-ac12-04d61c7a4eae",
10
  "measured_usage": [
11
    {
12
      "measure": "api_calls",
13
      "quantity": 10
14
    }
15
  ]
Copied!
2.3.6 SampleApiJavaServiceController 클래스
서비스 사용 요청을 처리하는 REST Controller. 본 샘플 애플리케이션에서는 미터링을 하는 기능만 수행 한다.
1
중략..
2
@RequestMapping (value = "/plan1", method = RequestMethod.POST)
3
public ResponseEntity<String> serviceAPIPlan01(@RequestBody String input) throws Exception {    
4
    JSONParser jsonParser = new JSONParser ();
5
    JSONObject jsonObject = (JSONObject) jsonParser.parse(input);    
6
    String orgId = (String) jsonObject.get("organization_id");
7
    String spaceId = (String) jsonObject.get("space_id");    
8
    String appId = (String) jsonObject.get("consumer_id");    
9
    String planId = (String) jsonObject.get("plan_id");    
10
    JSONObject serviceKeyOBJ = (JSONObject) jsonObject.get("credential");    
11
    String serviceKey = (String) serviceKeyOBJ.get("serviceKey");    
12
​
13
    if(!SERVICE_KEY.equals(serviceKey))
14
        return new ResponseEntity<>("credential is wrong", HttpStatus.UNAUTHORIZED);
15
​
16
    meteringService.reportUsageData(orgId, spaceId, appId, planId);        
17
​
18
    String successStr = "orgId:" + orgId + "/ spaceId:" + spaceId + "/ appId:" + appId + "/ planId:" + planId + " was reported to abacus collector.";
19
​
20
    return new ResponseEntity<>(successStr, HttpStatus.OK);
21
} 
22
후략..
Copied!
2.4 API 서비스 연동 샘플 애플리케이션
본 가이드에서는 API 서비스를 호출하는 애플리케이션의 개발에 대해서는 기술하지 않는다. 샘플 애플리케이션의 개발에 대해서는 Node.js API**미터링 개발 가이드의Api서비스 연동 애플리케이션 개발**을 참고 한다.
2.4.1 API 서비스 연동 샘플 애플리케이션 인터페이스 항목
1.  API 서비스 엔드 포인트
1
GET|POST|PUT|DELETE <api_service_restful_api>
Copied!
2.  API 서비스 미터링 전송 항목
항목명
유형
설명
예시
org_id
String
API 서비스를 요청한 앱의 조직 ID
54257f98-83f0-4eca-ae04-9ea35277a538
space_id
String
API 서비스를 요청한 앱의 영역 ID
d98b5916-3c77-44b9-ac12-04456df23eae
consumer_id
String
API 서비스를 요청한 앱 ID
d98b5916-3c77-44b9-ac12-045678edabae
instance_id
String
API 서비스를 요청한 앱의 자원 인스턴스 ID
d98b5916-3c77-44b9-ac12-045678edabad
plan_id
String
앱의 요청한 API 서비스의 plan ID
basic
credentials
JSON
서비스 요청에 필요한 credential 항목을 설정한다.
credentials: {
key: value,
…
}
inputs
JSON
서비스 요청에 필요한 입력 정보를 설정한다.
inputs: {
key:value,
...
}
3.  API 서비스 미터링 전송 항목 예제
1
{
2
  organization_id: 'd6ce3670-ab9c-4453-b993-f2821f54846b',
3
  space_id: 'ab63eaed-7932-4f24-804d-dccb40a68752',
4
  consumer_id: 'ff7476f9-f5b6-420c-96f0-ac39be43de8c',
5
  instance_id: 'ff7476f9-f5b6-420c-96f0-ac39be43de8c',
6
  plan_id: 'standard',
7
  credential: {
8
    'serviceKey': '[cloudfoundry]',
9
    'url': 'http://localhost:9602/plan1'
10
  },
11
  inputs: {
12
    key1: 'val1',
13
    key2: 'val2'
14
  }
15
}
Copied!
2.5. 미터링/등급/과금 정책
서비스, 그리고 서비스 제공자 마다 미터링/등급/과금 정책 다르기 때문에 본 가이드에서는 정책의 개발 예제를 다루지는 않는다. 다만 CF-ABACUS에 적용할 수 있는 형식에 대해 설명한다.
2.5.1. 미터링 정책
미터링 정책이란 수집한 미터링 정보에서 미터링 대상의 지정 및 집계 방식을 정의한 JSON 형식의 오브젝트이다. 서비스 제공자는 미터링 정책 스키마에 맞춰 서비스에 대한 정책을 개발한다.
1.  미터링 정책 스키마
항목명
유형
필수
예시
plan_id
String
O
API 미터링 Plan ID
measures
Array
최소 하나
API 미터링 정보 수집 대상 정의
name
String
O
미터링 정보 수집 대상 명
unit
String
O
미터링 정보 수집 대상 단위
metrics
Array
최소 하나
API 미터링 집계 방식 정의
name
String
O
미터링 정보 수집 대상 명
unit
String
O
미터링 정보 수집 대상 단위
meter
String
X
미터링 정보에 대해서 수집 단계에 적용하는 계산식 또는 변환식
accumulate
String
X
미터링 정보에 대해서 누적 단계에 적용하는 계산식 또는 변환식
aggregate
String
X
미터링 정보에 대해서 집계 단계에 적용하는 계산식 또는 변환식
summarize
String
X
미터링 정보를 보고할 때 적용하는 계산식 또는 변환식
title
String
X
API 미터링 제목
2.  미터링 정책 예제
1
{
2
  "plan_id": "basic-object-storage",
3
  "measures": [
4
    {
5
      "name": "storage",
6
      "unit": "BYTE"
7
    },
8
    {
9
      "name": "api_calls",
10
      "units": "CALL"
11
    }
12
  ],
13
  "metrics": [
14
    {
15
      "name": "storage",
16
      "unit": "GIGABYTE",
17
      "meter": "(m) => m.storage / 1073741824",
18
      "accumulate": "(a, qty) => Math.max(a, qty)"
19
    },
20
    {
21
      "name": "thousand_api_calls",
22
      "unit": "THOUSAND_CALLS",
23
      "meter": "(m) => m.light_api_calls / 1000",
24
      "accumulate": "(a, qty) => a ? a + qty : qty",
25
      "aggregate": "(a, qty) => a ? a + qty : qty",
26
      "summarize": "(t, qty) => qty"
27
    }
28
  ]
29
}
Copied!
2.5.2. 등급 정책
등급 정책이란 각 서비스의 사용 가중치를 정의한 JSON 형식의 오브젝트이다. 서비스 제공자는 등급 정책 스키마에 맞춰 서비스에 대한 정책을 개발한다.
1.  등급 정책 스키마
항목명
유형
필수
설명
plan_id
String
O
API 등급 Plan ID
metrics
Array
최소 하나
등급 정책 목록
name
String
O
등급 정의 대상 명
rate
String
X
가중치 계산식 또는 변환식
charge
String
X
사용량에 대한 과금 계산식 또는 변환식
title
String
X
등급 정책 명
2.  등급 정책 예제
1
{
2
  "plan_id": "object-rating-plan",
3
  "metrics": [
4
    {
5
      "name": "storage"
6
    },
7
    {
8
      "name": "thousand_api_calls",
9
      "rate": "(p, qty) => p ? p * qty : 0",
10
      "charge": "(t, cost) => cost"
11
    }
12
  ]
13
}
Copied!
2.5.3. 과금 정책
과금 정책이란 각 서비스에 대한 사용 단가를 정의한 JSON 형식의 오브젝트이다. 서비스 제공자는 과금 정책 스키마에 맞춰 서비스에 대한 정책을 개발한다.
1.  과금 정책 스키마
항목명
유형
필수
설명
plan_id
String
O
API 과금 Plan ID
metrics
Array
최소 하나
과금 정책 목록
name
String
O
과금 대상 명
price
Array
최소 하나
과금 정책 상세
country
String
O
서비스 사용 단가에 적용할 통화
price
Number
O
서비스 사용 단가
title
String
X
과금 정책 제목
2.  과금 정책 예제
1
{
2
  "plan_id": "object-pricing-basic",
3
  "metrics": [
4
    {
5
      "name": "storage",
6
      "prices": [
7
        {
8
          "country": "USA",
9
          "price": 1
10
        },
11
        {
12
          "country": "EUR",
13
          "price": 0.7523
14
        },
15
        {
16
          "country": "CAN",
17
          "price": 1.06
18
        }
19
      ]
20
    },
21
    {
22
      "name": "thousand_api_calls",
23
      "prices": [
24
        {
25
          "country": "USA",
26
          "price": 0.03
27
        },
28
        {
29
          "country": "EUR",
30
          "price": 0.0226
31
        },
32
        {
33
          "country": "CAN",
34
          "price": 0.0317
35
        }
36
      ]
37
    }
38
  ]
39
}
Copied!
2.5.4. 정책 등록
정책은 2가지 방식 중 하나의 방법으로 CF-ABACUS에 등록할 수 있다.
1.  js 파일을 등록하는 방식
작성한 정책을 다음의 디렉토리에 저장한 후, CF에 CF-ABACUS를 배포 또는 재 배포 한다.
미터링 정책의 경우
1
cf-abacus/lib/plugins/provisioning/src/plans/metering
Copied!
등급 정책의 경우
1
cf-abacus/lib/plugins/provisioning/src/plans/pricing
Copied!
과금 정책의 경우
1
cf-abacus/lib/plugins/provisioning/src/plans/rating
Copied!
2.  DB에 등록하는 방식
작성한 정책을 curl 등을 이용해 DB에 저장하는 방식으로 CF-ABACUS를 재배포할 필요는 없다. 정책 등록 시, 정책 ID는 고유해야 한다.
미터링 정책의 경우
1
POST /v1/metering/plans/:metering_plan_id
Copied!
>
1
## 예제
2
$ curl -k -X POST 'http://abacus-provisioning-plugin.bosh-lite.com/v1/metering/plans/sample-linux-container' \
3
     -H "Content-Type: application/json" \
4
     -d '{"plan_id":"sample-linux-container","measures":[{"name":"current_instance_memory","unit":"GIGABYTE"},{"name":"current_running_instances","unit":"NUMBER"},{"name":"previous_instance_memory","unit":"GIGABYTE"},{"name":"previous_running_instances","unit":"NUMBER"}],"metrics":[{"name":"memory","unit":"GIGABYTE","type":"time-based","meter":"((m)=>({previous_consuming:newBigNumber(m.previous_instance_memory||0).div(1073741824).mul(m.previous_running_instances||0).mul(-1).toNumber(),consuming:newBigNumber(m.current_instance_memory||0).div(1073741824).mul(m.current_running_instances||0).toNumber()})).toString()","accumulate":"((a,qty,start,end,from,to,twCell)=>{if(end<from||end>=to)returnnull;constpast=from-start;constfuture=to-start;consttd=past+future;return{consuming:a&&a.since>start?a.consuming:qty.consuming,consumed:newBigNumber(qty.consuming).mul(td).add(newBigNumber(qty.previous_consuming).mul(td)).add(a?a.consumed:0).toNumber(),since:a&&a.since>start?a.since:start};}).toString()","aggregate":"((a,prev,curr,aggTwCell,accTwCell)=>{if(!curr)returna;constconsuming=newBigNumber(curr.consuming).sub(prev?prev.consuming:0);constconsumed=newBigNumber(curr.consumed).sub(prev?prev.consumed:0);return{consuming:consuming.add(a?a.consuming:0).toNumber(),consumed:consumed.add(a?a.consumed:0).toNumber()};}).toString()","summarize":"((t,qty,from,to)=>{if(!qty)return0;constrt=Math.min(t,to?to:t);constpast=from-rt;constfuture=to-rt;consttd=past+future;constconsumed=newBigNumber(qty.consuming).mul(-1).mul(td).toNumber();returnnewBigNumber(qty.consumed).add(consumed).div(2).div(3600000).toNumber();}).toString()"}]}' \
5
    -H "Authorization: $(cf oauth-token | grep bearer)"
Copied!
등급 정책의 경우
1
 POST /v1/rating/plans/:rating_plan_id
Copied!
>
1
## 예제
2
$ curl -k -X POST 'http://abacus-provisioning-plugin.bosh-lite.com/v1/rating/plans/linux-rating-sample' \
3
     -H "Content-Type: application/json" \
4
     -d '{"plan_id":"linux-rating-sample","metrics":[{"name":"memory","rate":"((price,qty)=>({price:price,consuming:qty.consuming,consumed:qty.consumed})).toString(),charge:((t,qty,from,to)=>{if(!qty)return0;constrt=Math.min(t,to?to:t);constpast=from-rt;constfuture=to-rt;consttd=past+future;constconsumed=newBigNumber(qty.consuming).mul(-1).mul(td).toNumber();constgbhour=newBigNumber(qty.consumed).add(consumed).div(2).div(3600000).toNumber();returnnewBigNumber(gbhour).mul(qty.price).toNumber();}).toString()"}]}' \
5
     -H "Authorization: $(cf oauth-token | grep bearer)"
Copied!
과금 정책의 경우
1
POST /v1/pricing/plans/:pricing_plan_id
Copied!
>
1
## 예제
2
$ curl -k -X POST 'http://abacus-provisioning-plugin.bosh-lite.com/v1/pricing/plans/linux-pricing-sample' \
3
     -H "Content-Type: application/json" \
4
     -d '{"plan_id":"linux-pricing-sample","metrics":[{"name":"memory","prices":[{"country":"USA","price":0.00014}]}]}' \
5
    -H "Authorization: $(cf oauth-token | grep bearer)"
Copied!
2.6. 배포
파스-타 플랫폼에 애플리케이션을 배포하면 배포한 애플리케이션과 파스-타 플랫폼이 제공하는 서비스를 연결하여 사용할 수 있다. 파스-타 플랫폼상에서 실행을 해야만 파스-타 플랫폼의 애플리케이션 환경변수에 접근하여 서비스에 접속할 수 있다.
2.6.1 파스-타 플랫폼 로그인
아래의 과정을 수행하기 위해서 파스-타 플랫폼에 로그인
$ cf api --skip-ssl-validationhttps://api.<파스-타 도메인>#파스-타 플랫폼TARGET지정
$ cf login -u <user name> -o <org name> -s <space name>#로그인 요청
2.6.2. API 서비스 브로커 생성
애플리케이션에서 사용할 서비스를 파스-타 플랫폼을 통하여 생성한다. 별도의 서비스 설치과정 없이 생성할 수 있으며, 애플리케이션과 바인딩과정을 통해 접속정보를 얻을 수 있다.
서비스 생성 (cf marketplace 명령을 통해 서비스 목록과 각 서비스의 플랜을 조회할 수 있다.)
1
##서비스 브로커 CF 배포
2
$ cd <샘플 서비스 브로커 경로>/sample_api_java_broker
3
$ cf push
Copied!
1
      ##서비스 브로커 생성
2
      $ cf create-service-broker <서비스 브로커 명> <인증ID> <인증Password> <서비스 브로커 주소>
3
​
4
      예)
5
      $ cf create-service-broker sample-api-broker admin cloudfoundry http://sample-api-java-broker.bosh-lite.com
6
​
7
      ##서비스 브로커 확인
8
      $ cf service-brokers
9
      Getting service brokers as admin...
10
​
11
     name url
12
      sample-api-broker http://sample-api-java-broker.bosh-lite.com
13
​
14
      ##서비스 카탈로그 확인
15
      $ cf service-access
16
      Getting service access as admin...
17
      broker: sample-api-broker
18
      service plan access orgs
19
      standard_obejct_storage_light_api_calls standard none
20
      standard_obejct_storage_heavy_api_calls basic none
21
​
22
      ##등록한 서비스 접근 허용
23
      $ cf enable-service-access <서비스명> -p <플랜 명>
24
​
25
      예)
26
      $ cf enable-service-access standard_obejct_storage_light_api_calls -p standard
Copied!
2.6.3. API 서비스 애플리케이션 배포 및 서비스 등록
API 서비스 애플리케이션을 파스-타 플랫폼에 배포한다. 서비스 등록한 API는 다른 애플리케이션과 바인다 하여 API 서비스를 할 수 있다.
1.애플리케이션 배포
gradle build -x test 명령으로 빌드 한다.
cf push 명령으로 배포한다. 별도의 값을 넣지않으면 manifest.yml의 설정을 사용한다
API 서비스 배포
$ cd <샘플api서비스 경로>/sample_api_java_service
1
 ## gradle 빌드
2
 $ gradle build -x test
3
 :compileJava
4
 :processResources
5
 :classes
6
 :findMainClass
7
 :jar
8
 :bootRepackage
9
 :assemble
10
 :check
11
 :build
Copied!
BUILD SUCCESSFUL
Total time: 13.426 secs $ cf push
서비스 생성
1
 $ cf create-service <서비스명> <플랜 명> <서비스 인스턴스 명>
2
 예)
3
 $ cf create-service standard_obejct_storage_light_api_calls standard sampleNodejslightCallApi
4
​
5
 ##서비스 확인
6
 $ cf services
7
 Getting services in org real / space ops as admin...
8
 OK
Copied!
name service plan bound apps last operation sampleNodejslightCallApi standard_obejct_storage_light_api_calls standard create succeeded
2.6.4. API 서비스 연동 샘플 애플리케이션 배포 및 서비스 연결
애플리케이션과 서비스를 연결하는 과정을 '바인드(bind)라고 하며, 이 과정을 통해 서비스에 접근할 수 있는 접속정보를 생성한다.
애플리케이션과 서비스 연결
1
## API 서비스 연동 샘플 애플리케이션 배포
2
$ cd <샘플 애플리케이션 경로>/sample_api_node_caller
3
$ npm install && npm run babel && npm run cfpack && ./cfpush.sh
4
​
5
## 서비스 바인드
6
$ cf bind-service <APP_NAME> <SERVICE_INSTANCE> -c <PARAMETERS_AS_JSON>
7
​
8
예) 
9
$ cf bind-service sample-api-node-caller sampleNodejslightCallApi -c '{"serviceKey": "cloudfoundry"}'
10
​
11
## 서비스 연결 확인
12
$ cf services
13
Getting services in org real / space ops as admin...
14
OK
15
​
16
name                       service                                   plan       bound apps               last operation   
17
sampleNodejslightCallApi   standard_obejct_storage_light_api_calls   standard   sample-api-node-caller   create succeeded
18
​
19
## 애플리케이션 실행
20
$ cf start <APP_NAME>
21
​
22
예)
23
$ cf start sample-api-node-caller
24
​
25
## 형상 확인
26
$ cf a
27
Getting apps in org real / space ops as admin...
28
OK
29
​
30
name                      requested state   instances   memory   disk   urls   
31
sample-api-node-service   started           1/1         512M     512M   sample-api-node-service.bosh-lite.com   
32
sample-api-java-broker    started           1/1         512M     1G     sample-api-java-broker.bosh-lite.com   
33
sample-api-node-caller    started           1/1         512M     512M   sample-api-node-caller.bosh-lite.com
Copied!
2.7. API 및 CF-Abacus 연동 테스트
API 연동 샘플 애플리케이션의 url을 통해 웹 브라우저에서 접속하면 API 연동 및 API 사용량에 대한 CF-Abacus 연동 테스트를 진행 할 수 있다.
1.CF-Abacus 연동 확인
1
    ## 조직 guid 확인
2
    $ cf org <샘플 애플리케이션을 배포한 조직> --guid
3
​
4
    예)
5
    $ cf org real --guid
6
    877d01b2-d177-4209-95b0-00de794d9bba
7
​
8
    ## 샘플 애플리케이션 guid 확인
9
    $ cf env <샘플 애플리케이션 명>
10
    예)
11
    $ cf env sample-api-node-caller
12
    Getting env variables for app sample-api-node-caller in org real / space ops as admin...
13
    OK
14
​
15
    <<중략>>
16
    {
17
     "VCAP_APPLICATION": {
18
      "application_id": "58872d8a-edfc-44df-97f0-df67cf9033a7",
19
      "application_name": "sample-api-node-caller",
20
      "application_uris": [
21
       "sample-api-node-caller.bosh-lite.com"
22
      ],
23
      "application_version": "55678102-584c-4fca-8304-82f727506b1d",
24
      "limits": {
25
       "disk": 512,
26
       "fds": 16384,
27
       "mem": 512
28
      },
29
      "name": "sample-api-node-caller",
30
      "space_id": "2ce08996-f463-406c-a971-adbbaf4e4ca5",
31
      "space_name": "ops",
32
      "uris": [
33
       "sample-api-node-caller.bosh-lite.com"
34
      ],
35
      "users": null,
36
      "version": "55678102-584c-4fca-8304-82f727506b1d"
37
     }
38
    }
39
​
40
    <<후략>> 
41
​
42
    ## API 사용량 확인
43
    $ curl 'http://abacus-usage-reporting.<파스-타 도메인>/v1/metering/organizations/<샘플 애플리케이션을 배포한 조직>/aggregated/usage'
44
​
45
    예)
46
    $ curl 'http://abacus-usage-reporting.bosh-lite.com/v1/metering/organizations/877d01b2-d177-4209-95b0-00de794d9bba/aggregated/usage'
Copied!
2.8. 샘플코드
샘플코드는 아래의 사이트에 다운로드 할 수 있다.
​다운로드​
PublicAPI 개발 가이드
Java 서비스 미터링 개발 가이드
Last modified 1yr ago
Copy link
Contents
Table of Contents
1. 개요
1.1. 문서 개요
2. JAVA API 서비스 미터링 개발가이드
2.2 개발환경 구성
2.3 샘플 API 서비스 개발
2.4 API 서비스 연동 샘플 애플리케이션
2.5. 미터링/등급/과금 정책
2.6. 배포
2.7. API 및 CF-Abacus 연동 테스트
2.8. 샘플코드