Amazon DynamoDBにクライアントサイドJSでアクセスしてみる

lib/aws-java-sdk-1.11.65.jar
third-party/lib/aspectjrt-1.8.2.jar
third-party/lib/aspectjweaver.jar
third-party/lib/commons-codec-1.9.jar
third-party/lib/commons-logging-1.1.3.jar
third-party/lib/freemarker-2.3.9.jar
third-party/lib/httpclient-4.5.2.jar
third-party/lib/httpcore-4.4.4.jar
third-party/lib/ion-java-1.0.1.jar
third-party/lib/jackson-annotations-2.6.0.jar
third-party/lib/jackson-core-2.6.6.jar
third-party/lib/jackson-databind-2.6.6.jar
third-party/lib/jackson-dataformat-cbor-2.6.6.jar
third-party/lib/javax.mail-api-1.4.6.jar
third-party/lib/jmespath-java-1.11.65.jar
third-party/lib/joda-time-2.8.1.jar
third-party/lib/spring-beans-3.0.7.RELEASE.jar
third-party/lib/spring-context-3.0.7.RELEASE.jar
third-party/lib/spring-core-3.0.7.RELEASE.jar
third-party/lib/spring-test-3.0.7.RELEASE.jar

　LambdaLogger logger = null;
　//
　static final AWSCredentials CREDENTIALS = new BasicAWSCredentials("[Access key ID]","[Secret access key]");
　static final Region TARGET_REGION = Region.getRegion(Regions.[Region]);
　static final String TABLE_NAME = "watsonTokens";
　//
　AmazonDynamoDBClient dynamoDB = null;

　protected void _log(String input) {
　　this.logger.log(input+"\n");
　}

　public void putItem(String key, String value) {

　　_log("putItem key ["+key+"] value["+value+"]");

　　Map<String, AttributeValue> item = new HashMap<String, AttributeValue>();
　　item.put("tokenType", new AttributeValue().withS(key));
　　item.put("data", new AttributeValue().withS(value));

　　PutItemRequest putItemRequest = new PutItemRequest(TABLE_NAME, item);

　　PutItemResult putItemResult = this.dynamoDB.putItem(putItemRequest);

　　_log("putItem Result["+putItemResult+"]");
　}

　@Override
　public Object handleRequest(Object input, Context context) {
　　this.logger = context.getLogger();

　　try{
　　　Map<String, OkHttpClient> connMap = new HashMap<String, OkHttpClient>();
　　　Map<String, UrlInfo> accMap = new HashMap<String, UrlInfo>();
　　　accMap.put("TTStoken", new UrlInfo("https://stream.watsonplatform.net/authorization/api/v1/token?url=https%3A%2F%2Fstream.watsonplatform.net%2Ftext-to-speech%2Fapi","************************************", "************"));
　　　accMap.put("STTtoken", new UrlInfo("https://stream.watsonplatform.net/authorization/api/v1/token?url=https%3A%2F%2Fstream.watsonplatform.net%2Fspeech-to-text%2Fapi","************************************", "************"));
　　　//
　　　this.dynamoDB = new AmazonDynamoDBClient(CREDENTIALS);
　　　this.dynamoDB.setRegion(TARGET_REGION);
　　　//
　　　for(Map.Entry<String, UrlInfo> elem : accMap.entrySet()) {

　　　　String key = elem.getKey();
　　　　UrlInfo urlInfo = elem.getValue();

　　　　connMap.put( key, new OkHttpClient() );
　　　　Request request = new Request.Builder()
　　　　　.url(urlInfo.getUrl())
　　　　　.header("Authorization", Credentials.basic(urlInfo.getAccessKey(),urlInfo.getAccessSecret()))
　　　　　.build();

　　　　Response response = connMap.get(key).newCall(request).execute();
　　　　if (response.isSuccessful()) {
　　　　　String token = response.body().string();
　　　　　_log("token["+token+"]");
　　　　　//
　　　　　putItem(key, token);
　　　　} else {
　　　　　_log("response error["+response.message()+"]");
　　　　}
　　　}
　　}
　　catch (Exception e){
　　　_log(e.toString());
　　}
　　return null;
}

<script src="https://sdk.amazonaws.com/js/aws-sdk-2.7.13.min.js"></script>
<script type="text/javascript">
<!--
　var ACCESSKEYID = "[Access key ID]";
　var SECRETACCESSKEY = "[Secret access key]";
　var REGION = "[Region]";
　var TABLENAME = "watsonTokens";

　AWS.config.update({accessKeyId: ACCESSKEYID, secretAccessKey: SECRETACCESSKEY});
　var table = new AWS.DynamoDB({params: {TableName: TABLENAME}, region: REGION });
　table.getItem({
　　Key:{ tokenType:{S:'STTtoken'}}
　},function(err,data){
　　if( err === null ){
　　　console.log( "STTtoken [" + data.Item.data.S + "]" );
　　　// Tokenを使用してWatson STT処理
　　}
　});
　table.getItem({
　　Key:{ tokenType:{S:'TTStoken'}}
　},function(err,data){
　　if( err === null ){
　　　console.log( "TTStoken [" + data.Item.data.S + "]" );
　　　// Tokenを使用してWatson TTS処理
　　}
　});
//-->
</script>