def db_writer_thread_func(connection_string): """Thread này chạy liên tục, lấy dữ liệu từ Queue và ghi xuống DB.""" ...