[AWS] RDS 엘라스틱 캐쉬 - 레디스(Redis) > AWS.클라우드
AWS.클라우드

[AWS] RDS 엘라스틱 캐쉬 - 레디스(Redis)

조회 325회 댓글 0건

AWS Elasticache는 Amazon Web Services(AWS)에서 제공하는 완전 관리형 인메모리 데이터 스토어 및 캐시 서비스입니다. 이 서비스는 레디스와 Memcached를 지원하며, 이를 통해 고성능, 스케일링 가능한 및 비용 효율적인 인메모리 캐시 솔루션을 제공합니다. 

3a431b4e617b1cc09be8a09a9296fb78_1699530217_3883.png
 

Redis는 RDB가 아닙니다.
RDB에서 IO를 줄이거나 슬로우쿼리가 약간 있거나 많은 게시물이 있을때 키 밸류의 인메모리 디비를 사용하면 잇점이 있기 때문에 사용하는 데이터 베이스 입니다.

AWS 엘라스틱캐쉬 REDIS

레디스(Redis)에 대해 설명하자면, Redis는 고성능의 분산 저장 시스템으로서 키-값 구조의 데이터를 메모리에 저장하여 빠른 읽기/쓰기 작업을 가능하게 합니다. Redis는 문자열, 리스트, 세트(set), 정렬된 세트(sorted set), 해시 등 다양한 데이터 타입을 지원합니다.

AWS Elasticache for Redis는 이러한 Redis의 기능들을 AWS 환경에서 사용할 수 있게 해주며, 아래와 같은 주요 기능들이 있습니다

  1. 고성능: AWS Elasticache for Redis는 메모리 내 데이터 처리로 매우 빠른 성능을 제공합니다.
  2. 확장성: 클러스터 크기 조정이나 여러 클러스터 간에 자동 분할(sharding) 등의 기능으로 확장성이 용이합니다.
  3. 내구성과 가용성: 자동 복제(replication), 자동 장애 조치(failover), 백업 및 복원 기능 등으로 데이터 안정성과 서비스 가용성을 보장합니다.
  4. 보안: VPC 네트워크 내에서 동작하며 SSL/TLS 프로토콜로 암호화된 연결을 지원하여 보안을 유지합니다.

require 'vendor/autoload.php';

class DatabaseWithCache {
    private $db;
    private $cache;

    public function __construct($dbHost, $dbName, $dbUser, $dbPassword, $cacheEndpoint) {
        // Initialize MySQL connection
        $this->db = new PDO("mysql:host=$dbHost;dbname=$dbName", $dbUser, $dbPassword);

        // Initialize Redis connection
        $this->cache = new Predis\Client([
            'scheme' => 'tcp',
            'host'   =>  '<elasticache-endpoint>',
            'port'   => 6379,
        ]);
    }

    public function fetch($query, array $params = [], bool $useCache = true) {
        // Generate cache key from query and parameters
        ksort($params);
        $cacheKey = md5($query . serialize($params));

        if ($useCache && ($result = @$this->cache->get($cacheKey))) {
            return unserialize($result);
        } else {
            // Execute the query and fetch result from database
            try{
                if (!empty($params)) {
                    foreach ($params as &$param){
                        if(is_int(strpos(strtolower($param), ':'))){
                            throw new Exception("Parameters should not contain colon (:)");
                        }
                    }
                }

                $_sql = str_replace(array_keys( array_map(function($_key){ return ':'.$_key; },$params)),array_values( array_map(function($_value){ return "'".$_value."'"; },$params)),$query);
                $_stmt = @$this->pdoObject->prepare($_sql);
                $_stmt -> execute();

                while ($_row=$_stmt -> fetch(PDO::FETCH_ASSOC)){
                    $_result[]=$_row;
                }

                // Cache the result in Redis (if enabled)
                if ($useCache && isset($_result)) {
                    @$this->cache->setex($cacheKey, 3600 /* expire after 1 hour */, serialize($_result));
                }

               return $_result;

           }catch(Exception $__e){
               echo $__e -> getMessage();
           }
       }
    }

    public function updateOrDelete(string $__query,array $__param){

        try{

            foreach($__param as &$__p){
                if(is_int(strpos(strtolower($__p), ':'))){
                    throw new Exception("Parameters should not contain colon (:)");
                }
            }

            $__sql=str_replace(array_keys(array_map(function($__k){return ':'.$__k;},$__param)),array_values(array_map(function($__v){return "'".$__v."'";},$__param)),$__query);
            $__stmt=@$this->pdoObject->prepare($__sql);
            $__stmt -> execute();

             // Generate cache key from query and parameters
             ksort($__param);
             $cacheKey = md5($__query . serialize($__param));

             // Invalidate the cache
             @$this->cache->del($cacheKey);

        }catch(Exception $__e){
            echo $__e -> getMessage();
        }

     }

}
 


    $db = new DatabaseWithCache('dbHost', 'dbName', 'dbUser', 'dbPassword', '<elasticache-endpoint>');

    // Fetch data with caching
    $result = $db->fetch("SELECT * FROM users WHERE id = :id", ['id' => 1]);

    // Update data and invalidate cache
    $db->updateOrDelete("UPDATE users SET email = :email WHERE id = :id", ['email' => 'newemail@example.com', 'id' => 1]);

    // Delete data and invalidate cache
    $db->updateOrDelete("DELETE FROM users WHERE id = :id", ['id' => 1]);
 

- update, delete 할때는 redis에서 삭제 합니다.
- select 할때는 redis에서 있는지 확인 후 사용하고, 없으면 DB 조회 후 redis에 입력 합니다.




  • 페이스북으로 공유
  • 트위터로  공유
  • 구글플러스로 공유
전체 61건 1 페이지
  • profile_image 페이지를 가져오지 못하니 404인가 아니면 서버쪽 설정 문제 이므로 500번때 코드가 나올까?결론은 아래 처럼 502 오류가 발생 합니다.ELB에서 리스너가 없을 경우 서버로 접속해서 데이터를 가져오지 못하는 상황에선 아래와 같은 메시지를 만나게 됩니다.포트지정 설정을 잘못해도 동일 하겠지요. 학술적으로 정리를 해보면 아래와 같이 말을 할 수 있다. HTTP 502 코드는 "Bad Gateway" 오류로 웹 서버가 게이트웨이나 프록시 서버를 통…
  • profile_image https용도로 사용할 수 있는 AWS Cerificate Manager 페이지에서의 인증서 생성하는 것에 대한 것입니다.이곳에선 외부에서 받은 인증서 파일을 올리거나 무료로 인증서를 생성 할 수 있습니다.AWS 무료인증서는 속도가 빠른 장점이 있고 무료이지만 문제는 이것을 다른곳에선 사용하지 못한 다는것입니다.예를 들면 EC2의 웹서버에서 https 용도로 사용하지 못합니다.그럼 EC2에선 외부에서 생성한 인증서를 가져와 사용하던가. 아니면 …
  • profile_image 클라우드 와치 수동으로 내보내기 하려 하는데 아래와 같은 메시지를 보게 되면GetBucketAcl call on the given bucket failed. Please check if CloudWatch Logs has been granted permission to perform this operation."S3 버킷에 대한 GetBucketAcl 호출 실패" 오류는 CloudWatch Logs가 지정된 S3 버킷에 대한 접근 권한이 없음을…
  • profile_image 온프레미스 환경에선 주기적으로 압축하여 보관하거나 복사하거나 해서 관리 후 삭제 하기도 하는데. 오토스케일링 사용으로 EC2가 없어지는 경우 이런 방식이 필요하다. 물론 EFS를 사용하는 방법도 있겠지만 난 그러고 싶지 않다. ● 클라우드와치 Agent를 설치 한다.yum -y install amazon-cloudwatch-agent▷ 아래는 테스트 하기 위한 로그를 2초에 한번 씩 발생 시킨다.while true; do (curl http:/…
  • profile_image NAT(Network Address Translation) 게이트웨이 구성으로 VPC(Virtual Private Cloud) 환경에서 프라이빗 서브넷에 있는 인스턴스들이 인터넷이나 AWS의 다른 공개 서비스에 접근할 수 있게 된다. ● NAT 게이트웨이NAT 게이트웨이는 AWS에서 관리하는 서비스로, 높은 가용성과 자동 확장 기능을 제공합니다. NAT 게이트웨이를 사용하면 별도의 관리 없이도 프라이빗 서브넷의 인스턴스가 인터넷에 접근할 수 있…
  • profile_image 아마존리눅스2에서 기본적으로 mysql 클라이언트가 없어서 접속을 하지 못하는 문제가 있어서 설치 하는 도중에 발생한 문제를 다음에는 쉽게 해결하기 위해서 적습니다.이게 없으면 덤프받은것 올리지도 못하고 해당 서버에서 디비서버로 접속도 못하네요~● mysql 클라이언트 설치 시도amazon-linux-extras install epel -ywget https://dev.mysql.com/get/mysql80-community-release-el…
  • profile_image S3에서 올린 본인 이외에 제 3자도 읽을 수 있도록 올린 것이 아닌 경우 클라우드 프론트에서만 읽을 수 있는 권한을 주는 방법에 대한 것이다. 프로그램으로 하나 씩 올리면서 권한을 줬으면 문제 되지 않는다.그렇지 않고. 아래 처럼 올린 경우 권한이 없어서 오류가 발생 한다. s3cmd sync /로컬/디렉토리 s3://버킷이름 아래처럼 배포를 생성할때 설정 해도 되고 다 설정한 다음 후에 수정을 해도 됩니다.<Error><Co…