993. (Android/Java) [간단 소스] 안드로이드 Aws Kvs HLS getHLSStreamingSessionURL 호출 시 필요한 Signature V4 서명 방법

---

[개발 환경 설정]

​

개발 툴 : AndroidStudio

개발 언어 : Java / Kotlin

​

 

---

[소스 코드]

​

// --------------------------------------------------------------------------------------
[개발 및 테스트 환경]
// --------------------------------------------------------------------------------------

- 언어 : Java / Kotlin

- 개발 툴 : AndroidStudio

- 기술 구분 : Aws / Kvs / Kinesis Video Streams

// --------------------------------------------------------------------------------------






// --------------------------------------------------------------------------------------
[사전) 필요 설정 정리] : build.gradle 의존성 부여
// --------------------------------------------------------------------------------------

// [AWS] : [target 31 이상 의존성]
implementation 'com.amazonaws:aws-android-sdk-kms:2.57.0'
implementation 'com.amazonaws:aws-android-sdk-s3:2.57.0'
implementation 'com.amazonaws:aws-android-sdk-iot:2.57.0'
implementation 'com.amazonaws:aws-android-sdk-mobile-client:2.57.0'
implementation 'com.amazonaws:aws-android-sdk-kinesisvideo:2.57.0'

// --------------------------------------------------------------------------------------





// --------------------------------------------------------------------------------------
[소스 코드]
// --------------------------------------------------------------------------------------

// --------------------------------------------------------
// TODO [필요 변수 선언]
// --------------------------------------------------------
String ACCESS_KEY = "AD ..FE";
String SECRET_KEY = "df2 ..";
String REGION = "ap-northeast-2";
String STREAM_NAME = "TWOK_DEVICE";
// --------------------------------------------------------


// --------------------------------------------------------
// TODO [AWSCredentials 자격 증명 초기화 수행]
// --------------------------------------------------------
AWSCredentials credentials = new BasicAWSCredentials(ACCESS_KEY, SECRET_KEY);
// --------------------------------------------------------


// --------------------------------------------------------
// TODO [Http 요청 시 필요한 Body 데이터 정의]
// --------------------------------------------------------
JSONObject payload = new JSONObject();
payload.put("StreamName", STREAM_NAME);
payload.put("PlaybackMode", "LIVE");

byte[] contentBytes = payload.toString().getBytes("UTF-8"); // String To Bytes

RequestBody requestBody = RequestBody.create(payload.toString(), MediaType.parse("application/json"));
// --------------------------------------------------------


// --------------------------------------------------------
// TODO [AWS Signature V4 서명 적용]
// --------------------------------------------------------
// import com.amazonaws.DefaultRequest;
// import com.amazonaws.Request;
// --------------------------------------------------------
Request<?> signRequest = new DefaultRequest<>("kinesisvideo"); // Service Name : kinesisvideo

signRequest.setHttpMethod(HttpMethodName.POST); // TODO [Http 요청 메소드 타입]
signRequest.setEndpoint(new URI(dataEndpoint)); // TODO [DataEndpoint 적용]
signRequest.setEncodedResourcePath("/getHLSStreamingSessionURL"); // TODO [Path 설정 : 해당 값 추가 중요]

signRequest.addHeader("Host", new URI(dataEndpoint).getHost()); // TODO [호스트 지정]
signRequest.addHeader("Content-Length", String.valueOf(contentBytes.length)); // TODO [Body Length]
signRequest.addHeader("Content-Type", "application/json"); // TODO [Body 에서 지정한 MediaType 타입]

signRequest.setContent(new ByteArrayInputStream(contentBytes)); // TODO [Body Data]
// --------------------------------------------------------
AWS4Signer signer = new AWS4Signer();

signer.setServiceName("kinesisvideo");
signer.setRegionName(REGION);

signer.sign(signRequest, credentials); // TODO [Sign 인증 수행]
// --------------------------------------------------------


// --------------------------------------------------------
// TODO [서명된 헤더들을 okhttp 헤더에 반영]
// --------------------------------------------------------
Headers.Builder okHttpHeaders = new Headers.Builder();
for (Map.Entry<String, String> entry : signRequest.getHeaders().entrySet()) {
    okHttpHeaders.add(entry.getKey(), entry.getValue());
    S_Log.w("KWON_TWOK", ">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> Okhttp Header Insert :: " + String.valueOf(entry.getKey()) + " :: " + String.valueOf(entry.getValue()) + " >>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
}
// --------------------------------------------------------

// --------------------------------------------------------------------------------------





// --------------------------------------------------------------------------------------
[참고 사이트]
// --------------------------------------------------------------------------------------

[kvs (Kinesis Video Streams) , HLS (HTTP 라이브 스트리밍) 설명 및 정리]

https://blog.naver.com/kkh0977/223724719256?trackingCode=blog_bloghome_searchlist


[AWS 사이트 주요 질문 정리 사이트]

https://aws.amazon.com/ko/kinesis/video-streams/faqs/


[Aws Kvs 실시간 영상 업로드 위한 엔드포인트 정보 확인 - GetDataEndpointRequest]

https://blog.naver.com/kkh0977/223855177383


[API 요청용 AWS Signature Version 4]

https://docs.aws.amazon.com/ko_kr/IAM/latest/UserGuide/reference_sigv.html

// --------------------------------------------------------------------------------------

 

---

[참고 사이트]

​

https://blog.naver.com/kkh0977/223855177383

984. (Android/Java) [간단 소스] Aws Kvs 실시간 영상 업로드 위한 엔드포인트 정보 확인 - GetDataEndpointReq

---