본문 바로가기

mysql7

2. Kafka 주문 이벤트 1 Producer - 2 Consumer 실습 (spring, mysql) 🧪 Kafka 1 Producer - 2 Consumer 실습Spring Boot, Kafka, Docker 기반의 실습 프로젝트입니다.하나의 Producer가 Kafka 토픽에 메시지를 전송하면, 두 개의 서로 다른 Consumer가 각각의 목적에 따라 해당 메시지를 받아 처리하는 구조입니다.📁 프로젝트 구조2-single-producer-multi-consumer/├── order-producer/ # Kafka Producer - 주문 메시지 발행├── order-log-consumer/ # Kafka Consumer 1 - 로그 저장├── order-processing-consumer/ # Kafka Consumer 2 - 주문 처리├── docker-c.. 2025. 8. 7.
1. Kafka 주문 이벤트 1 Producer - 1 Consumer 실습 (spring, mysql) https://github.com/qpwisu/kafka-event-demohttps://github.com/qpwisu/kafka-event-demo✅ 1. 프로젝트 개요주제:Kafka를 활용한 주문 이벤트 처리 시스템 구축구성 요소:order-producer: 주문 요청을 받아 Kafka에 이벤트 전송 (Spring Boot + MySQL + Kafka)order-consumer: Kafka에서 주문 이벤트를 수신하여 로그 DB에 저장 (Spring Boot + MySQL)Kafka: 이벤트 중심 메시지 브로커MySQL: 각 모듈별 데이터 저장소 (eventdb, consumerdb)Docker Compose: Kafka, Zookeeper, 두 개의 MySQL 컨테이너 관리✅ 2. 시스템 흐름도[사.. 2025. 8. 6.
데이터 수집 후 도커로 공유하기 mysql, redis 로컬에서 mysql, redis에 데이터 저장덤프로 데이터를 포함해서 이미지로 빌드도커 허브에 올리기공유 받을 사람이 도커 허브에서 pullMysql 공유1. 현재 데이터 백업 (덤프) - 로컬에서 실행되고 있는 mysql (도커 x)mysqldump -u root -p stock_db > stock_db_dump.sql2. MySQL 컨테이너 생성 및 데이터 복원docker run --name stock-db-container -e MYSQL_ROOT_PASSWORD=admin -e MYSQL_DATABASE=stock_db -d mysql:8.0컨테이너가 실행 후, 데이터베이스에 stock_db_dump.sql을 복원docker cp stock_db_dump.sql stock-db-container:.. 2025. 3. 4.
mysql user 생성 및 roll 권한 부여 #@localhost는 내부접근 @"%" 외부 접근 허용이고 ""를 붙이는건 상관없다. create user test2@localhost identified by "user1234"; create user "test3"@"%" identified by "1234";v user 생성 후 권한 주기 all privileges on은 모든 권한을 주는것 mysql 8.0 이후부터는 생성하면서 권한을 주지 못함 create user "test4"@"localhost" identified by "1234"; grant all privileges on *.* to "test4"@"localhost" with grant option; #권한 해제 revoke grant option on *.* from "test4".. 2022. 7. 19.
python 상장 기업 정보 mysql에 insert하기 mysql에 company table 생성 drop table company; create table company ( 회사명 varchar(20) not null, 종목코드 varchar(8) not null, 업종 varchar(50), 주요제품 varchar(100), 상장일 varchar(20), 결산월 varchar(5), 대표자명 varchar(50), 홈페이지 varchar(50), 지역 varchar(50), primary key(종목코드) ); kind에서 상장 기업들의 정보를 크로링해서 mysql에 insert def load_mysql_company(): def get_stocks(market=None): market_type = '' if market == 'kospi': marke.. 2022. 7. 16.
python 주가 데이터 mysql에 insert하기 우선 mysql에서 table을 만들어 주었습니다. 기본키는 티커와 날짜 두개의 다중 기본키를 사용하였습니다. create table price ( ticker varchar(6) not null, day1 varchar(8) not null, open1 int, high int, low int, end1 int, volume int, mount Long, rate float, name1 varchar(20), primary key(ticker,day1) ) 일정기간동안의 주가 데이터를 pykrx로 가져와서 전처리합니다 def getStockPrice(self,start_day, end_day): print("start get_stock_price") def str_day(d): return d.strf.. 2022. 7. 13.

티스토리툴바