노트 템플릿 시리즈

# PowerShell 권한설정 Get-ExecutionPolicy Set-ExecutionPolicy AllSigned # Chocolatey 설치 (세션 정책변경, TLS 프로토콜 활성화) Set-ExecutionPolicy Bypass -Scope Process -Force; [System.Net.ServicePointManager]::SecurityProtocol = [System.Net.ServicePointManager]::SecurityProtocol -bor 3072; iex ((New-Object System.Net.WebClient).DownloadString('https://community.chocol atey.org/install.ps1')) # 정상 실행 및 버전확인 choco choco install jdk11 choco install jq choco install spring-boot-cli

@SpringBootApplication public class ProductServiceApplication { // .. // ContextRefreshedEvent => 새로고침시 발생 @EventListener(ContextRefreshedEvent.class) public void initIndicesAfterStartup() { // .. } }

@EnableBinding(Sink.class) // Spring Cloud Stream에서 사용하는 어노테이션 public class MessageProcessor { // .. // 이벤트 처리 @StreamListener(target = Sink.INPUT) public void process(Event<Integer, Product> event) { // ... } }

@Bean RestTemplate restTemplate() { return new RestTemplate(); }

@Autowired public ProductCompositeIntegration( WebClient.Builder webClient, RestTemplate restTemplate, ObjectMapper mapper, @Value("${app.product-service.host}") String productServiceHost, @Value("${app.product-service.port}") int productServicePort ) { this.webClient = webClient.build(); this.restTemplate = restTemplate; this.mapper = mapper; productServiceUrl = "http://" + productServiceHost + ":" + productServicePort + "/product"; }

@Autowired HealthAggregator healthAggregator; @Autowired ProductCompositeIntegration integration; @Bean ReactiveHealthIndicator coreServices() { ReactiveHealthIndicatorRegistry registry = new DefaultReactiveHealthIndicatorRegistry(new LinkedHashMap<>()); registry.register("product", () -> integration.getProductHealth()); return new CompositeReactiveHealthIndicator(healthAggregator, registry); }

private Mono<Health> getHealth(String url) { url += "/actuator/health"; LOG.debug("Will call the Health API on URL: {}", url); return webClient.get().uri(url).retrieve().bodyToMono(String.class) .map(s -> new Health.Builder().up().build()) .onErrorResume(ex -> Mono.just(new Health.Builder().down(ex).build())) .log(); }

api: common: version: 1.0.0 title: Sample API description: Description of the API... termsOfServiceUrl: MINE TERMS OF SERVICE URL license: License licenseUrl: MY LICENSE URL contact: name: Contact url: My email: me@mail.com product-composite: get-composite-product: description: Returns a composite view of the specified product id notes: | # Normal response If the requested product id is found the method will return information regarding: 1. Base product information 1. Reviews 1. Recommendations 1. Service Addresses\n(technical information regarding the addresses of the microservices that created the response) # Expected partial and error responses In the following cases, only a partial response be created (used to simplify testing of error conditions) ## Product id 113 200 - Ok, but no recommendations will be returned ## Product id 213 200 - Ok, but no reviews will be returned ## Non numerical product id 400 - A <b>Bad Request</b> error will be returned ## Product id 13 404 - A <b>Not Found</b> error will be returned ## Negative product ids 422 - An <b>Unprocessable Entity</b> error will be returned

@Api(description = "REST API for composite product information.") public interface ProductCompositeService { /** * Sample usage: curl $HOST:$PORT/product-composite/1 * * @param productId * @return the composite product info, if found, else null */ @ApiOperation( value = "${api.product-composite.get-composite-product.description}", notes = "${api.product-composite.get-composite-product.notes}") @ApiResponses(value = { @ApiResponse(code = 400, message = "Bad Request, invalid format of the request. See response message for more information."), @ApiResponse(code = 404, message = "Not found, the specified id does not exist."), @ApiResponse(code = 422, message = "Unprocessable entity, input parameters caused the processing to fails. See response message for more information.") }) @GetMapping( value = "/product-composite/{productId}", produces = "application/json") ProductAggregate getProduct(@PathVariable int productId); }

# kubectl 다운로드 및 설치 확인 curl -o kubectl.exe https://s3.us-west-2.amazonaws.com/amazon-eks/1.22.6/2022-03-09/bin/windows/amd64/kubectl.exe kubectl version --short --client # eksctl 다운로드 및 설치 확인 choco install -y eksctl eksctl version aws eks로 kubeconfig 설정