Airflow DB 변경

Airflow DB 변경

- Airflow DB 변경하는 이유
: 기본적으로 Airflow를 설치하면 Sqllite를 기본 DB로 사용하게 되는데 Sequential Executor를 제외한 다른       Executor를 사용하기 위해서는 DB 변경이 필요하다.
: 주로 Airflow 에서는 postgresql을 사용한다.

 

DB(postgresql) 설치

- DB 설치 방법은 간단하다.
# sudo apt-get update postgresql
- 설치가 완료되었으면 패키지 설치를 진행하였으므로, postgres user가 자동으로 생성된다.
# su - postgres
# psql

=# create database airflow_db
=# \list

## example
=# create user airflow with password 'airflow';
=# grant all privileges on airflow to airflow;
=# Ctrl+D

 

Airflow 설정 변경

- DB 생성이 완료되었으니, 생성된 DB로 Airflow DB 연결을 변경해줍니다.
# vim /home/airflow/airflow.cfg
## sql_slchemy_conn, result_backend를 설정한 postgresql 정보로 변경해줍니다.
## psycopg2 package 오류 시 install 해줍니다.
# pip install psycopg2 

## DB 초기화
# airflow db init

 

Airflow 재 실행

- Webserver 실행
# airflow webserver

- Scheduler 실행
# airflow scheduler

- DB 확인
# psql
=# \c airflow_db
=# \dt