NGUYỄN ANH KIỆT (ARIC)

Tập đoàn NextTech · Nền tảng Data Lakehouse Hợp nhất Đa miền 01/2025 – 12/2025 • Chức danh: Data Engineer • Stack: Delta Lake / Apache Iceberg UniForm, Spark, dbt, ClickHouse, Airflow, DataHub

• Liên kết Lakehouse Đa đám mây (Tuân thủ PCI-DSS): Do 3 công ty thành viên chạy trên 3 hạ tầng độc lập (Omisell trên GCP, Boxme trên Azure/AWS/R2, NextPay trên Private K8s nội bộ vì ràng buộc PCI-DSS), thiết kế tầng lưu trữ mở trung tâm (MinIO / SeaweedFS S3, Delta Lake & Apache Iceberg UniForm) chỉ đồng bộ các bảng Silver/Gold đã băm ẩn danh PII mà không sao chép dữ liệu giao dịch nhạy cảm.
• Định danh Dữ liệu Chủ (MDM) & Đối soát 3 Chiều Tự động: Xây dựng thuật toán phân giải thực thể (theo mã số thuế, SĐT, tài khoản thụ hưởng) hợp nhất định danh nhà bán hàng xuyên 3 công ty và tự động hóa đối soát 3 chiều (Đơn hàng ↔ Xuất kho ↔ Tiền về) kèm chốt chặn Write-Audit-Publish (WAP Gate), rút ngắn thời gian phát hiện đơn xuất kho chưa thu được tiền xuống 15 phút.
• Merchant 360 & Kho Đặc trưng Tín dụng (Point-in-Time Feature Store): Kết hợp tốc độ đơn hàng (Omisell), giá trị tồn kho vật lý tại kho làm tài sản đảm bảo (Boxme) và dòng tiền thanh toán (NextPay) trên các cửa sổ trượt 7/30/90/180 ngày (đảm bảo Point-in-Time Correctness); điều phối qua Apache Airflow, quản trị phả hệ trên DataHub và đồng bộ Reverse-ETL về Redis/MySQL phục vụ duyệt ứng vốn T+0 trong <10ms.

NextPay (Hệ sinh thái Tập đoàn NextTech) · Công nghệ Tài chính & Cổng Thanh toán 01/2024 – 12/2024 • Chức danh: Data Engineer • Stack: Private K8s (PCI-DSS), Debezium CDC, Kafka, Flink, Delta/Iceberg, ClickHouse

• Xử lý Khuếch đại Ghi (1:60) & Giảm tải MySQL OLTP: Giải quyết tình trạng 1 giao dịch quẹt thẻ/QR đẻ ra gần 40 câu lệnh SQL và JSON log đối tác nặng 10–20 KB: tách luồng ghi log bất đồng bộ nén ZSTD (giảm 85% dung lượng) kèm lưu giữ cuốn chiếu 30 ngày, đồng thời chuyển 100% truy vấn báo cáo doanh thu của điểm bán sang ClickHouse (độ trễ <200ms, giảm 65% IOPS OLTP).
• Lakehouse Nội bộ chuẩn PCI-DSS & Xử lý Luồng CDC có Trạng thái: Do ràng buộc PCI-DSS & Nghị định 13/2023/NĐ-CP không đưa dữ liệu thẻ thô lên Public Cloud, xây dựng cụm Lakehouse trên Private Kubernetes; dùng Debezium MySQL Binlog CDC, Apache Kafka và Apache Flink (RocksDB StateTTL) để chặn ~1,5% Webhook ngân hàng bắn trùng và giám sát độ trễ loa báo tiền IoT (<1,5s).
• Sổ cái Kép Chính xác Tuyệt đối & Đối soát Tự động 38+ Ngân hàng: Chuẩn hóa toàn bộ trường tiền tệ sang DECIMAL(18,4) để triệt tiêu lỗi làm tròn số thực; chuẩn hóa hơn 38 định dạng sao kê ngân hàng để chạy đối soát 2 chiều hằng sáng (T+1, xử lý giao dịch quẹt sát giờ cắt sổ 23:59:58) trên Delta Lake / Apache Iceberg UniForm kèm cổng kiểm toán WAP Gate (Delta = 0.00).

Boxme Global (Hệ sinh thái Tập đoàn NextTech) · Kho vận Thông minh & Hoàn tất Đơn hàng 3PL 01/2023 – 12/2023 • Chức danh: Data Engineer • Stack: Multi-Cloud (Azure, AWS S3, Cloudflare R2), Apache Flink, ClickHouse, Power BI RLS

• Sổ cái Tồn kho Bất biến theo Lô/Hạn sử dụng (FEFO) & Đối soát ERP: Thay thế cơ chế ghi đè số dư tồn kho gây mất dấu lịch sử bằng sổ cái giao dịch bất biến theo từng mã lô và ngày hết hạn (FEFO Batch/Lot Ledger), đảm bảo 100% xuất hàng cận hạn trước cho ngành Mỹ phẩm/FMCG (giảm 25% hàng cận date) và tự động đối soát phí sang Odoo ERP (rút 80% thời gian chốt kỳ).
• Xử lý Sự kiện Súng bắn Mã vạch Trễ sóng với Apache Flink Event-Time: Xử lý bài toán thiết bị PDA của nhân viên kho bị mất sóng Wi-Fi giữa các dãy kệ sắt và đẩy dồn sự kiện trễ 5–10 phút (Out-of-Order Events) bằng Apache Flink (BoundedOutOfOrdernessWatermarks & Side Outputs), tính SLA 4 bước theo đúng giờ quét thực tế và giữ tỷ lệ bàn giao đúng hạn FHR >95%.
• Chỉ mục Video Đóng gói Đa đám mây & Báo cáo Phân quyền (RLS): Đánh chỉ mục nối mã vận đơn với ~30 TB/tháng video camera đóng gói trên Cloudflare R2 (Zero-Egress) và ảnh khiếu nại trên AWS S3 giúp tra cứu bằng chứng tráo hàng trong <3 giây; phục vụ báo cáo vận hành trên ClickHouse và Azure Power BI Embedded (Row-Level Security).

Omisell (Hệ sinh thái Tập đoàn NextTech) · Quản lý Đơn hàng Thương mại Điện tử Đa sàn 01/2022 – 12/2022 • Chức danh: Data Engineer • Stack: GCP BigQuery & GCS, PySpark (AQE / Salting), dbt (SCD Type 2 / Slim CI), MySQL, Redis

• Khử trùng lặp Bão Webhook Đa sàn, Phân rã Combo & Giảm tải OLTP: Chặn 100% đơn nhân bản do hơn 20 sàn TMĐT bắn lặp Webhook khi nghẽn mạng bằng bộ lọc biên HMAC-SHA256 & Redis SETNX; tách tải báo cáo sang MySQL Read-Replica (giảm 70% CPU OLTP), chuẩn hóa 14 trạng thái đơn hàng và phân rã đệ quy >700 gói sản phẩm Combo (Virtual Bundles) về đơn vị SKU vật lý.
• Xử lý Lệch dữ liệu Mùa Mega Sale với PySpark AQE & dbt SCD Type 2: Vào các đợt 11.11/12.12, khoảng 80% sản lượng đơn dồn vào 5% nhà bán hàng lớn (Mega-Sellers) gây treo phép nối phân tán; áp dụng PySpark Adaptive Query Execution (AQE) & Key Salting để chia đều tải, kết hợp dbt Snapshots (SCD Type 2) lưu lịch sử thay đổi giá vốn (COGS) và dbt Slim CI.
• Kho Tài chính GCP BigQuery (Bóc tách 11 Phí sàn, Đối soát COD) & Tối ưu FinOps: Bóc tách 11 loại phí ẩn trong JSON quyết toán của sàn và tự động đối soát tiền thu hộ (COD), chênh lệch cân nặng với hơn 50 hãng vận chuyển; thay thế truy vấn phân trang SELECT * ... OFFSET bằng Partition Pruning + Clustering + Keyset Pagination giúp giảm >90% chi phí quét dữ liệu BigQuery.