Home

beam-pipeline-toolkit Wiki

A reusable Apache Beam pipeline framework: generic parse → validate → aggregate → sink wiring, a Dataflow control-plane API, an opt-in logging layer, a safety layer, and an optional e-commerce extension.

一個可重複使用的 Apache Beam 管線框架：通用的 parse → validate → aggregate → sink 組裝流程、Dataflow 控制平面 API、選用的日誌記錄層，以及一個安全防護層，並附帶一個可選用的電商擴充模組。

---

📘 English

• Overview
• File Guide — full file tree, one line per file
• Pipeline Module — pipeline/
• Control Plane Module — controlplane/
• Log Module — log/
• Safety Module — safety/
• Ecommerce Module — ecommerce/
• Testing — tests/

📗 繁體中文

• 總覽
• 檔案導覽 — 完整檔案樹，每個檔案一行說明
• Pipeline 模組 — pipeline/
• 控制平面模組 — controlplane/
• 日誌模組 — log/
• 安全模組 — safety/
• 電商模組 — ecommerce/
• 測試 — tests/

---

Repo: https://github.com/sinlead/beam-toolkit