Composer Airflow 데이터 베이스 접속 후 테이블 조회 및 삭제

베하~

안녕하세요 3대 5000의 man, xoxo 입니다.

이번 시간에는 저번 시간에 이어서 Composer 안의 Airflow 데이터 베이스 안의 테이블을 조회 및 삭제하는 방법에 대해 알아보도록 하겠습니다.

 

저번 시간에 연결했던 VM 창을 여신 다음 아래의 코드로 순차적으로 진행하시면 됩니다!

순서
composer gke 접속 -> 네임스페이스 확인 -> 해당 네임스페이스 pod 조회 -> pod 접속 -> 테이블 삭제

$ kubectl get ns
composer-버전-airflow-버전-<문자열> #로 이루어진 네임스페이스를 복사

$ kubectl get pod -n <위의 네임스페이스>
airflow-webserver-<문자열>-<문자열> #로 이루어진 pod 이름 복사

# 아래의 명령어를 통하여 해당 pod안에 접속하여 python을 실행
$ kubectl exec -it <복사한 pod 이름> python -n <복사한 네임스페이스>

그럼 아래와 같이 >>> 화살표 창이 나올 것입니다.
>>>

# 특정 테이블 조회법
>>> session = Session()
>>> session.execute("SELECT * FROM <table>")
>>> session.commit() 

# 특정 테이블 삭제법
>>> session = Session()
>>> session.execute("DROP TABLE <table>")
>>> session.commit() 

#session.commit()을 해야지 적용이 됩니다 ~

 

이번시간은 Composer 안의 Airflow 데이터 베이스 접속하여 데이터 베이스를 조회하고 삭제하는 방법에 대해 알아보았습니다.

이번 시간에 보신 것을 참조하셔서 더 많은 기능들도 사용해보시면 좋을 것 같습니다~