事件

CQRS 与事件溯源落地指南(2025)

CQRS 与事件溯源落地指南(2025)CQRS 将写入与读取分离,事件溯源保留变化历史,提升可维护性与可审计性。一、模型与边界写模型:聚焦业务不变量与事务边界。读模型:针对查询优化的反规范化视图。二、事件存储与回放存储:事件表或日志记录状态变化与元数据。回放:用于重建读模型或审计追溯。三、一致性与

Flink 事件时间与水位线深度实践(2025)

Flink 事件时间与水位线深度实践(2025)事件时间驱动窗口是 Flink 的核心能力。本文聚焦乱序与迟到数据的工程实践。一、事件时间与水位线事件时间:以事件携带时间戳驱动计算,避免处理时间偏差。水位线(Watermark):标示低于某时间的事件基本到齐,推进窗口触发。二、乱序与迟到数据乱序容忍

KEDA Scalers 队列长度与事件驱动自动伸缩(2025)

KEDA Scalers 队列长度与事件驱动自动伸缩(2025)一、触发器与指标Scaler:RabbitMQ/Kafka/Redis 等触发器读取 `队列长度` 与速率。指标:转换为 HPA 可消费的指标,驱动副本数变化。二、伸缩策略与并发策略:设定最小/最大副本与步进;避免抖动。并发上限:为下游

KEDA 事件驱动自动伸缩实践(2025)

KEDA 事件驱动自动伸缩实践(2025)KEDA 将外部事件源(队列/流/数据库)转换为伸缩信号,适合波动与异步任务场景。一、触发器与 ScaledObject触发器:Kafka/Redis/HTTP 等触发器参数与阈值配置。ScaledObject:绑定 Deployment 与最小/最大副本与