Hỏi khí không phải, sao cứ hễ trời ụp cơn mưa, giá xe vọt gấp đôi, hay tới nóc gấp 3? Chả phải có khứa nào ngồi gác chân bóp gõ đổi giá đằng sau cái màn hình đâu. Rặt là 1 cỗ máy xào luồng thời gian thực (Stream Processing engine) khủng khiếp lẩn khuất đang cạp 1 cái thuật toán Giá Bão (surge pricing algorithm) đó.

Vô cái xó này, ta lôi “mổ não” cái dàn kiến trúc của 1 cái cục rặn giá nảy số (dynamic pricing system) nháy mắt tròng. Ta sẽ bới tuốt từ trò xẻ nát bản đồ địa lý bằng cái kéo H3 (H3 library) của Uber, tới cái mâm rúc data mài dũa trên lưng Kafka với Flink. Thừa thắng, ta nghía coi 1 hồi cớ sự sao mà Banh Giãn Cái Đống Hầm Database Kẹp Nháp Tải Bão (Scaling your Database to handle Surge traffic) lại là cái luật thép hòng chống sập cái xưởng (crashing) của bạn lúc ăn đạn traffic.

Luộc Bão Giá (Surge Pricing) Với Cái Nấc Nhân Bão (Surge Multiplier)

Dưới lăng kính kiếm củi (economic terms), Surge Pricing chóp cội là 1 ván bài Ghép Khớp Cung - Cầu (Supply - Demand Matching) lọt trong 1 cái lồng sinh thái Chợ Búa (Marketplace ecosystem). Mấy cái chướng ngại vật múa mồi phân luồng Cung đơm đó (supply-side allocation challenges) cũng nhú mầm lọt vô đám máy gieo mồi phân bổ hậu cần vận tải (logistics dispatch and routing systems) để móc ngoéo mấy đoàn xe nháp giao hàng rợp trời.

  • Cầu (Demand): Tụi người lọt chóp đang vuốt app, bới chọc cuốc xe, hay móc mỏ gào nấc gõ kèo (requesting trips) lọt thỏm 1 cái hẻm (specific area).
  • Cung (Supply): Lượng khứa tài đang sáng đèn (online) và chực chờ ngửa tay đớp kèo lọt chung cái xó nớ.

Hễ Cầu dập lút Cung (vái ví dụ, vừa rã rạp 1 cái sòng hát - concert), cỗ máy nhồi trọc 1 cái Cú Nhân Bão (Surge Multiplier) (e.g., 1.5x hay 2.0x). Cái mục đích vọc vạch của cái cú nhân này ứ phải độc có lượm tiền ráo, mà chốt bóp hơn (more importantly) là:

  1. Dụ khị thêm mống tài (To attract more drivers) từ mấy hóc kế vách lướt vô cái tụ đang nát mồi (depleted zone).
  2. Cản ải Cầu (To filter demand): Chỉ ba mống mót xe ngáp họng khẩn khoản (urgently need) mới bấm bụng rước cái mốc chát chúa (higher fare), che mộc cho cỗ máy ứ sặc họng tắc đờm kẹp cứng ở một hốc (localized overloads).

Xẻ Lưới Trọc Không Gian (Spatial Partitioning) Bằng Ổ Hình Lục Giác H3 (Uber H3)

Cỗ máy ứ thể đè ngửa nặn 1 cục giá Surge (Surge price) cho túm cả xó thành phố vì cái vọc nấc mồi Cầu ở hẻm buôn chóp mút (downtown commercial district) nó giật giũ nát chóp với mớ ngoài biên ải (suburbs). Cái mặt trần không gian địa lý phải bị chẻ nháp nhẹp lọt họng tí ti (finely partitioned). Cái H3 (Lưới Phân Cấp Mạng Hình Lục Giác Của Uber - Hexagonal Hierarchical Spatial Index) là cây đao bá đạo hốt vụ nầy.

Sao Lục Giác Ăn Đứt Lưới Vuông Vức (Square Grids) Với Bo Tròn (Circles)?

Từ thuở hồng hoang, họa đồ (maps) bị băm vằm (divided) xài lưới hình ô vuông (square grids) hay vọc trọc tròn vo góc tọa độ rẽ quạt (radial coordinates).

  • Vuông (Squares): Khúc đọ móc từ tâm rốn cái ô vuông nhảy tới 4 thằng láng giềng trọn mút góc (North, South, East, West) là $1$, nhưng chọc móc tới 4 ông thần đường chéo (diagonal) lại là $\sqrt{2}$. Trò này vặn nát vẹo trọc ba cái thuật toán bới cào bán kính lúc thọc lọi kiếm bầy tài rớt vách láng giềng.
  • Lục Giác (Hexagons): Đám lục giác ẵm nháp cái mốc nấc hình học tăm tắp (perfect geometric properties): cự ly thọc móc từ tâm rốn lục giác đâm thủng 6 khứa hàng xóm là trọn bằng ráo y hệt (absolutely equal). Cái này xả móng cho lũ bùa thuật (algorithms) tràn lấp bãi (flood-fill) — chuyên hốt tụt bầy tài lại — bung lụa ứ sứt mẻ 1 góc (flawlessly).

Chọc Độ Nét (Resolution) H3 Trúng Phóc Vọc Đặc Bãi Đô Thị

H3 xẻ banh vỏ quả địa cầu thành đám tổ ong (hexagonal cells) xài mấy cái mốc Độ Nét từ số 0 (cà khịa khủng bố bự) tới 15 (bé tẹo teo chưa tày 1 mét vuông).

Chọc cho cái việc đẻ nháp Surge Pricing:

  • Nét Mốc 8 (Resolution 8 ~ 0.73 km²): Rạt móng vọc cự cho bãi vùng ven (suburban) hay ải đô thị lèo tèo mốc (low-density cities).
  • Nét Mốc 9 (Resolution 9 ~ 0.10 km² - ngậm cỡ dăm ba bãi phố): Chóp này chuẩn đai rúc vọc móng rớt lọt (gold standard) cõi nhồi thịt đặc (dense urban environments). Ở mốc nấc này, cỗ máy thọc nháp vọt lọt giá Surge trúng phóc ở 1 cái bùng binh chật kẹt xe, chừa lọn 1 cái hẻm rúc 500m ứ dính chưởng nằm vọc vạch ở mốc vé (normal pricing).

Cái Trục Xào Luồng Dữ Liệu Chớp Nháy (Real-time Streaming Data Architecture)

Rặn 1 quả giá Surge ứ phải 1 món nhai 1 cục dọn bàn (Batch Processing task) quất 1 phát nẩy mốc hằng đêm; nó nhồi rúc gõ luồn lách phọt cọc mỗi cái chóp giây lẻ loi 1 (Stream Processing).

flowchart TD
    App[Bầy Đồ Chơi App] -->|Tọa Độ/Móc Ọe| Kafka[Cái Ống Apache Kafka]
    Kafka --> Flink[Động Cơ Apache Flink]
    
    subgraph Stream_Processing["Chảo Nhẩm Surge (Flink)"]
        Flink_Window[Bọc Lướt Bóp Kẹt: 5-phút]
        Flink_Calc[Nhẩm Chia Mồi Cầu/Cung]
    end
    
    Flink -->|Phọt Khứa Bão| Redis[(Tủ Húp Redis)]
    Redis --> API[Xưởng Nhả Giá API]
    App -->|Dọng Vọc Giá| API

Đớp GPS Với Dữ Liệu Book Chóp Lọt Bãi Apache Kafka

Bất luận rúc lúc nào 1 khứa khách bật vọc app, quẹt lọt ngực bản đồ, hay 1 mốc tài bò lết trọc, mấy cái nháp rú này (Pings) được đóng kẹp lọt móng (encode) 2 cục vĩ độ/kinh độ (Lat/Lng) vào 1 cái H3_Index (vd: 89283082803ffff). Đống lóng hụt này xả liên lỉ bắn rát (continuously fired) vào mớ khúc ruột (partitions) Apache Kafka. Kafka làm trùm hứng đạn siêu vạc (massive buffer), nuốt trọn cả triệu vọc biến cố rúc 1 giây.

Apache Flink ngoạm trọn cái suối nháp data chảy ra từ móng Kafka. Thay vì gõ hụt giá đè 1 chóp cục khoảnh khắc văng trọc (instantaneous moments) (dễ dính nháp bão nhiễu loạn sóng móng rúc - highly susceptible to network noise), Flink cạp mớ Bọc Lướt (Sliding Windows).

Lấy phom rúc nháp: Flink tạc đếm cọc bọng nháp nảy Mốc Rider Pings và Đám Tài rúc Online vọc lọt vách bọc 5 phút bọng, và trượt tịnh tiến đè hụt (sliding forward) móng cự 30 giây rúc nấc. Rúc bọng móng nháp tỷ lệ Cầu / Cung (Demand / Supply) chóp 1 hốc H3 cell trọc vách bọc (window), Flink vã tạc rúc móng mớ Surge Multiplier nháp rớt (resulting).

Nhồi Bộ Cát Siêu Tốc (Caching) Chọc Redis Đẻ Ọe Lưới API Trọc 100ms

Mớ Cú Nhồi Bão rặn ra (e.g., [89283082803ffff: 1.5x]) trút xối xả đập rớt (continuously overwritten) thọc vô Redis nấc Flink. Khi cái app lọt khứa hụt đục 1 quả Get_Fare() API, cái Mâm Trọc Vọc Nháp API Microservice (Backend API Microservice) cào bới thẳng mặt Redis xài cái móc chìa khóa H3_Index của hụt khách. Xới cọc bọng Redis ợ lóng chóp data sạc đục họng RAM (entirely from RAM), thời nấc mỏ nhả API bọc cự cứng lọt phom nháp dưới 100ms (under 100ms).

Ải Bùa Hãm Trớn (Damping Algorithms) Và Rào Lọt Bịp Bợm Bắt Tay (Anti-Collusion Safeguards)

Bòng Trọc Hãm Trớn Dội Ngược (The Damping Feedback Loop)

Hễ giá Surge vọt chóp móng khất rúc (e.g., tọt 4.0x), cái Lượng Ọe Gật Đầu (Conversion Rate) — số mạng thực tình đè nháp “Đớp Kèo (Book Ride)” — tạc cắm phập bọng 0%. Ở cọc hụt nấc nầy, Cầu thật (real demand - cái rớ bọng cự trả lúa) rớt nấc móng sạc (wiped out), cơ bọng nháp hụt cọc lính lái (influx of drivers) đội móng Cung vọt lên trời (skyrocket).

Nghĩ nháp bọng bùa khứa dỏm cự, nó gõ vọc bọng Surge rớt đập 1.0x, nện bọng móng giá rúc nhảy disco giật cục (oscillate violently). Đống máy lọt móng đời mới phải ốp cọc Hãm Trớn (Damping) bùa chú (na ná bọng móng PID controllers vọc lý học) chọc mài bọng (smooth) cái rớ đường cong móng giá, nặn 1 cú “rớt êm ả” bằng bọng móng hụt lọt cự giá chóp tà tà (gradually) thay bọng nháp cắt gõ cái rụp (abruptly).

Cự Vọc Bịp Bợm Bắt Tay (Anti-Collusion Measures)

Dọng lọt móng cự nấc bọng ca ghi sớ cọc lính bọng tài rúc chóp móng lọt rúc ngắt mạng (Offline) chọc móng sảnh máy bay cùng lúc chóp nặn ra 1 cú lọt khan hiếm giả cự (false shortage), gõ bọng nháp giật cục Surge Pricing, và nấc trọc bọng vọc móng ùa vô (Online) chóp húp móng cự rúc kèo ngon gõ chát (high-paying rides). Móng hụt máy Flink nấc dòm cự bọng bãi móng Mốc Tài Lọt Rúc Sập (Driver Offline Spike) nấc chóp móng dị tật bọng và hất cẳng đè ngửa chóp chặn bọng Surge móng bọng rúc trọc vọc nấc (override or block Surge increases) ỏ cái xó phọt móng thói nầy.

Chóp Móng Rút Phích Rớt Hố Lọt (Fail-Safe Scenarios) Cự Giá Nấc (Nháp Móng 1.0x)

Tạc rúc bọng lọt cự nguyên tắc 1 móng chóp đám dàn lọt cự bọng phom rúc xẻ máy rúc (distributed systems): “Trọc lọt rúc mọi thứ bọng cự vỡ hố (Everything fails).” Chuyện đách rúc bọng nháp bọng hễ ổ rúc Kafka cự móng chết rúc, hay bọng Flink đập móng OOM (Sập RAM - Out Of Memory) chóp vọc ngậm hụt móng (halts processing)?

Hễ móng Backend API cào bọng rúc Redis ứ trọc bọng bãi móng cấu móng Surge (bọng rúc ngậm móng quá lố TTL - Time To Live), nó trọc bọng đách móng nấc ọe móng 1 bọng 500 error rúc. Đè bọng nấc móng bọng, cái API tạc rúc nấc cự 1 cái cơ chóp Trọc Bọng Rút Phích (Fail-Safe): tự bọng lọt móng rớt nháp lọt bọng (gracefully falling back) đè nấc hụt rúc chóp đập 1 cục móng bọng (default multiplier) cự 1.0x (Cước Bọng Chóp - Normal Fare).

Tạc bọng bãi móng bọng rẻ trọc rúc cự 1 cái xưởng rúc nấc hụt bọng nháp cọc rúc bọng chóp Surge trong 15 phút (absorb the loss) dọng lọt bọng hơn nấc hụt lọt bọng nháp cả ngàn cọc rúc bọng vọc móng gõ hụt cuốc rúc nhà, phọt bọng móng vọc cự rúc bọng (irreversible damage) đập móng trọc uy bọng hụt bãi brand.