앞구름기

》 Zookeeper 가 Kafka 관리 》 Kafka 를 통해 메세지 전송 》 Zookeeper&Kafka 서버 다운 방지 : Clustering ◎ 준비 : 가상머신 6대 → Zookeeper 3대 : 200.200.200.155 & 200.200.200.156 & 200.200.200.157 → Kafka 3대 : 200.200.200.150 & 200.200.200.151 & 200.200.200.145 [ Zookeeper 설정 ] 》 기본포트 : 2181 》 클러스터링 구성 시 : 2888, 3888 할당 > 하나가 active (leader) & 나머지 standby (follower) ● 설치 # jdk 설치 yum -y install java-1.8.0-openjdk-devel.x86_6..

[ Django - Web Server ] 》 Producer 역할 ● urls.py path('postnow/', board.views.posting_now) ● views.py # 게시글 등록할 때 def posting(request): contents = request.POST.get('contents',None) bimg = request.FILES['image'] post = Board() post.contents = contents post.bimg = bimg post.writer = request.session['user_id'] post.save() # DB 저장과 동시에 메세지 발행 (토픽메세지 - kafka) producer = KafkaProducer( acks=0, compress..

[ Broker 서버 준비 ] 2023.03.20 - [분류 전체보기] - [Kafka] Broker 서버를 이용한 Producer&Consumer 메세지 전송 [Kafka] Broker 서버를 이용한 Producer&Consumer 메세지 전송 [ 가상머신 준비 ] ◎ CentOS 8 : 3대 → Producer(200.200.200.150) → Consumer(200.200.200.151) → Broker(200.200.200.152) ● 설치 # jdk 설치 yum -y install java-1.8.0-openjdk-devel.x86_64 # kafka 설치 wget https://downloads.apache.org/kafk alsrudalsrudalsrud.tistory.com [ REST P..

● 참고 2023.03.20 - [분류 전체보기] - [Kafka] Broker 서버를 이용한 Producer&Consumer 메세지 전송 [Kafka] Broker 서버를 이용한 Producer&Consumer 메세지 전송 [ 가상머신 준비 ] ◎ CentOS 8 : 3대 → Producer(200.200.200.150) → Consumer(200.200.200.151) → Broker(200.200.200.152) ● 설치 # jdk 설치 yum -y install java-1.8.0-openjdk-devel.x86_64 # kafka 설치 wget https://downloads.apache.org/kafk alsrudalsrudalsrud.tistory.com > django 프로젝트 코드 수정 ..

[ 가상머신 준비 ] ◎ CentOS 8 : 3대 → Producer(200.200.200.150) → Consumer(200.200.200.151) → Broker(200.200.200.152) ● 설치 # jdk 설치 yum -y install java-1.8.0-openjdk-devel.x86_64 # kafka 설치 wget https://downloads.apache.org/kafka/3.4.0/kafka_2.13-3.4.0.tgz # 압축 해제 tar -xzvf kafka_2.13-3.4.0.tgz # 파일 이동 mv kafka_2.13-3.4.0 /opt/kafka ● 호스트 이름 설정 ① vi /etc/hostname 》 각 컴퓨터에 producer / consumer / broker 입력..

● 스택 생성 》 AWS 》 CloudFormation 》 스택 》 스택 생성 》 새 리소스 사용 》 샘플 템플릿 》 WordPress blog 》 InstanceType : t2.micro ● 확인

※ 공식 문서 참고 : https://aws.amazon.com/ko/premiumsupport/knowledge-center/cloudwatch-memory-metrics-ec2/ EC2 인스턴스에서 CloudWatch로 메모리 및 디스크 지표 전송 EC2 인스턴스에서 CloudWatch로 메모리 및 디스크 지표를 전송하려면 어떻게 해야 합니까? 최종 업데이트 날짜: 2022년 4월 5일 Amazon Elastic Compute Cloud(Amazon EC2) 인스턴스에서 Amazon CloudWatch 지표로 메모 aws.amazon.com [ CloudWatch에 EC2 인스턴스 메모리/디스크 지표 전송 ] ① IAM 역할 생성 + EC2 인스턴스에 연결 ● 역할 생성 》 AWS 》 IAM 》 액세..

◎ 모니터링 [ EC2 부하테스트 ] ● 대시보드 생성 》 AWS 》 CloudWatch 》 대시보드 》 대시보드 생성 》 위젯 추가 : 행 》 지표 》 EC2 》 인스턴스별 지표 》 CPUUtilization ● EC2 생성 후 대시보드에 연결 》 EC2 생성 : EC2 》 인스턴스 시작 》 인스턴스 연결 : ● Stress 주기 》 생성한 EC2 의 퍼블릭 IP 로 PuTTy 접속 #ubuntu 처음 시작 시 apt update #stress 설치 apt-get install stress #stress 주기 stress -c [cpu 코어 수] ☞ 대시보드에서 확인하기 ~ ☜

◎ 사용자 그룹 : 사용자별로 묶기 ◎ 역할 : 역할별로 묶기 ◎ 정책 》 제일 중요한 건 ~ 루트 사용자 》 루트 사용자가 아닌 최소한의 권한만 가진 새로운 사용자를 생성해 사용 》 로그인 시 IAM 사용자로 로그인 [ IAM 사용자로 로그인 ] ① 사용자 추가 》 AWS 》 IAM 》 사용자 》 사용자 추가 》 AWS Management Console에 대한 사용자 액세스 권한 제공 》 직접 정책 연결 : AmazonEC2ReadOnlyAccess 》 시크릿 모드로 전환한 탭에서 추가한 사용자 로그인 ② 루트 사용자로 EC2 인스턴스 생성 ③ 추가한 사용자로 확인 [ 사용자 그룹에 사용자 추가 ] ① 사용자 그룹 생성 》 AWS 》 IAM 》 액세스 관리 》 사용자 그룹 》 그룹 생성 》 사용자 선택..

》 post 방식 사용 》 db 연결 》 zip 파일로 업로드 한 함수 생성 ● Python 파일 생성 (pycharm - lambda_function.py) import pymysql def lambda_handler(event, context): # DB 연동 conn = pymysql.connect( host='[AWS:RDS 엔드포인트]', user='[계정명]', password='[비밀번호]', db='[연결된db]', charset='utf8' ) # 학생 이름 입력 student = event['body-json'] sql = "select * from student" # DB 불러오기 with conn: with conn.cursor() as cur: cur.execute(sql) res..