Bối cảnh và vấn đề nghiên cứu

Trong bối cảnh đô thị hóa nhanh và sự gia tăng của các phương tiện di chuyển, việc quản lý và điều tiết lưu lượng giao thông trở thành thách thức lớn đối với hạ tầng đô thị. Sự phát triển của các hệ thống giao thông thông minh (Intelligent Transportation System - ITS) đòi hỏi các giải pháp dự báo lưu lượng và tốc độ di chuyển có độ chính xác cao nhằm hỗ trợ vận hành, giảm thiểu ùn tắc và tối ưu hóa điều phối tuyến đường. Đồng thời, sự phổ biến của mạng lưới cảm biến thu thập dữ liệu giao thông liên tục theo thời gian thực đã tạo ra khối lượng dữ liệu khổng lồ, đưa bài toán dự báo luồng giao thông bước vào kỷ nguyên Dữ liệu lớn (Big Data).

Mặc dù đã có nhiều mô hình dự báo được nghiên cứu, phần lớn các hệ thống truyền thống vẫn dựa trên các mô hình thống kê xác suất cổ điển (như ARIMA) hoặc các mô hình học máy nông, vốn bộc lộ nhiều hạn chế khi xử lý các mối quan hệ phi tuyến phức tạp và dữ liệu chuỗi thời gian quy mô lớn. Việc ứng dụng các kỹ thuật học sâu (Deep Learning) kết hợp cùng nền tảng tính toán phân tán (như Apache Spark, BigDL) mở ra khả năng khai phá các đặc trưng nhiều tầng của dữ liệu, cải thiện tốc độ huấn luyện và đáp ứng yêu cầu xử lý thời gian thực.

Mục tiêu và nhiệm vụ nghiên cứu của khóa luận được xác định cụ thể như sau:

  1. Nghiên cứu tổng quan bài toán dự báo luồng giao thông và các kỹ thuật xử lý dữ liệu lớn chuỗi thời gian.
  2. Khảo sát, xây dựng và thực nghiệm các mô hình dự báo chuỗi thời gian từ thống kê truyền thống đến học sâu, bao gồm ARIMA, Prophet, Long Short-Term Memory (LSTM) và Temporal Convolutional Network (TCN).
  3. Ứng dụng kỹ thuật học sâu phân tán (Distributed Deep Learning) thông qua nền tảng BigDL trên Apache Spark để tối ưu hóa việc tìm siêu tham số và huấn luyện mô hình.
  4. Xây dựng kiến trúc hệ thống hoàn chỉnh có khả năng thu nhận dữ liệu luồng (streaming data), tiền xử lý tự động, dự báo tốc độ giao thông thời gian thực và trực quan hóa kết quả lên bản đồ nhiệt (Heatmap).

Về đối tượng và phạm vi nghiên cứu:

  • Đối tượng nghiên cứu: Tốc độ và lưu lượng luồng giao thông đô thị được biểu diễn dưới dạng chuỗi thời gian đa biến (Multivariate Time Series).
  • Phạm vi không gian: Mạng lưới giao thông thành phố New York, Hoa Kỳ, thu thập thông qua hệ thống cảm biến giám sát tốc độ đường bộ.
  • Phạm vi dữ liệu: Bộ dữ liệu NYC Real Time Traffic Speed Data Feed từ cổng thông tin NYC OpenData do Sở Giao thông Vận tải Thành phố New York cung cấp, bao gồm hơn 50 triệu điểm dữ liệu lịch sử cùng luồng dữ liệu cập nhật liên tục theo thời gian thực.

Cơ sở lý thuyết và phương pháp nghiên cứu

Nghiên cứu được xây dựng trên nền tảng lý thuyết phân tích dữ liệu lớn, xử lý dữ liệu truyền trực tuyến, phân tích chuỗi thời gian và các mô hình học sâu phân tán:

1. Dữ liệu lớn và xử lý luồng dữ liệu thời gian thực

Khóa luận tiếp cận dữ liệu lớn theo khung 5 đặc trưng cơ bản (5V):

  • Khối lượng (Volume): Quy mô dữ liệu vượt ngưỡng lưu trữ và xử lý của các hệ thống đơn lẻ truyền thống.
  • Tốc độ (Velocity): Tốc độ sinh dữ liệu và yêu cầu xử lý đạt mức thời gian thực (Real-time).
  • Tính đa dạng (Variety): Dữ liệu xuất phát từ nhiều định dạng có cấu trúc, bán cấu trúc hoặc phi cấu trúc (cảm biến, log hệ thống, JSON, CSV).
  • Tính xác thực (Veracity): Mức độ tin cậy và độ chính xác của dữ liệu, đòi hỏi các kỹ thuật lọc nhiễu và xử lý dữ liệu thiếu.
  • Giá trị (Value): Khả năng chuyển hóa dữ liệu thô thành thông tin hữu ích cho việc ra quyết định điều phối giao thông.

Kiến trúc xử lý dữ liệu truyền trực tuyến (Streaming Data) bao gồm hai thành phần cốt lõi: lớp lưu trữ (đảm bảo tính tuần tự, nhất quán) và lớp xử lý (thực hiện biến đổi qua cửa sổ thời gian trượt). Hệ thống sử dụng khung làm việc Apache Spark cùng các thành phần chuyên biệt: Spark Core (tính toán trong bộ nhớ - In-memory computing), Spark Streaming (xử lý dữ liệu mini-batch), Spark SQL (xử lý dữ liệu có cấu trúc dạng DataFrame) và MLlib (thư viện học máy phân tán).

2. Phương pháp phân tích chuỗi thời gian

Chuỗi thời gian được phân tích qua ba thành phần cấu trúc: Xu hướng (Trend), Thời vụ (Seasonal) và Chu kỳ (Cyclic). Tác giả so sánh hai phương pháp tiếp cận dự báo:

  • Dự báo thống kê truyền thống (Traditional Statistical Style): Huấn luyện trên toàn bộ chuỗi lịch sử đến mốc thời gian quan sát cuối cùng để dự báo các bước tiếp theo; khi dịch chuyển mốc thời gian cần tái huấn luyện toàn bộ mô hình và thường bị giới hạn trong việc dự báo đa biến.
  • Dự báo theo phong cách hồi quy thông thường (Regular Regression Style): Chuyển đổi bài toán chuỗi thời gian thành học có giám sát bằng cách sử dụng cửa sổ quan sát trượt (lookback window) để dự báo một khoảng thời gian trong tương lai (forecast horizon), cho phép dự báo đa bước (Multi-Step) và đa biến (Multivariate) mà không cần huấn luyện lại từ đầu.

3. Các mô hình dự báo được áp dụng

  • Mô hình Prophet: Dựa trên mô hình cộng tính phi tuyến (Additive Model): $$y(t) = g(t) + s(t) + h(t) + \epsilon(t)$$ Trong đó $g(t)$ là hàm xu hướng (mô hình tăng trưởng bão hòa Logistic hoặc hồi quy đoạn tuyến tính Piecewise Linear), $s(t)$ là thành phần thời vụ sử dụng chuỗi Fourier với chu kỳ $P=365.25$ ngày hoặc $P=7$ ngày, $h(t)$ là mô hình tác động của ngày lễ/sự kiện đột xuất, và $\epsilon(t)$ là sai số phân phối chuẩn.
  • Mô hình ARIMA: Mô hình tự hồi quy kết hợp trung bình trượt tích hợp $\text{ARIMA}(p, d, q)$, kết hợp giữa quá trình tự hồi quy bậc $p$ ($\text{AR}$), sai phân bậc $d$ ($\text{I}$) để đạt tính dừng, và trung bình trượt bậc $q$ ($\text{MA}$). Chất lượng mô hình được đánh giá qua tiêu chuẩn thông tin Akaike (AIC).
  • Mô hình LSTM: Kiến trúc mạng nơ-ron hồi quy đặc biệt giải quyết vấn đề triệt tiêu đạo hàm và phụ thuộc xa (Long-term dependencies) thông qua trạng thái tế bào (Cell State) và ba cổng kiểm soát luồng thông tin sử dụng hàm kích hoạt Sigmoid và Tanh: cổng quên (Forget Gate), cổng cập nhật (Update Gate) và cổng đầu ra (Output Gate).
  • Mô hình TCN: Mạng tích chập thời gian kết hợp tích chập nhân quả (Causal Convolution - ngăn rò rỉ thông tin tương lai về quá khứ bằng zero-padding kích thước $k-1$) và tích chập giãn nở (Dilated Convolution với hệ số giãn nở $d = b^i$). Thiết kế này mở rộng trường tiếp nhận (Receptive Field) $w = 1 + (k - 1) \frac{b^n - 1}{b - 1}$ mà không làm bùng nổ số lượng tham số, đồng thời kết hợp khối dư (Residual Block) để tăng độ sâu mạng.

4. Kỹ thuật học sâu phân tán với BigDL

Nghiên cứu áp dụng kỹ thuật song song hóa dữ liệu (Data Parallelism). Dữ liệu được chia đều cho các nút làm việc (worker nodes) để tính toán độc lập, sau đó đồng bộ trọng số thông qua máy chủ tham số (Parameter Server) theo cơ chế tính trung bình tham số (Parameter Averaging) hoặc cập nhật theo gradient (Update Gradient-Based). Hệ thống sử dụng BigDL 2.0 (tích hợp Analytics Zoo, Orca, RayOnSpark, Chronos) trên nền Apache Spark để phân tán việc huấn luyện và tự động dò tìm siêu tham số (Hyperparameter Tuning).

Thiết kế và triển khai hệ thống

Hệ thống dự báo luồng giao thông thời gian thực được thiết kế theo mô hình kiến trúc ba lớp:

[ Nguồn Dữ liệu NYC OpenData ]

Quy trình xử lý dữ liệu được chuẩn hóa qua 5 bước liên tiếp:

  • Bước 1: Trích chọn thuộc tính: Lọc từ dữ liệu thô ba trường thông tin phục vụ bài toán gồm DATA_AS_OF (mốc thời gian), LINK_ID (mã định danh đoạn đường) và SPEED (vận tốc đo được).
  • Bước 2: Tái cấu trúc ma trận dữ liệu: Chuyển đổi định dạng bảng với cột chỉ mục (Index) là thời gian ghi nhận, mỗi cột (Header) đại diện cho một mã đường (LINK_ID), và giá trị ô là vận tốc tương ứng.
  • Bước 3: Khử nhiễu và lọc ngoại lai: Phân tích phân phối thống kê để phát hiện và loại bỏ các giá trị dị biệt sinh ra do lỗi cảm biến.
  • Bước 4: Gom nhóm theo chu kỳ thời gian: Đồng bộ hóa dữ liệu từ các cảm biến bằng cách tổng hợp và lấy giá trị vận tốc trung bình trong mỗi khung thời gian 5 phút.
  • Bước 5: Xử lý giá trị khuyết thiếu: Áp dụng kỹ thuật nội suy (Interpolation) để điền các giá trị trống (Null) phát sinh tại các đoạn đường không có tín hiệu cảm biến gửi về trong chu kỳ 5 phút.

Nội dung chính theo từng chương

Chương 1. Mục tiêu và phạm vi nghiên cứu

Chương 1 xác định tổng quan đề tài, sự cần thiết của việc xây dựng hệ thống dự báo giao thông trong thời đại dữ liệu lớn, nêu rõ 4 nhiệm vụ nghiên cứu và xác định phạm vi thực nghiệm trên bộ dữ liệu giao thông thành phố New York.

Chương 2. Giới thiệu bài toán

Chương 2 mô tả chi tiết bài toán dự báo luồng giao thông (Traffic Flow Forecasting/Prediction), phân tích cơ chế thu thập dữ liệu từ cảm biến, radar, camera, GPS và tổng hợp các công trình nghiên cứu trong nước cũng như quốc tế:

Tác giả / Công trình Năm Mô hình sử dụng Bộ dữ liệu / Quy mô Kết quả công bố
Yisheng Lv và cs. 2014 Stacked Autoencoders (SAEs) PeMS California (>15.000 cảm biến) MAE tại 15-30-45-60 phút lần lượt là: 34,1; 64,1; 92,0; 122,8
Rui Fu và cs. 2016 LSTM và GRU PeMS California (dữ liệu 30 phút dự báo 5 phút) MAE đạt 18,1 (LSTM) và 17,2 (GRU)
Yi Liu và cs. 2020 Federated Learning + GRU (FedGRU) PeMS California (>39.000 cảm biến) Độ chính xác 90,96%, MAE đạt 6,84
Quang Hung Do và cs. 2018 Wavelet mờ (FWNN) tối ưu hóa iBBO Dữ liệu giao thông ngắn hạn RMSE mô hình FWNN-iBBO đạt 20,9846 (tổng thể 20,4034)
Trịnh Đình Toàn, Việt Hùng Trương 2021 SVM kết hợp Nearest Neighbor (kNN) Dữ liệu giao thông ngắn hạn MAPE tốt nhất đạt 2,39% tại mốc dự báo 5 phút

Chương 3. Cơ sở lý thuyết

Chương 3 trình bày cơ sở toán học và kiến trúc kỹ thuật của hệ thống:

  • Bản chất dữ liệu lớn và kiến trúc Apache Spark (Spark Core, Spark Streaming, Spark SQL, GraphX, MLlib).
  • Phương pháp phân tích chuỗi thời gian theo tiếp cận thống kê truyền thống và tiếp cận hồi quy học sâu.
  • Chi tiết toán học của 4 mô hình: mô hình cộng tính Prophet, mô hình tích hợp sai phân ARIMA kết hợp tiêu chuẩn AIC, cấu tạo cổng và trạng thái tế bào của mạng hồi quy LSTM, nguyên lý tích chập nhân quả - giãn nở và khối dư của mạng tích chập thời gian TCN.
  • Cơ chế học sâu phân tán (Data Parallelism, Model Parallelism, Parameter Server) và thư viện BigDL 2.0 (Orca, RayOnSpark, Chronos).

Chương 4. Hệ thống dự báo luồng giao thông thời gian thực

Chương 4 mô tả thiết kế kiến trúc ba thành phần:

  • Bộ phận thu nhận và xử lý dữ liệu: Pipeline tải dữ liệu lịch sử CSV (>50 triệu dòng) và nhận luồng trực tuyến JSON qua API của NYC OpenData, chuẩn hóa qua 5 bước tiền xử lý.
  • Bộ phận mô hình dự báo: Quy trình cấu hình và huấn luyện phân tán các mô hình ARIMA, Prophet, LSTM, TCN; sử dụng công cụ tối ưu hóa siêu tham số tự động trên BigDL/Ray.
  • Bộ phận phát trực tuyến: Điều phối luồng xử lý Spark Streaming theo chu kỳ trượt và tích hợp hiển thị dữ liệu dự báo trực tiếp lên bản đồ nhiệt (Heatmap).

Chương 5. Thực nghiệm và thảo luận

Chương 5 thiết lập môi trường thử nghiệm, đánh giá so sánh hiệu năng của 4 mô hình (ARIMA, Prophet, LSTM, TCN) qua các kịch bản:

  • Đánh giá khả năng dự báo ngắn hạn (short-term) và dài hạn (long-term).
  • Phân tích hiệu suất dự báo tại các khung giờ khác nhau trong ngày (giờ cao điểm, giờ thấp điểm) và các ngày trong tuần.
  • Đánh giá ảnh hưởng của kích thước khoảng độ trễ đầu vào (lookback window) đối với mô hình LSTM và TCN.
  • Đo lường thời gian huấn luyện phân tán trên cụm máy tính và mức độ tiêu hao tài nguyên.
  • Kiểm thử độ chính xác của mô hình TCN trên tập dữ liệu hoàn toàn mới và trực quan hóa so sánh tốc độ dự báo với tốc độ thực tế.

Chương 6. Kết luận và hướng phát triển

Chương 6 tổng kết các kết quả kỹ thuật đạt được của hệ thống, chỉ ra các giới hạn thực nghiệm và định hướng mở rộng đề tài.

Kết quả và đóng góp

Nghiên cứu đạt được các kết quả kỹ thuật và đóng góp cụ thể:

  • Xây dựng hoàn chỉnh đường ống xử lý dữ liệu lớn: Thiết lập thành công pipeline tích hợp Apache Spark và Spark Streaming, có khả năng tiếp nhận luồng dữ liệu JSON từ API của NYC OpenData, thực thi quy trình tiền xử lý 5 bước tự động (lọc thuộc tính, chuyển cấu trúc, khử nhiễu, tổng hợp chu kỳ 5 phút và nội suy khuyết thiếu) trên quy mô dữ liệu lịch sử hơn 50 triệu bản ghi.
  • Ứng dụng huấn luyện phân tán hiệu quả: Tận dụng thư viện BigDL và RayOnSpark để phân tán tác vụ tìm kiếm siêu tham số tự động cho mô hình chuỗi thời gian (như AutoProphet với MSE tối ưu đạt mức 61,52 qua 800 thử nghiệm) và phân tán quá trình huấn luyện các mạng học sâu (LSTM, TCN) theo cơ chế Data Parallelism.
  • Thực nghiệm so sánh đa mô hình: Triển khai và đối chiếu hiệu năng giữa các phương pháp thống kê cổ điển (ARIMA), mô hình xu hướng cộng tính (Prophet) và các mạng học sâu tuần tự/tích chập (LSTM, TCN), chứng minh khả năng mô hình hóa chuỗi thời gian giao thông đa biến theo phong cách hồi quy (Regular Regression Style).
  • Trực quan hóa thời gian thực: Kết nối đầu ra dự báo từ mô hình với giao diện bản đồ nhiệt (Traffic Flow Heatmap), cho phép hiển thị cảnh báo và trạng thái tốc độ luồng giao thông tức thời.

Hạn chế và hướng nghiên cứu tiếp

Khóa luận ghi nhận các giới hạn kỹ thuật và vạch ra định hướng mở rộng:

  • Hạn chế:
    • Độ chính xác của hệ thống phụ thuộc chặt chẽ vào tính liên tục của tín hiệu cảm biến; việc tồn tại nhiều điểm dữ liệu Null hoặc nhiễu đo lường đòi hỏi bước nội suy nhân tạo có thể tạo ra sai số cục bộ.
    • Phạm vi thực nghiệm tập trung vào dữ liệu mạng lưới đường bộ thành phố New York, chưa kiểm chứng trực tiếp trên hạ tầng giao thông hỗn hợp tại Việt Nam.
    • Mô hình hiện tại chủ yếu khai thác đặc trưng thời gian (Temporal), chưa kết hợp sâu đặc trưng liên kết không gian (Spatial) giữa các nút giao thông liền kề.
  • Hướng nghiên cứu tiếp:
    • Tích hợp các kiến trúc mạng nơ-ron đồ thị không gian - thời gian (Spatial-Temporal Graph Neural Networks như STGCN, DCRNN) để mô hình hóa đồng thời cấu trúc liên kết mạng lưới đường bộ và chuỗi thời gian.
    • Mở rộng hệ thống để tiếp nhận thêm các biến ngoại cảnh như thời tiết, sự cố tai nạn, công trình thi công và các sự kiện đột xuất theo thời gian thực.
    • Tối ưu hóa hiệu năng tính toán phân tán trên cụm máy chủ quy mô lớn hơn nhằm giảm độ trễ xử lý luồng dữ liệu xuống mức dưới 1 phút.

Giá trị tham khảo

Tài liệu này mang lại giá trị thực tiễn cho các nhóm đối tượng:

  • Sinh viên và học viên ngành Khoa học Dữ liệu, Công nghệ Thông tin: Nguồn tài liệu tham khảo chi tiết về quy trình xây dựng đường ống phân tích dữ liệu lớn từ đầu đến cuối (End-to-End Big Data Pipeline) sử dụng hệ sinh thái Apache Spark và BigDL.
  • Nghiên cứu viên trong lĩnh vực Giao thông thông minh (ITS): Cung cấp hệ thống lý thuyết, công thức toán học và thiết kế kiến trúc chuẩn mực cho các mô hình phân tích chuỗi thời gian hiện đại (đặc biệt là cơ chế tích chập nhân quả và giãn nở của TCN so với mạng hồi quy LSTM).
  • Kỹ sư dữ liệu và kỹ sư học máy: Hướng dẫn thực hành có giá trị về phương pháp tiền xử lý dữ liệu cảm biến chuỗi thời gian thực tế, kỹ thuật xử lý dữ liệu phân tán (Data Parallelism, Parameter Averaging) và cách tổ chức luồng streaming qua API.

Câu hỏi thường gặp

1. Nguồn dữ liệu thực nghiệm của hệ thống được thu thập từ đâu và có đặc điểm gì?

Dữ liệu được lấy từ bộ dữ liệu NYC Real Time Traffic Speed Data Feed do Sở Giao thông Vận tải Thành phố New York cung cấp thông qua cổng NYC OpenData. Bộ dữ liệu bao gồm hơn 50 triệu bản ghi lịch sử dưới dạng tệp CSV và luồng dữ liệu thời gian thực được thu nhận liên tục qua API định dạng JSON từ các cảm biến tốc độ đặt trên các tuyến đường tại New York.

2. Quy trình tiền xử lý dữ liệu giao thông trong khóa luận gồm những bước nào?

Quy trình gồm 5 bước tuần tự: (1) Lọc bỏ các thuộc tính không cần thiết, chỉ giữ lại DATA_AS_OF, SPEED và LINK_ID; (2) Tái cấu trúc bảng dữ liệu với cột là mã định danh đường (LINK_ID) và chỉ mục là mốc thời gian; (3) Thống kê và loại bỏ các giá trị ngoại lai do lỗi cảm biến; (4) Gom nhóm và tính tốc độ trung bình theo từng chu kỳ 5 phút; (5) Sử dụng kỹ thuật nội suy (Interpolation) để xử lý các giá trị khuyết thiếu (Null).

3. Sự khác biệt giữa phương pháp dự báo chuỗi thời gian thống kê truyền thống (TS) và hồi quy học sâu (RR) là gì?

Phương pháp thống kê truyền thống (TS Style) huấn luyện mô hình trên toàn bộ chuỗi lịch sử cho đến mốc quan sát cuối và phải tái huấn luyện lại từ đầu khi thay đổi mốc thời gian dự báo, đồng thời bị giới hạn trong bài toán đơn biến. Ngược lại, phương pháp hồi quy học sâu (RR Style) chuyển đổi bài toán thành học có giám sát bằng cách sử dụng cửa sổ quan sát trượt (lookback window) để dự báo đoạn giá trị tương lai (horizon), cho phép dự báo đa bước, đa biến và áp dụng cho các mốc thời gian khác nhau mà không cần huấn luyện lại.

4. Mô hình Temporal Convolutional Network (TCN) ngăn ngừa việc rò rỉ thông tin tương lai bằng cách nào?

TCN sử dụng kỹ thuật tích chập nhân quả (Causal Convolution), đảm bảo đầu ra tại thời điểm $t$ chỉ được tính toán dựa trên các phần tử tại thời điểm $t$ và các thời điểm trước đó trong chuỗi đầu vào. Để giữ nguyên kích thước tensor đầu ra bằng kích thước đầu vào mà không vi phạm tính nhân quả, mô hình bổ sung một vùng đệm số 0 (zero-padding) có độ dài bằng $\text{kernel_size} - 1$ vào phía trước chuỗi dữ liệu đầu vào.

5. Hệ thống sử dụng công nghệ nào để thực hiện huấn luyện mô hình phân tán?

Hệ thống sử dụng thư viện BigDL 2.0 (tích hợp Analytics Zoo, Orca, RayOnSpark, Chronos) chạy trên nền tảng tính toán phân tán Apache Spark. Mô hình được huấn luyện theo phương pháp song song hóa dữ liệu (Data Parallelism), phân chia dữ liệu cho các nút làm việc và đồng bộ hóa trọng số mô hình thông qua máy chủ tham số (Parameter Server).

Kết luận

Khóa luận tốt nghiệp của tác giả Trần Đăng Khoa và Hoàng Đình Quang đã xây dựng thành công kiến trúc hệ thống dự báo luồng giao thông thời gian thực hoàn chỉnh trên nền tảng phân tích dữ liệu lớn chuỗi thời gian. Bằng việc kết hợp hiệu quả giữa khung xử lý phân tán Apache Spark, thư viện học sâu BigDL và các thuật toán dự báo hiện đại như LSTM và TCN, nghiên cứu đã giải quyết được thách thức về khối lượng dữ liệu cảm biến lớn và yêu cầu tính toán tức thời. Đề tài cung cấp cơ sở lý thuyết vững chắc, quy trình xử lý dữ liệu chuẩn hóa và minh chứng thực nghiệm có giá trị ứng dụng cao cho việc phát triển các hệ thống giao thông thông minh.