Airflow DataBase 내 기본 테이블 구조

2021-05-31

.

Data_Engineering_TIL(20210531)

[ec2-user@ip-10-172-372-192 airflow]$ mysql -h my-airflow-db.cluster-xxxxxxxx-ap-northeast-2.rds.amazonaws.com -u minman -p
Enter password: *********

...

mysql> use airflow
...
Database changed

mysql> show tables;
+-------------------------------------------------------+
| Tables_in_airflow                                           |
+-------------------------------------------------------+
| ab_permission                                               |
| ab_permission_view                                          |
| ab_permission_view_role                                     |
| ab_register_user                                            |
| ab_role                                                     |
| ab_user                                                     |
| ab_user_role                                                |
| ab_view_menu                                                |
| alembic_version                                             |
| celery_taskmeta                                             |
| celery_tasksetmeta                                          |
| chart                                                       |
| connection                                                  |
| dag                                                         |
| dag_code                                                    |
| dag_pickle                                                  |
| dag_run                                                     |
| dag_tag                                                     |
| import_error                                                |
| job                                                         |
| known_event                                                 |
| known_event_type                                            |
| kube_resource_version                                       |
| kube_worker_uuid                                            |
| log                                                         |
| rendered_task_instance_fields                               |
| serialized_dag                                              |
| sla_miss                                                    |
| slot_pool                                                   |
| task_fail                                                   |
| task_instance                                               |
| task_reschedule                                             |
| users                                                       |
| variable                                                    |
| xcom                                                        |
+-------------------------------------------------------+
35 rows in set (0.00 sec)

# airflow webserver에 접근하는 사용자 조회
mysql> select * from ab_user;
id, first_name, username, password(암호화되어있음), login_count,  등의 데이터가 있는 테이블

# airflow 내부에 직접접근하는 system 사용자 조회
# REST API 등으로 접근할때 이 계정정보를 이용해야함
mysql> select * from users;
+------------------------------------------------------------------------------+--------------+
| id | username | email                                   | password                   | superuser      |
+----+---------+------------------------------------+--------------------------+--------------+
|  1 | my_sys_user| minsupark@korea.com                   | qlwnecklqncelqqwenkxq(난수)|             0  |
...
+----+---------+------------------------------------+--------------------------+--------------+