【第34回】AWS CloudFormationを用いた基盤自動化(14)SpringCloudAWSを利用したBackend Serviceアプリケーションにおけるスタック情報の取得・設定¶

package org.debugroom.mynavi.sample.cloudformation.backend.config;

import org.socialsignin.spring.data.dynamodb.repository.config.EnableDynamoDBRepositories;

import org.springframework.context.annotation.Configuration;

@Configuration
@EnableDynamoDBRepositories(
   basePackages = "org.debugroom.mynavi.sample.cloudformation.backend.domain.repository.dynamodb"
)
public class DynamoDBConfig {
}

package org.debugroom.mynavi.sample.cloudformation.backend.config;

import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;

@Configuration
@ComponentScan("org.debugroom.mynavi.sample.cloudformation.backend.app.listener")
public class SQSConfig {
}

package org.debugroom.mynavi.sample.cloudformation.backend.config;

// omit

import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.services.cloudformation.AmazonCloudFormationClient;
import com.amazonaws.services.cloudformation.model.Export;
import com.amazonaws.services.cloudformation.model.ListExportsRequest;
import com.amazonaws.services.cloudformation.model.ListExportsResult;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig;

import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.aws.context.config.annotation.EnableStackConfiguration;
import org.springframework.cloud.aws.core.env.ResourceIdResolver;
import org.springframework.cloud.aws.jdbc.config.annotation.EnableRdsInstance;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Profile;

@Profile("dev")                                                                         // …(A)
@EnableStackConfiguration(stackName = "mynavi-sample-infra-dev")                        // …(B)
@EnableRdsInstance(
    dbInstanceIdentifier = "mynavi-sample-cloudformation-dev-postgresql",
    password = "${rds.password}",
    readReplicaSupport = false)                                                         // …(C)
@Configuration
public class DevConfig implements InitializingBean {                                    // …(D)

    @Autowired
    AmazonCloudFormationClient amazonCloudFormationClient;                              // …(E)

    @Autowired(required = false)
    ResourceIdResolver resourceIdResolver;                                              // …(F)

    @Bean
    public DynamoDBMapperConfig dynamoDBMapperConfig(){                                 // …(G)
       return DynamoDBMapperConfig.builder()
          .withTableNameOverride(
                  DynamoDBMapperConfig.TableNameOverride
                          .withTableNamePrefix("dev_"))
          .build();
   }

   @Bean
   public AmazonDynamoDB amazonDynamoDB(){
       ListExportsResult listExportsResult = amazonCloudFormationClient
          .listExports(new ListExportsRequest());                                       // …(H)
       List<Export> exportList = listExportsResult.getExports();
       List<Export> dynamoDBStackExportList = exportList.stream()
          .filter(export -> export.getExportingStackId().equals(
                  resourceIdResolver.resolveToPhysicalResourceId("DynamoDBDevStack")))  // …(I)
          .collect(Collectors.toList());
       Export dynamoDBServiceEndpointExport = dynamoDBStackExportList.stream()
          .filter(export -> export.getName().equals("MynaviSampleDynamoDB-Dev-ServiceEndpoint"))
          .findFirst().get();                                                           // …(J)
       Export environmentRegionExport = dynamoDBStackExportList.stream()
          .filter(export -> export.getName().equals("MynaviSampleDynamoDB-Dev-Region"))
          .findFirst().get();                                                           // …(K)
       return AmazonDynamoDBClientBuilder.standard()
          .withEndpointConfiguration(
              new AwsClientBuilder.EndpointConfiguration(
                  dynamoDBServiceEndpointExport.getValue(), environmentRegionExport.getValue()))
          .build();                                                                     // …(L)
    }
    // omit
}

package org.debugroom.mynavi.sample.cloudformation.backend.config;

import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig;

import org.springframework.cloud.aws.context.config.annotation.EnableStackConfiguration;
import org.springframework.cloud.aws.jdbc.config.annotation.EnableRdsInstance;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Profile;

import org.debugroom.mynavi.sample.cloudformation.common.apinfra.cloud.aws.CloudFormationStackInfo;

@Profile("staging")                                                                         // …(A)
@EnableStackConfiguration(stackName = "mynavi-sample-infra-staging")                        // …(B)
@EnableRdsInstance(
     dbInstanceIdentifier = "mynavi-sample-cloudformation-staging-postgresql",              // …(C)
     password = "${rds.password}",
     readReplicaSupport = false)
@Configuration
public class StagingConfig {

    private static final String DYNAMODB_STACK_NAME = "DynamoDBStagingStack";               // …(D)
    private static final String DYNAMODB_ENDPOINT_EXPORT = "MynaviSampleDynamoDB-Staging-ServiceEndpoint";
    private static final String DYNAMODB_REGION_EXPORT = "MynaviSampleDynamoDB-Staging-Region";

    @Bean
    CloudFormationStackInfo cloudFormationStackInfo(){                                      // …(E)
        return new CloudFormationStackInfo();
    }

    @Bean
    public DynamoDBMapperConfig dynamoDBMapperConfig() {                                    // …(F)
        return DynamoDBMapperConfig.builder()
             .withTableNameOverride(
                     DynamoDBMapperConfig.TableNameOverride
                             .withTableNamePrefix("staging_"))
             .build();
    }

    @Bean
    public AmazonDynamoDB amazonDynamoDB() {                                                // …(G)
        return AmazonDynamoDBClientBuilder.standard()
             .withEndpointConfiguration(
                     new AwsClientBuilder.EndpointConfiguration(
                             cloudFormationStackInfo().getExportValue(
                                     DYNAMODB_STACK_NAME, DYNAMODB_ENDPOINT_EXPORT),
                             cloudFormationStackInfo().getExportValue(
                                     DYNAMODB_STACK_NAME, DYNAMODB_REGION_EXPORT)))
             .build();
    }

}

package org.debugroom.mynavi.sample.cloudformation.common.apinfra.cloud.aws;

// omit
import com.amazonaws.services.cloudformation.AmazonCloudFormationClient;
import com.amazonaws.services.cloudformation.model.Export;
import com.amazonaws.services.cloudformation.model.ListExportsRequest;
import com.amazonaws.services.cloudformation.model.ListExportsResult;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.cloud.aws.core.env.ResourceIdResolver;
import org.springframework.stereotype.Component;

@Component
public class CloudFormationStackInfo implements InitializingBean {

    @Autowired
    AmazonCloudFormationClient amazonCloudFormationClient;

    @Autowired(required = false)
    ResourceIdResolver resourceIdResolver;

    private List<Export> exportList;

    public String getExportValue(String logicalStackName, String exportName){
        Optional<Export> targetExport = exportList.stream()
          .filter(export -> export.getExportingStackId().equals(
                  resourceIdResolver.resolveToPhysicalResourceId(logicalStackName)))
          .filter(export -> export.getName().equals(exportName))
          .findFirst();
        return targetExport.isPresent() ? targetExport.get().getValue() : null;
    }

    @Override
    public void afterPropertiesSet() throws Exception {
        ListExportsResult listExportsResult = amazonCloudFormationClient
          .listExports(new ListExportsRequest());
        this.exportList = listExportsResult.getExports();
    }

}