일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | |||||
3 | 4 | 5 | 6 | 7 | 8 | 9 |
10 | 11 | 12 | 13 | 14 | 15 | 16 |
17 | 18 | 19 | 20 | 21 | 22 | 23 |
24 | 25 | 26 | 27 | 28 | 29 | 30 |
- 데이터분석
- 그로스해킹
- PostgreSQL
- hackerrank
- mysql :=
- 프로그래머스
- Round
- SQLite
- TRUNCATE
- 데이터리안 웨비나
- matplotlib
- 결측값
- 전처리
- 다중 JOIN
- join
- GROUPBY
- SQL
- Limit
- solvesql
- SUM
- having
- airflow 설치
- 데이터시각화
- MySQL
- Oracle
- pandas
- 파이썬
- seaborn
- not in
- 머신러닝
- Today
- Total
목록DevOps/Airflow (4)
Milky's note
GCP 프로젝트에서 고정 IP를 생성하여 인스턴스에 할당을 해주었다.그래서 외부 IP로 Airflow UI에 접속하여 ETL 운영 작업을 했었는데갑자기 보안 정책으로 인하여,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,고정 IP를 제거하라는 요청이 들어왔다. SSH 터널링을 이용해서 외부 IP 없이 내부 IP로 Airflow UI에 접속할 수 있다. 로컬 머신에서 GCP의 VM 인스턴스에 SSH로 연결한 후, Airflow UI에 접근할 수 있도록 포트를 포워딩 0. 사전 작업 (gcloud 설치)gcloud sdk를 이용하여 로컬 기기에 ssh 연결을 해주어야 하기 때문에 gcloud cli를 입력할 수 있는 gcloud를 설치해야한다. 다음 링크를 들어가서 설치를 해준다.https://clo..
전 글에서 잠깐 설명한 Airflow default DB를 sqlite에서 MySQL로 바꾸는 작업과GCP 인스턴스에 설치한 Airflow를 서비스(데몬)으로 띄우는 작업에 대해서 글을 쓰려고 한다. 만약 아직 Airflow를 설치하지 않았다면 이전 글을 참고해서 Airflow부터 설치해야 한다. https://milkyspace.tistory.com/127 [Airflow] 설치 (by.GCP 환경)GCP에 Airflow를 설치하려면 당연히 인스턴스가 있어야 한다.혹시나 인스턴스 생성이 안되어 있다면 이전 게시글을 참조하면 된다. https://milkyspace.tistory.com/125 [GCP] VM Instance 생성 및 고정 IP 할당GCPmilkyspace.tistory.com 3. My..
GCP에 Airflow를 설치하려면 당연히 인스턴스가 있어야 한다.혹시나 인스턴스 생성이 안되어 있다면 이전 게시글을 참조하면 된다. https://milkyspace.tistory.com/125 [GCP] VM Instance 생성 및 고정 IP 할당GCP에 VM Instance를 생성하는 법은 간단한 클릭 몇 번만으로 할 수 있다. 먼저 GCP에 로그인 한 후,[Compute Engine] → [VM 인스턴스] → [인스턴스 만들기] 를 클릭한다. 1. 머신 구성그리고 서버 용도에milkyspace.tistory.com 1. 사전 작업GCP에 Airflow를 설치하기 전에 먼저 해주어야 할 작업이 있다.계정 생성과 Python을 설치해 주어야 한다.Service를 사용하지 않으면 계정은 굳이 만들지 ..
Airflow Dag의 default 설정 중에서 catch up 이라는 설정이 있는데 이를 True로 하면 오류가 발생했을 때 start_date 시간부터 dag에서 설정한 crontab의 시간마다 수행한다. 기존에 수행 되었던 스케줄부터 다시 실행 시키고 싶으면 단순히 소스에서 catchup = True만 해놓지말고 기존에 수행되었던 기록을 삭제해주어야 한다. 기존 수행 내역을 삭제하려면 Browse > DAG Runs 에서 해당하는 Dag Id를 찾고 전부 선택하여 delete한다. DAG ID들을 삭제해주면 DAG가 재실행되고 이전 스케줄 시간부터 순차적으로 수행이 된다.