ブログ

/**
 * アクセストークンを取得サンプルコード
 */
private void acquireAccessToken() throws Exception {
    URL url = new URL(this.oauthTokenUrl);
    HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    conn.setRequestMethod("POST");
    conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
    conn.setDoOutput(true);

    // リクエストボディを作成
    String params = String.format("grant_type=client_credentials&client_id=%s&client_secret=%s",
            URLEncoder.encode(this.oauthClientId, StandardCharsets.UTF_8.name()),
            URLEncoder.encode(this.oauthClientSecret, StandardCharsets.UTF_8.name()));

    // リクエストを送信
    try (OutputStream os = conn.getOutputStream()) {
        os.write(params.getBytes(StandardCharsets.UTF_8));
    }

    // レスポンスを処理
    if (conn.getResponseCode() == HttpURLConnection.HTTP_OK) {
        try (BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(), StandardCharsets.UTF_8))) {
            String response = br.lines().collect(Collectors.joining("\n"));
            JSONObject jsonResponse = new JSONObject(response);
            this.accessToken = jsonResponse.getString("access_token");
        }
    } else {
        // エラー処理 (ここでは省略)
    }
}


/**
 * AuditLog APIをページネーションで全件取得し、一時的なCSVファイルに書き込みます。
 */
private void fetchAndStoreAuditLogs() throws Exception {
    // データを書き込むための一時ファイルを作成
    this.tempCsvFilePath = Files.createTempFile("auditlog_data_", ".csv");
    List<String> csvHeaders = null; // CSVのヘッダー情報を保持するリスト

    // ページネーションのためのループ
    boolean hasMorePages = true;
    String nextHandle = null; // 次のページを取得するための目印

    try (BufferedWriter csvWriter = Files.newBufferedWriter(this.tempCsvFilePath, StandardCharsets.UTF_8)) {
        while (hasMorePages) {
            // ■ APIリクエストURLを構築
            String currentRequestUrl;
            if (nextHandle != null) {
                // 2ページ目以降: handleパラメータで次のページを指定
                currentRequestUrl = String.format("%s?handle=%s",
                        this.auditLogServiceApiEndpointUrl,
                        URLEncoder.encode(nextHandle, StandardCharsets.UTF_8.name()));
            } else {
                // 1ページ目: time_fromとtime_toで期間を指定
                String startTime = this.logPeriodStartUtc.format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);
                String endTime = this.logPeriodEndUtc.format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);
                currentRequestUrl = String.format("%s?time_from=%s&time_to=%s",
                        this.auditLogServiceApiEndpointUrl,
                        URLEncoder.encode(startTime, StandardCharsets.UTF_8.name()),
                        URLEncoder.encode(endTime, StandardCharsets.UTF_8.name()));
            }

            // APIを呼び出し
            URL url = new URL(currentRequestUrl);
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
            conn.setRequestMethod("GET");
            conn.setRequestProperty("Authorization", "Bearer " + this.accessToken); // 取得したトークンを設定

            // レスポンスを処理
            if (conn.getResponseCode() != HttpURLConnection.HTTP_OK) {
                throw new RuntimeException("AuditLog APIの呼び出しに失敗しました。 HTTP Status: " + conn.getResponseCode());
            }

            // レスポンスボディ（JSON配列）を読み込む
            String responseJsonString;
            try (BufferedReader apiReader = new BufferedReader(new InputStreamReader(conn.getInputStream(), StandardCharsets.UTF_8))) {
                responseJsonString = apiReader.lines().collect(Collectors.joining("\n"));
            }
            JSONArray logDataArray = new JSONArray(responseJsonString);

            // CSVファイルへの書き込み
            if (!logDataArray.isEmpty()) {
                // 最初のデータからヘッダーを動的に作成
                if (csvHeaders == null) {
                    JSONObject firstRecord = logDataArray.getJSONObject(0);
                    csvHeaders = new ArrayList<>(firstRecord.keySet());
                    csvWriter.write(String.join(",", csvHeaders));
                    csvWriter.newLine();
                }

                // 各レコードをCSV形式で追記
                for (int i = 0; i < logDataArray.length(); i++) {
                    JSONObject record = logDataArray.getJSONObject(i);
                    List<String> values = new ArrayList<>();
                    for (String header : csvHeaders) {
                        values.add(escapeCsvValue(record.optString(header, "")));
                    }
                    csvWriter.write(String.join(",", values));
                    csvWriter.newLine();
                }
            }

            // ページネーションの判定
            // レスポンスヘッダーの "Paging" から次のページのハンドルを取得
            String pagingHeader = conn.getHeaderField("Paging");
            if (pagingHeader != null && pagingHeader.toLowerCase().startsWith("handle=")) {
                nextHandle = pagingHeader.substring("handle=".length()).trim();
                hasMorePages = true; // 次のページがあるのでループ継続
            } else {
                hasMorePages = false; // 次のページがないのでループ終了
            }
        }
    }
}