搭建 Temporal 工作流集群

适用场景

需要持久化、可重试的长时间工作流，例如订单履约、支付对账、数据管道和人工审批。Temporal 把工作流状态存到数据库，Worker 故障后可以继续执行。

前置条件

• Kubernetes 集群和 Helm。
• PostgreSQL 或 Cassandra 数据库。
• 对象存储用于归档历史事件（可选）。
• 明确 namespace、保留周期和并发规模。

步骤

1. 准备数据库：

kubectl create namespace temporal
kubectl -n temporal create secret generic temporal-db \
  --from-literal=password='***'

2. 安装 Temporal：

helm repo add temporal https://go.temporal.io/helm-charts
helm install temporal temporal/temporal \
  --namespace temporal \
  --set server.replicaCount=2 \
  --set postgresql.enabled=false \
  --set server.config.persistence.default.sql.host=postgres \
  --set server.config.persistence.default.sql.database=temporal \
  --set server.config.persistence.default.sql.user=temporal \
  --set server.config.persistence.default.sql.password='***'
kubectl -n temporal get pods

3. 创建 namespace：

temporal operator namespace create --namespace orders \
  --retention 7d
temporal operator namespace list

4. 部署 Worker（应用侧）：

temporal worker start --namespace orders --task-queue orders

5. 访问 Web UI：

kubectl -n temporal port-forward svc/temporal-web 8080:8080

6. 配置归档（可选）：

temporal operator cluster upsert --history-archival-enabled true

验证

• Temporal 前端、历史、匹配和 Worker 服务均正常。
• temporal workflow start 能创建并执行工作流。
• Worker 重启后工作流继续执行。
• UI 能查看事件历史和堆栈。
• 保留周期和归档按配置生效。

回滚

• 升级前备份 PostgreSQL/Cassandra。
• 保留旧 Helm values 和镜像版本。
• 工作流代码保持向后兼容，避免重放失败。
• 不要直接删除 namespace，会丢失工作流历史。

常见坑

• 数据库连接数不足，前端启动失败。
• namespace 和 Worker 的 Task Queue 不匹配，任务一直 Pending。
• 工作流代码包含非确定性操作，重放失败。
• 历史事件过大，超过单事件限制。
• 没有配置归档，历史数据无限增长。
• 多副本前端没有正确的 membership 配置。
• 生产环境没有 TLS 和认证，UI/API 暴露风险高。

相关命令

• temporal — namespace、workflow、task queue 管理
• kubectl — 查看 Temporal 组件
• psql — 检查数据库连接和表
• helm — 安装和升级