Connect to Airflow DB shell in local docker env

To Nha Notes | May 3, 2023, 10:37 a.m.

List up docker processes

docker ps

CONTAINER ID   IMAGE                   COMMAND                  CREATED             STATUS                    PORTS                                                           NAMES
a85de3f0f765   postgres:10-alpine      "docker-entrypoint.s…"   About an hour ago   Up 19 minutes             5432/tcp                                                        aws-mwaa-local-runner-2_5_postgres_1
8b584b8d7f2f   amazon/mwaa-local:2_5   "/entrypoint.sh loca…"   4 days ago          Up 19 minutes (healthy)   5555/tcp, 8793/tcp, 0.0.0.0:8080->8080/tcp, :::8080->8080/tcp   aws-mwaa-local-runner-2_5_local-runner_1
 

Connect to Airflow DB container running process

docker exec -ti a85de3f0f765 sh

Connect to Airflow DB shell

/ # psql --user airflow
psql (10.23)
Type "help" for help.

airflow=#

List up DB commands

airflow=# \?
airflow=# \? [commands]          show help on backslash commands

Show tables

airflow=# \dt
                     List of relations
 Schema |              Name              | Type  |  Owner
--------+--------------------------------+-------+---------
 public | ab_permission                  | table | airflow
 public | ab_permission_view             | table | airflow
 public | ab_permission_view_role        | table | airflow
 public | ab_register_user               | table | airflow
 public | ab_role                        | table | airflow
 public | ab_user                        | table | airflow
 public | ab_user_role                   | table | airflow
 public | ab_view_menu                   | table | airflow
 public | alembic_version                | table | airflow
 public | callback_request               | table | airflow
 public | connection                     | table | airflow
 public | dag                            | table | airflow
 public | dag_code                       | table | airflow
 public | dag_owner_attributes           | table | airflow
 public | dag_pickle                     | table | airflow
 public | dag_run                        | table | airflow
 public | dag_run_note                   | table | airflow
 public | dag_schedule_dataset_reference | table | airflow
 public | dag_tag                        | table | airflow
 public | dag_warning                    | table | airflow
 public | dagrun_dataset_event           | table | airflow
 public | dataset                        | table | airflow
 public | dataset_dag_run_queue          | table | airflow
 public | dataset_event                  | table | airflow
 public | import_error                   | table | airflow
 public | job                            | table | airflow
 public | log                            | table | airflow
 public | log_template                   | table | airflow
 public | rendered_task_instance_fields  | table | airflow
 public | serialized_dag                 | table | airflow
 public | session                        | table | airflow
 public | sla_miss                       | table | airflow
 public | slot_pool                      | table | airflow
 public | task_fail                      | table | airflow
 public | task_instance                  | table | airflow
 public | task_instance_note             | table | airflow
 public | task_map                       | table | airflow
 public | task_outlet_dataset_reference  | table | airflow
 public | task_reschedule                | table | airflow
 public | trigger                        | table | airflow
 public | variable                       | table | airflow
 public | xcom                           | table | airflow
(42 rows)

Query data from a table

select * from public.dag;