Data Pipeline

47 篇内容

工程实践QuestDB Engineering

Read Measuring port congestion from free AIS data with NATS and QuestDB

文章介绍 Port Context Engine 用免费 AIS 流构建港口拥堵监测:Go 采集器接收船舶位置,经 NATS JetStream 分发并写入 QuestDB,五个服务分别负责采集、挂靠检测、增强、API 和归档。系统利用 LATEST ON、ASOF JOIN、SAMPLE BY、去重和 TTL/分区,在 2 CPU/1 GB 容器内完成实时查询、降采样及原始数据归档到 Parquet。作者复盘了分区删除需双重校验、ILP 重连、去重键和类型转换等工程教训。该方案适合低吞吐、强时间语义的物联网分析,但受免费 AIS 覆盖范围和港口数据边界限制。

推荐收录:文章给出了可运行系统的完整证据,包括五服务架构、QuestDB 表结构与保留策略、ILP 写入、LATEST ON/ASOF JOIN/SAMPLE BY 查询、Parquet 归档校验和真实运维踩坑。适合数据工程、时间序列数据库和物联网后端读者参考,其“先独立校验再删除分区”和资源受限下的数据生命周期设计可直接迁移。注意其负载仅约 860 消息/分钟,不能代表高吞吐场景。

工程实践TiDB 社区博客 - 实践案例

凌晨时分,几十万亿资产开始对账:某国有大行为什么把托管核心换成 TiDB

文章复盘某国有大行将运行十余年的 Oracle 资产托管核心迁移到 TiDB 的三年工程。面对几十 TB 数据、数万条复杂 SQL 和不能长时间停机的约束,项目放弃强行分库分表,采用原生分布式架构实现计算与存储弹性扩展。迁移中先做关联应用试点,再进行一年多的新旧系统双轨逐笔比对、数百项故障与性能准入验证,并用独立部署的 TiCDC 支撑灾备、数据湖和 Oracle 反向回写。上线后通过资源组隔离交易、批量和报表负载,降低慢查询扩散风险。文章给出了金融核心库替换的可复用路径,但作为厂商社区案例,缺少具体性能指标、成本和失败细节。

推荐收录为工程案例。文章不仅说明选型结果,还交代了不做分库分表的业务约束、双轨并行与回切链路、TiCDC 独立部署和资源隔离等具体做法,对承担核心系统数据库迁移、容灾和批流混合负载的团队有迁移方法上的参考价值。需注意其来自 TiDB 社区,缺少量化指标与失败复盘,阅读时应把厂商结论与可验证工程证据分开。

工程实践ClickHouse Engineering

What I learned from a month with WalShadow on ClickHouse Managed Postgres

文章记录作者对 ClickHouse Managed Postgres 内置 WalShadow 的为期一个月私有预览测试,比较其与 ClickPipes 从 Postgres 向 ClickHouse 同步变更的延迟和运维表现。作者让同一源库并行运行两条链路,以提交到目标可见为口径,在每秒 1 千至 20 万行写入下测量延迟,并校验行数、求和与哈希一致性。结果显示 WalShadow 中位延迟稳定在约 0.4 秒,而 ClickPipes 在约每秒 5 万行以内受 Sync interval 影响、超过后持续积压。文章还验证仅写 Postgres 时聚合正确,模式变更、源库重启/扩缩容、目标停止等可自动恢复,并列出按表并行可见、初始加载 _commit_ts/_lsn、大事务阻塞等边界,结论限于私有预览环境。

推荐收录:文章提供了同源同目标的并行对比实验,给出提交到可见延迟、吞吐拐点和数据一致性校验等直接证据,并系统测试扩缩容、重启、目标停止等运维场景。适合数据库工程师、数据平台与实时分析架构师评估 Postgres CDC 方案;其测量口径、故障场景清单和目的地表使用注意事项可迁移到其他同步链路。需注意这是厂商博客中的私有预览结果,默认值和性能结论可能随正式版变化。

工程实践Greptime 技术

From Event Logs to GreptimeDB: How OpenAI's Spark Observability Evolved at Hyperscale

文章基于 OpenAI 在 Apache Community Over Code EU 2026 的两场公开演讲,梳理其超大规模 Spark 可观测性演进。OpenAI 每天运行数十万 Spark 应用,事件日志常超 100GB,History Server 首次加载曾需约半小时。团队先通过 Kafka/Flink/Delta 让事件日志可查询,又用驱动端快照和 Rust History Server 将加载提速(P90 约 10 倍、P99 约 30 倍),再让带边界约束的 Agent 技能参与排障。最终他们将 Spark 指标、事件和日志统一写入 GreptimeDB,替代部分 Flink 解析链路和 S3 快照,并利用 Parquet 开放格式与湖仓互通。文章也指出约两周查询保留、profile 仍依赖 Pyroscope,以及该方案未必适合所有团队等边界。

推荐收录:虽然来自 Greptime 的厂商博客,但正文以两场公开演讲的时间戳为证据,给出规模数字、四阶段演进、GreptimeDB 替换链路的原因与保留周期等具体工程细节。对 Spark 平台、可观测性、SRE 与数据基础设施团队有较高迁移价值,尤其是减少重复管道、统一查询状态、让 Agent 在受控工具边界内取证;阅读时需意识到厂商立场并回看原始演讲。

工程实践SelectDB 技术分享

Apache Doris + Vane:让多模态数据进入业务分析 通过 Vane 将客服录音、图片等非结构化数据加工为文本与向量,并整合进 Doris 数据库,与订单、工单及生产批次...

文章介绍 Apache Doris 与 Vane 组合,将客服录音等非结构化内容加工为文本、候选分类和向量,并与订单、工单、生产批次关联。Vane 以 SQL、Python UDF 和 AI Function 组织转写、分类、向量化及 Stream Load;Doris 则用倒排索引和 ANN 索引支持业务过滤、相似检索、关联追溯与批次汇总。文中给出建表、录音加工到检索分析的完整 SQL/代码示例,并列举制造企业在工艺异常和售后质量分析中的场景。其价值是把语义检索纳入既有 SQL 分析链路,但示例依赖演示数据和一对一业务关系假设,AI 分类需人工复核,也缺少性能与成本评估。

推荐收录为工程案例:文章不仅展示 Doris 与 Vane 的产品组合,还给出建表、索引、UDF、Prompt、向量化和 Stream Load 的可复现代码,并把相似检索与订单/批次追溯串成完整链路。适合数据平台、AI 工程化和售后质量分析读者参考。需注意其演示数据、业务关系假设和人工复核边界,不能直接视为生产性能结论。

技术文章SelectDB 技术分享

Apache Doris + Vane:让多模态数据进入业务分析 通过 Vane 将客服录音、图片等非结构化数据加工为文本与向量,并整合进 Doris 数据库,与订单、工单及生产批次...

文章介绍 Apache Doris 与 Vane 组合,将客服录音、图片等非结构化内容经 Vane 转写、分类和向量化后写入 Doris,并与订单、工单、生产批次关联。文中给出建表与倒排/ANN 索引、语音识别 UDF、LLM 分类与 embedding、Stream Load 写入、向量检索和批次统计的完整 SQL/代码链路。核心是把语义检索与业务分析放在同一数据体系:先用型号、时间等条件缩小范围,再做相似检索、业务追溯和批次汇总,并保留原始文件位置用于核查。该方案适合售后质量分析与工艺异常检索,但作为厂商教程,缺少大规模性能、成本和人工复核效果的量化验证。

推荐收录:文章不是泛泛介绍产品,而是给出了从多模态加工、索引设计到 Doris 查询与批次统计的可复现代码链路,对数据平台、搜索和售后质量分析团队有直接迁移价值。需要注意的是它属于厂商教程,缺少生产规模下的性能、成本、数据噪声和人工复核闭环验证,读者应结合自身场景评估。

技术文章SelectDB 技术分享

从实时入库到实时可用:Apache Doris 5.0 增量计算场景与实践 数据的实时写入只是第一步,如何让下游指标与宽表低延迟、低成本地同步变更,是实时数仓搭建的核心...

文章介绍 Apache Doris 5.0 的增量计算体系:Changelog 持久化行级新增、更新与删除,Table Stream 按分区维护消费位点,使下游能持续读取变化并在同一事务中提交结果与进度。基于此,物化视图增量维护(IVM)可对受支持的聚合与 Join 查询生成增量计划,避免每轮全量重算。文章结合订单指标、客户宽表、ODS 到 DWD 分层加工和 Flink 跨系统流出四个场景,给出建表、刷新、Stream 消费与 Connector 配置示例。作者也指出首次刷新需建立基线、异步刷新可能滞后,且 Flink 链路交付语义受 Checkpoint、日志保留、去重和 Sink 能力制约;作为厂商分享,版本依赖与性能收益仍需生产验证。

推荐收录:文章不仅介绍 Doris 5.0 的 Changelog、Table Stream 与 IVM 机制,还用四个可执行 SQL 场景说明增量指标、宽表维护、分层加工和跨系统流出的实现方式,并明确首次刷新、异步滞后和 Flink 交付语义等边界。适合实时数仓、OLAP 和流式数据管道开发者做选型与方案设计参考;需注意其厂商背景,性能与版本兼容性应结合生产环境验证。

工程实践QuestDB Engineering

Read Ingesting live market data from Databento into QuestDB

文章介绍如何用 QuestDB Enterprise 4.0 的 Databento connector 将 EQUS.MINI 美股实时行情接入 QuestDB。作者通过单一 TOML 配置订阅 mbp-1 与 trades,连接器自动建表,以 ts_recv 作为纳秒时间戳,并将买卖盘存为二维数组;随后用 LATEST ON、SAMPLE BY、ASOF JOIN 和 Web Console 仪表板进行查询与可视化。文章重点验证连接器重启后借助 Databento intraday replay 回补数据、用 replay_dedup 去重,以及 QuestDB 停机时连接器在内存中缓冲、恢复后按原始时间戳补写和副本 failover。文中还讨论分区、冷存储与保留策略,并指出该方案依赖企业版连接器和实时订阅,长停机及常规交易时段的高压路径尚未完整实测。

推荐收录:文章基于真实运行数据,完整展示了从配置、建表、SQL 查询到重启回补、去重、QuestDB 停机缓冲和副本 failover 的链路,并比较了 replay_dedup 与 DEDUP UPSERT KEYS 的取舍。适合做时序数据库、行情数据管道和高可用接入的工程师参考,其中按确认位点重放、计数式去重和缓冲边界具有可迁移价值;但需注意其企业版连接器与 Databento 实时订阅的特定依赖,长停机路径仍属设计而非实测。

工程实践Greptime 技术

3+ Billion Rows per Experiment: How a Commercial Space Company Moved from InfluxDB to GreptimeDB

文章复盘商业航天公司把卫星研发时序数据从 InfluxDB 2.x 迁至自托管 GreptimeDB 的案例。单次实验超 30 亿行,原系统出现查询 OOM、开源版不能横向扩展、bucket 数量受限和 Flux 使用门槛高,InfluxDB 3 Core 的库表列上限也不符合按实验分库、按对象建宽表的设计。团队评估 ClickHouse 与 VictoriaMetrics 后选择 GreptimeDB:改造 Vector 经 gRPC 写入,以 tag_/field_ 前缀做 schema 映射,按数据库统一 TTL,临时数据首写自动建表加列,并用 SQL 统一查询指标与日志。文章区分了固定 schema 的治理数据和自动扩展的临时实验数据,但作为厂商访谈,缺少迁移后的独立性能对比与失败细节。

推荐收录。文章给出了 30 亿行级实验数据下 InfluxDB 的具体约束、选型对比、Vector 写入 schema 映射、TTL 与自动建表加列等可迁移设计,适合时序数据库选型、可观测数据平台和航天/实验数据工程读者。需注意这是 Greptime 官方博客的客户访谈,缺少独立压测与迁移后量化结果,引用其结论时应结合自身负载验证。

技术文章TiDB 社区博客 - 实践案例

TiDB + numpy 数据分析实战案例

文章以电商订单数据为背景,演示从 TiDB v8.5.3 经 SQLAlchemy 读取数据到 pandas、再用 numpy 完成分析与建模的完整链路。核心内容包括用 to_numpy() 把 DataFrame 列转成 numpy 数组、向量化运算与常用统计函数、Z-Score 标准化,以及基于消费额/下单次数/活跃度按 4:3:3 加权、先用 Min-Max 归一化再生成客户价值分的打分模型,最终把结果写回 TiDB 的 customer_scores 表。文中还列出 8 个常见坑(循环慢、values 与 to_numpy() 混用、归一化除零、std 的 ddof 口径、布尔索引括号、axis 方向、随机种子等)并给出成因与修正。整体偏入门教学,numpy 部分为通用基础知识,深度有限,更适合初学者建立向量化思维与端到端数据流程。

推荐收录:文章给出从 TiDB 读取到 numpy 计算再写回数据库的完整可运行代码链路,且 8 个避坑点附有具体成因与修正(如 std(ddof=1) 与 Excel 口径差异、布尔索引需用 & 并加括号、axis=0/1 方向、随机种子复现),对想把关系型/分布式数据库与 Python 数据分析打通的初学者有直接可迁移价值。主要不足是 numpy 内容较基础、结论多为常识性经验,进阶读者收益有限,建议作为入门参考而非深度技术素材。

工程实践Netflix TechBlog

Behind the Scenes: Evolving Netflix’s Ads Event Pipeline for Live — Part II

本文复盘 Netflix 为支撑直播广告而重构 Ads Event Publisher。旧架构在投放关键路径同步写入全局 Metadata Registry,数千万并发下形成扩展瓶颈、强依赖和新鲜度风险。新架构让广告服务器仅将响应写入 Kafka,由 Flink 有状态作业在 60 分钟窗口内将客户端事件与服务响应按 key 实时 join,完成跨区域重路由、去重和发布;迟到事件由 Spark 批作业从数仓回补。去重采用稳定哈希 ID 和本地状态,保证至少一次与尽力去重,而非精确一次。上线采用双管道并行、共享富化模块、自动审计和按稳定 key 灰度切流,最终下线旧服务与 Registry。边界是依赖 Netflix Flink/Maestro 平台,且跨区域、重启或迟到恢复仍可能产生少量重复。

推荐收录:文章用直播广告的真实约束,完整展示了以 Kafka+Flink 流式 join 替代关键路径数据库写入的架构取舍、去重语义、跨区域路由、迟到回补和双跑灰度上线方法,并给出吞吐与一致性验证证据。适合流处理、实时数据管道、广告/计费和高可用系统工程师阅读,可迁移到降低关键路径依赖、以事件路由替代全局复制的场景;主要风险是与 Netflix 自研 Flink/Maestro 平台耦合较深,不能直接照搬。

工程实践Cloudflare Blog

Rewinding the exponential: How we keep hardware usage down

文章复盘 Cloudflare 数据管道在流量指数增长下控制硬件成本的多阶段改造。2022 年拆分单体消息 schema,2024 年将压缩算法从 LZ4 换成 zstd。2026 年引入跨区域共享接收池与延迟复制、在 Logfwdr 提前采样,并在管道各阶段做局部聚合。核心思路是把复制、采样和聚合尽量前移或下移,减少广域网与集中式数据中心处理量。结果上负载均衡约省 38 GB/s、采样约省 25 GB/s、聚合已省 7+ GB/s,合计约 70 GB/s,并降低约 50% 的接收端 CPU/内存;但采样会引入近似估计,聚合只适合可预定义维度和指标的数据集,且方案依赖其自研 Buftee、ClickHouse 与业务采样键。

推荐收录,因为文章给出了真实生产管道在 20 亿事件/秒规模下的多阶段优化证据,包含 schema 拆分、zstd 压缩、跨区域复制、采样和聚合的量化收益与取舍。适合数据平台、可观测性和大规模流处理工程师阅读,可迁移到日志/分析管道的降本、跨区域容灾和资源规划;需注意其效果依赖 Cloudflare 自研组件、ClickHouse 和业务采样键,不能简单照搬。

工程实践Grab Tech

GrabMart data for faster disease outbreak detection

文章提出一个利用 GrabMart 聚合交易数据进行疾病早期预警的早期概念,而非已部署系统。其思路是把符合规则的商品 SKU 映射到症状类别,按授权时间段和地理区域聚合购买量,再与季节/历史基线比较,生成 Early Outbreak Detection Index。候选统计方法包括季节时间序列模型和空间扫描统计,并建议用公共卫生数据回顾性评估敏感性、误报率、校准度、地理稳定性和季节性表现。隐私治理要求数据最小化、最小计数阈值、差分隐私、访问控制、留存限制和独立审查,且禁止个体健康推断、定向广告或保险决策。文章明确零售需求只是间接信号,受促销、天气、媒体、囤货和商品可得性影响,GrabMart 用户不具代表性,商品到症状映射也不确定,因此必须本地验证并保留专家解释权。

推荐收录,因为它把零售交易数据用于公共卫生异常检测的系统设计、统计验证和隐私治理边界讲得较完整,尤其是数据最小化、差分隐私、最小计数阈值、独立审查和验证指标,对数据工程、隐私工程和负责任数据应用的读者有参考价值。但文章仍处于早期概念阶段,无部署与实测结果,不能作为落地性能或有效性证据。

工程实践Jane Street Tech Blog

Flex Model: an event-driven feature engineering system

文章介绍 Jane Street 的 Flex Model:把订单簿更新、成交等市场事件转换为神经网络可用的特征向量,并将特征计算与交易执行解耦。旧单体系统新增特征常牵动多处代码,而 Incremental 因合并更新和 cutoff 不适合需要历史状态的行情特征。Flex Model 将特征拆成处理事件的 handler 与按需求值的 eval,禁止运行中改图以保留历史;planner 按事件类型和依赖生成有序计划,使新增计时器或数据源无需改核心。性能上采用启动期预分配、zero_alloc 检查、OxCaml 非装箱浮点和计划执行优化降低尾延迟。其边界是低延迟交易与 OCaml 技术栈,并刻意省略 cutoff、依赖静态图,结论需结合负载评估。

推荐收录:文章用旧系统“改一个特征触及十九个文件”、Incremental 在重复成交价下丢失事件等具体证据,完整呈现了 handler/eval 拆分、planner 生成执行计划和零分配热路径的取舍。适合构建低延迟事件驱动系统、特征平台或 ML 基础设施的读者,其静态计划与内存控制方法可迁移;注意结论依赖 Jane Street 的 OCaml/OxCaml 与交易负载。

工程实践Cloudflare Blog

Filter, reshape, and redact logs before export with Transformers

Cloudflare 介绍 Logpush Transformers:在日志导出流水线内嵌 SQL 转换,客户可按数据集用 WHERE 过滤、SELECT 重塑/重命名/嵌套字段并脱敏,再以 NDJSON 投递,避免额外处理服务与下游成本。实现上选用 Apache DataFusion/Arrow,在 Go 服务 Bufstream 内通过 cgo 与 Arrow IPC 跨 Rust 边界执行,并按时序切片缓存逻辑计划、按 job 并行。基准中 5000 行单 goroutine 约 3ms,约 160 万行/秒。设计强调失败关闭、重试和自动禁用持续失败任务,并暴露健康指标。限制是仅适用于同数据集 NDJSON 作业,会引入 CPU 开销,且跨语言边界仍有序列化与内存管理成本。

推荐收录:文章不是产品发布稿,而是完整披露在每秒亿级事件的日志导出链路中嵌入 SQL 转换的工程方案,包括 DataFusion/Arrow 选型、Go/Rust FFI 所有权管理、逻辑计划缓存、按 job 并行和 fail-closed 策略。适合可观测性、数据管道、高吞吐服务与跨语言性能边界的工程师参考,其性能数据与取舍可迁移到类似日志处理系统。

技术文章NVIDIA Technical Blog

Faster Scientific Image Analysis with NVIDIA cuPhoton

文章介绍 NVIDIA cuPhoton 开源 CUDA-X 工具包,面向天文、X 射线等高吞吐科学成像,目标是把从传感器读取到分类的完整处理链保留在 GPU 上。核心模块包括 xDataReader 直接加载 FITS、xRep 图像对齐、xPois PSF 匹配与差分、xFit 偶极拟合、xScan 候选审查以及 xRay 时域分析。文章以 Rubin Observatory LSSTCam 每 39 秒产生 3.2 吉像素曝光、每晚约 20 TB 和千万候选为背景,说明处理需在 60 到 120 秒告警窗口内完成,并给出多 GPU 下读取最高 14900 倍、信号处理最高 14550 倍的加速,但强调这是单操作而非端到端流水线数据。随后用合成天文图像演示加载、WCS 对齐、卷积核匹配差分、偶极拟合和审阅界面,并说明多 GPU/多节点 MPI 扩展方式。边界上,xDataReader 不支持 Rice 压缩和抖动浮点量化,示例依赖 CUDA 13/Linux 与特定 GPU,性能数字会随负载、实现和硬件变化。

推荐收录,因为文章给出了具体模块 API、FITS/GPUDirect Storage/nvCOMP 路径、PSF 匹配与偶极拟合公式、可运行代码和明确的不支持项,不是产品发布或泛泛宣传。它适合做 GPU 科学计算、高吞吐图像流水线和多 GPU 扩展的工程与研究人员,可迁移到需要在设备端完成加载、对齐、差分和批拟合的场景;但性能数字为单操作且依赖特定硬件,外推时需谨慎。

工程实践DuckDB Engineering Blog

Importing Data using Java Table Functions

文章源自 DuckDB 用户实战,为把 MongoDB 中一年的漏洞数据导入同服务器的 DuckDB,以支撑亚秒级分析查询和快速 Excel 导出,作者系统对比了四种 Java 侧导入方案。基准是 mongo 社区扩展,55 秒完成且查询低于 100ms,但因社区扩展缺乏未来兼容保证、团队又偏好用 Java 维护管道而被放弃。随后测试标准 JDBC 批量插入(3 分 37 秒,因 DuckDB 无原生批量插入、逐行开销大)和 Java Appender(2 分 2 秒,基于 2048 行 Data Chunk 真正批量刷新)。最终发现 mongo 扩展内部使用用户自定义表函数,改用 COPY over Java Table Function,配合 setMaxThreads(8) 与 preserve_insertion_order=FALSE 实现并行,达到 1 分 27 秒的最优 Java 方案。文章还讨论按天分批、导入后排序减小文件体积、磁盘空间约束等边界与取舍,并附可复用的开源代码。

推荐收录:文章给出四种导入方案在同一数据集上的实测耗时(55 秒到 3 分 37 秒)和完整实现代码,并解释性能差异根因,证据具体、可复现。对需要在 Java 中构建 DuckDB 或其他数据库摄取管道的数据工程师很有参考价值,其中表函数并行化、社区扩展长期维护风险和导入后排序权衡等经验可迁移到其他数据源与查询引擎。

工程实践Daniel Lemire

Parsing compressed JSON at 40 GB/s

文章讨论 NDJSON/JSON Lines 大文件压缩后如何高速读取,并以 simdjson 为例。作者用 5 百万条、812 MB 合成数据统计 active 记录并汇总 admin 用户得分。核心是按行边界切分解压缓冲:gzip 单流受 32 KiB 窗口限制只能单线程解压,文中用一线程解压、多线程解析,达约 2.5 GB/s;zstd/lz4 每 256 KiB 在新行处切独立帧,线程可跳过帧头分工解压解析。64 线程下 zstd 达 40 GB/s、lz4 达 34 GB/s,约为 gzip 最佳方案的 16 倍。代价是 zstd 比 gzip 约大 6%,且合成数据重复度高,真实数据可能更慢;适合能控制写入格式的高吞吐数据管道。

推荐收录:文章给出代码、数据规模、线程数和文件大小对照,具体说明 gzip 单流与 zstd/lz4 多帧在并行边界上的差异。对做日志/ML 数据管道、性能优化或存储格式选型的读者,可迁移“按新行切帧+多线程解压解析”的方案,同时注意合成数据重复性带来的速度上限与压缩率取舍。

科研议题Microsoft Research Blog

Forecasting space weather risks on power grids

本文介绍微软研究院实习项目构建的端到端机器学习系统,用于预测空间天气对美国本土66,935个变电站的电网风险。系统先用L1太阳风观测预测AE与Dst指数,再结合纬度、地质电导率和电网数据,以梯度提升模型估计dB/dt并生成位置化风险。2020—2026评估中,AE RMSE为410.2 nT,Dst在62.2%活跃小时优于Burton方程,最终严重事件检测提升1.2个百分点;GIC对10/20/50 nT/min阈值检测率为76.5%/81.2%/64.1%,误报随严重度上升且纬度差异明显。全站推理约333毫秒,但尚未经公用事业运行数据验证,只能用于规划与工程审查,不能直接用于电网运行。

推荐收录。文章展示了从L1太阳风观测、AE/Dst预测到66,935个变电站GIC风险估计的端到端机器学习流水线,并给出相对Burton方程和线性回归的量化对比、严重事件检测率与误报边界。适合AI for critical infrastructure、空间天气和电网韧性方向读者,可迁移其物理约束、位置特征和分阶段评估方法;风险是尚未经运行数据验证,不能直接用于电网调度。

工具笔记DuckDB Engineering Blog

DuckDB Now Ships inside dbt v2

文章介绍 dbt v2(基于 Rust 的 Fusion 引擎)首次内置 DuckDB 适配器。作者回顾 v1 需单独安装 Python 包 dbt-duckdb,而 v2 改为 Rust 单仓 + ADBC 驱动,并自动下载缓存 DuckDB 驱动,配置一个 profile 即可运行。v2 新增 DuckLake 与 Iceberg REST 目录支持(需 use_catalogs_v2 标志)、将 dbt 元数据写成可查询 Parquet、提供原生 SQL 语义理解与列级血缘,并固定 DuckDB 版本以推下更多原生函数。迁移可先在 v1.12 用 opt-in v2 parser 验证,再用 dbt-autofix 和升级指南切换。文章偏功能与用法说明,缺少性能基准和取舍分析,适合使用 dbt/DuckDB 的数据工程读者。

推荐收录:文章给出了 dbt v2 内置 DuckDB 的配置方式、DuckLake/Iceberg catalog、Parquet 元数据查询和迁移路径,属于可操作的工具集成参考。适合数据工程师和分析工程师了解本地 dbt 工作流及 v2 迁移。需注意它偏功能公告,缺少性能与取舍验证,版本锁定可能带来后续适配成本。

工程实践PlanetScale Blog

Blocking cutovers to save replication slots

文章介绍 PlanetScale Postgres 为何会在主从切换时因逻辑复制槽未就绪而主动阻断 cutover。作者先区分物理槽与逻辑槽:物理槽供副本记录 WAL 进度,逻辑槽则把 WAL 解码为面向 CDC 消费者的事件流;若提升的副本没有同步的逻辑槽书签,下游会丢失事件或停摆。PlanetScale 的 Kubernetes operator 会检测 failover、hot_standby_feedback、sync_replication_slots 等配置,发出告警并在计划内切换前等待槽 ready,从而避免静默数据丢失。正确配置包括创建槽时设置 failover=true、在控制台登记槽名,并开启 hot_standby_feedback 与 sync_replication_slots;后者默认关闭,因为会带来 vacuum horizon 固定、主库膨胀和长事务风险。该方法主要面向 PlanetScale Postgres 和逻辑复制槽场景,并非完整搭建指南,且宽限期后仍允许强行切换。

推荐收录,因为文章给出了具体可验证的故障模式、参数配置和平台阻断策略,清楚解释了逻辑复制槽未同步时切换会造成下游数据丢失。适合 PostgreSQL、SRE、CDC 与数据管道维护者阅读,其 failover=true、slot 登记和 hot_standby_feedback 权衡可迁移到自建高可用集群;注意其行为与 PlanetScale 平台托管能力强绑定,原生 Postgres 需自行补齐自动化与保护逻辑。

工程实践Lyft Engineering

Refreshing the Travel-Time Map Behind Lyft’s Marketplace: Rebuilding Neighborhood Reachability…

本文介绍 Lyft 如何重建其市场背后的 Neighborhood Reachability Signals 数据集。该数据集以 geohash-6 网格为单位,由 Airflow DAG 离线生成各区域的 ETA 矩阵与邻里中心文件,为动态定价、供给热力图等提供静态查找表。由于历史刷新均为增量式,核心 ETA 长期停留在 2018–2019 快照,导致旅行时间被系统性低估、可匹配的需求-供给对缺失,甚至把水面等不可驾驶网格纳入。重构以道路网派生的可驾驶 geohash 作为真值来源与最终否决清单,放宽剪枝以提升覆盖并新增消费方自助裁剪字段。Pricing 通过两周时间切分实验验证可行邻居结构从虚假近距离迁移到真实中距离,并计划自动化六个月刷新,下一步朝周内九时段的时间感知 ETA 演进。

推荐收录:文章来自真实生产系统,完整交代了数据集冻结的历史原因、三类缺陷、以道路网为真值的修复路径、放宽剪枝带来的覆盖与成本权衡,以及 Pricing 用两周时间切分实验验证的效果,证据链条清晰。对从事数据管道、地理空间 ETA、市场撮合或定价系统的工程师有直接可迁移价值,九时段分桶与预取权衡也提供了可复用设计模式。

工程实践ClickHouse Engineering

Introducing WalShadow: Sub-second Postgres replication to ClickHouse from physical WAL

ClickHouse 发布开源引擎 WalShadow,直接消费 Postgres 物理 WAL 将数据复制到 ClickHouse,绕开逻辑复制槽与逻辑解码插件。其架构分四阶段:在影子 Postgres 实例中回放 catalog WAL 以维护实时 schema,并行解码堆记录,按表批量组装成 ClickHouse 原生 block,再由独立插入池并发写入。为在并行乱序下保持正确性,每行携带源 WAL 位置 _lsn,schema 变更与 truncate 等操作设置屏障等待前序数据落盘。官方基准(同区域 c8i.2xlarge)给出提交到可见延迟约 200ms、吞吐 28.9 万行/秒,对比 PeerDB 的约 10 秒与 12 万行/秒,并支持加列、改列名、删列、建表等 schema 演进。文章属产品发布稿,性能数据来自单表受限场景,未深入讨论失败模式与运维成本。

收录理由在于它给出了可迁移的 CDC 设计证据:物理 WAL 替代逻辑解码的四阶段流水线、用 _lsn 加屏障解决并行乱序正确性,以及带方法说明的延迟/吞吐基准(约 200ms、28.9 万行/秒 vs PeerDB 约 10s、12 万行/秒)。适合正在设计 Postgres→OLAP 实时同步链路的数据与平台工程师参考。需注意其厂商产品发布属性、单表基准的局限,以及托管版仍处私有预览,落地前应自行验证 schema 变更与故障恢复路径。

工程实践ClickHouse Engineering

Build a real-time market data app with ClickHouse and Massive

文章以构建实时行情 tick 应用为主线,展示如何用 Massive(原 Polygon.io)WebSocket 订阅股票 trades 与 quotes,并用 ClickHouse 存储、Node.js/React 后端与可视化。作者给出 quotes/trades 表结构,以 sym 和一分钟时间桶设计 MergeTree 排序键,比较同步与异步插入后采用客户端批量同步写入。查询端用 argMax/argMin 结合时间戳与序列号生成实时行情表,并按两分钟窗口聚合 OHLCV;还演示 AggregatingMergeTree 物化视图预计算 1 分钟 OHLCV、摄入延迟监控与扩展建议。不足是示例缺少持久缓冲、重放、去重和鉴权,也不处理取消/更正或官方 OHLCV 重建,生产化需补齐可靠性设计。

推荐收录。文章提供了可运行的完整示例和关键设计细节:从 WebSocket 订阅、表结构与排序键、同步/异步插入取舍,到实时行情与 K 线查询、物化视图和延迟监控,均有代码与边界说明,适合构建实时分析、行情数据或 OLAP 摄取管道的工程师参考。其模式可迁移到其他高频事件流场景,但需注意示例本身不是生产级方案,缺少鉴权、持久缓冲和重放去重等能力。

工程实践Lyft Engineering

Rerouting the Stream: How Lyft Moved to the Apache Flink Operator

文章详细记录了Lyft的Streaming Compute团队将内部开发的Flink Kubernetes Operator迁移到开源Apache Flink Kubernetes Operator的全过程。作者首先分析了自研operator的三个核心痛点:维护负担重、功能缺失(如自动伸缩、自动回滚、内存自动调优)和依赖陈旧。随后介绍了迁移策略:通过部署API在边界处将旧的FlinkApplication CRD翻译为FlinkDeployment,实现增量迁移而不改变用户工作流。迁移后还解决了BlueGreen部署、自动伸缩受限于Flink版本、自动调优与Beam Python SDK内存冲突等问题,并引入Karpenter动态节点池和两档资源策略。最终平台节省了每年数百万美元的资源开支,并让团队从维护者转为开源生态使用者。文章也指出了迁移的复杂性,如状态机差异、内存模型不匹配和CRD转换等边界。

本文是一份真实的工程迁移案例,完整展示了从自研基础设施转向成熟开源方案的全过程,包括决策理由、增量迁移设计、问题修复和最终收益。适合负责流处理平台、Kubernetes基础设施或数据工程的工程师阅读,其边界翻译、两阶段策略和成本优化思路具有很强的可迁移性,同时文末也客观指出了迁移中的风险和代价。

工程实践Grab Tech

Data Mesh at Grab (Part III): Operationalizing data reliability with automated DPIs

文章介绍 Grab 如何通过自动化数据生产问题(DPI)把数据可靠性变成可运营的工作流。DPI 生命周期分为分诊、诊断、解决三阶段:分诊用 Kinabalu 评估契约测试、去重并聚合告警;诊断借 Data Health API 把失败归因为上游、平台、作业或数据错误并路由负责人;解决由 Hugo 自动重试等恢复常规故障,高风险才升级人工。文中给出生产数据:86.9% 的 DPI 自动解决,95% 以上自动创建,自动处理 MTTR 比人工快 6 倍。架构强调诊断与执行解耦,并展望了数据可靠性对 AI Agent 的价值。

本文来自 Grab 工程团队,展示了数据可靠性运营的完整闭环:从契约测试、告警分类、根因定性到自动修复,并附有 86.9% 自动解决率、MTTR 6 倍改善等生产数据,证据充分。适合数据平台工程师、SRE 和数据架构师参考,其通过稳定 API 屏蔽平台差异、诊断与执行解耦的架构思路可迁移到其他数据基础设施。

工程实践ClickHouse Engineering

Ensuring reliable OpenTelemetry ingestion at scale

ClickHouse 团队复盘内部可观测性平台 LogHouse 的 OpenTelemetry 摄取管道三次演进。第一版 agent+gateway 架构在 5000 万 events/s 规模下无法承受 ClickHouse 反压而频繁 OOM;第二版启用 collector 本地 WAL,需改造成 StatefulSet,1TiB 积压约需 4 小时排空,且 FIFO 顺序阻塞最新数据,只能截断 WAL 丢数据。团队放弃引入 Kafka,改用基于 S3 的优先级故障转移:仅在 ClickHouse 反压时由 failover connector 溢出到对象存储,再通过 SQS 事件通知由独立 catchup collector 回灌,规避常态 PUT 成本。文中给出完整 collector 配置与一小时停机 gameday 验证结果,也指出恢复期无法定位具体缺失数据、新区域需额外基础设施等局限。

推荐收录:文章完整呈现从默认两层采集架构到自研 S3 溢出方案的取舍链条,给出 5000 万 events/s、1TiB 积压需 4 小时排空、每年 10-50 万美元 PUT 成本等具体数字,并用一小时停机 gameday 验证无数据丢失。对负责可观测性采集、高吞吐数据管道或 ClickHouse/OTel 落地的工程师,其 failover connector 的队列开关顺序、优先级路由和 catchup 回灌设计可直接迁移。

技术文章Elastic Security Labs

How a team of entity maintainers monitors, connects and scores entities in Elastic Security

文章由Elastic Security Labs发布,深入解析了Elastic Security中实体分析(Entity Analytics)的实现机制。其核心是Entity Store v2,一种基于ES|QL查询语言和后台维护者(maintainers)架构的实体存储引擎,区别于传统SIEM的平面快照式实体处理。文章详细说明了实体记录的构建流程:通过ES|QL管道将原始事件聚合为实体基记录,再经LOOKUP JOIN合并历史状态;利用确定性实体唯一ID(EUID)和命名空间策略区分身份来源,如身份提供者与本地主机。维护者定期运行,负责建立访问关系、自动/手动身份解析以及累计风险评分,并支持通过API或UI纠正解析错误。文章还提供了自定义数据源接入的ECS字段配置指南,并指出当前扩展方向包括非人类身份(NHI)和动态风险评分。

推荐收录。文章以真实产品为载体,详细拆解了实体解析系统的工程实现,包括ES|QL管道、确定性ID派生、命名空间消歧、维护者调度和可追溯风险评分,技术细节充足且可验证。适合SIEM/安全分析平台开发者、数据工程师和架构师参考;其中的身份解析、增量合并、可纠正状态设计等模式可迁移至通用实体管理场景。唯一需注意的是内容来自厂商官方,可能偏重自家产品特性,但本文的架构分析和数据接入指南仍具长期参考价值。

工程实践SelectDB 技术分享

15 分钟搭建 PostgreSQL + Apache Iceberg + Apache Doris 的湖仓分析平台 搭建一条 CDC 实时数据同步链路,往往意味着要部署 Kafka、Debezium 等额外组件。有没...

文章以 PostgreSQL + Apache Iceberg + Apache Doris 为例,介绍如何用 OLake 快速搭建端到端的 CDC 湖仓分析链路。作者拆解了各组件角色:OLake 通过读取 PostgreSQL WAL 捕获变更并写入 Iceberg,Doris 作为查询引擎直接读取 Iceberg 表,并给出选择 Doris 的五个理由,包括全向量化执行、支持主流 Catalog、原生处理 Delete File、Time Travel 以及谓词下推和分区裁剪。随后提供完整部署命令和配置步骤,声称在一台小规格 Linux 实例上十几分钟即可跑通。文章还总结了生产环境关键注意事项,如控制文件大小、设计分区策略、定期执行 Snapshot 过期清理与 Compaction,以及按基础设施选择 Catalog。最后列举了业务实时看板、即席分析、SQL 分析平台和历史分析等应用场景。整体方案可快速复现,但 Demo 中使用本地 REST Catalog 属于简化做法,生产高可用与权限体系仍需另行设计。

这篇文章不是简单的产品介绍,而是给出了从组件选型、部署命令到生产调优的完整工程实践路径,其 OLake + Iceberg + Doris 的示例可直接用作实时湖仓链路的前期验证。适合正在评估 CDC 数据同步、开放湖仓架构或希望快速搭建可运行 Demo 的架构师和平台工程师。文章对文件大小、分区、表维护等注意事项的归纳可迁移到其他 Iceberg 湖仓场景,但需注意 OLake 仍属相对年轻的开源项目,并且部分性能结论来自官方或商业方的公开数据,迁移到大生产规模前应做独立验证。

工程实践DuckDB Engineering Blog

Reconciling JSON in DuckDB, One Patch at a Time

本文是 DuckDB 工程博客的客座文章,介绍 DuckDB v2.0 JSON 扩展新增的四个标量函数:json_merge_patch_diff(计算 RFC 7396 merge patch 的逆)、json_deep_merge(null 表示跳过合并的递归合并)、json_normalize(递归排序键以生成规范形式)和 json_strip_nulls(递归删除 null 值键)。文章以 Atlan 的元数据同步场景为背景,展示这些函数如何组合成端到端的状态对账流程,用 SQL 单查询完成清洗事件、计算最小补丁、应用补丁和规范化哈希。作者在 50 万条合成 CDC 事件上对比了 Python 实现,DuckDB 获得 10 到 123 倍的加速,并说明性能来自 yyjson 原地操作和向量化执行。文章也明确了函数语义边界,如 SQL NULL 与 JSON null 的差异、数组元素顺序保留等。

推荐收录,因为这是一篇来自数据库核心团队的一手设计解读,包含函数语义、实现机制、组合用法和可复现基准,不是泛泛的功能介绍。对使用 DuckDB 做数据管道或 JSON 对账的工程师、数据库内核开发者都有直接借鉴价值,其 diff/merge/normalize/strip 的抽象也可迁移到其他数据处理系统。

工程实践LinkedIn Engineering - Architecture

Rebuilding messaging: How we bootstrapped our platform

文章复盘 LinkedIn 重建消息平台时的存量数据迁移过程。旧系统单体且数据非规范化,共享内容与个人元数据冗余存储;新系统改为规范化微服务,将共享消息与个人元数据分离。迁移采用三阶段方案:先双写实时复制新写入,再通过确定性 UUID v5 生成新旧 ID 映射,最后对 17 年快照做 Hadoop ETL、变换和批量上传。文章重点介绍了阴影验证机制、基于 If-Unmodified-Since 避免覆盖在线更新,以及表索引数量影响上传吞吐等经验。整体展示了大规模在线数据迁移中可迁移的架构权衡与实施细节。

推荐收录:文章提供了 LinkedIn 超大规模消息系统数据迁移的完整工程案例,包含三阶段方案、双写一致性、离线变换与阴影验证等具体实践。对负责数据库迁移、分布式一致性和后端架构的读者具有直接参考价值,尤其展示了复杂在线系统零停机迁移的可操作方法。

工程实践LinkedIn Engineering - Architecture

From Lambda to Lambda-less: Lessons learned

文章记录了 LinkedIn 的 “谁看过你的个人资料” 功能从 Lambda 架构迁移到 Lambda-less 架构的工程实践。原架构以近线 Kafka 处理为速度层、Hadoop MapReduce 为批处理层、Pinot 为服务层,但双管道导致业务逻辑重复、维护成本高和 bug 风险增加。迁移后,团队采用 Samza 作业统一处理 ProfileViewEvent 和 NavigationEvent,移除与流处理重叠的离线逻辑,仅保留一个离线作业将实时数据复制到离线表以优化查询性能和数据保留。文章重点讨论了流式处理中的消息可重处理性与去重策略,包括分场景修复错误、Kafka offset 回退,以及在服务层和通知层去重。最终,该迁移使开发速度翻倍、维护开销减半,并改善了用户体验,为面临类似架构冗余的团队提供了可参考的经验。

推荐收录,因为这是一篇真实的架构演进案例,详细展示了 Lambda 架构的实际痛点、简化决策过程以及流式处理中非幂等问题的应对方法。文中对 Samza、Pinot 的选型理由和去重策略有具体描述,对从事数据管道设计、流/批处理和分布式系统演进的后端工程师极具参考价值。需要注意的是,方案的选择与业务实时性要求紧密相关,直接照搬需评估自身场景。

工程实践LinkedIn Engineering - Scalability

Engineering LinkedIn's job ingestion system at scale

本文复盘了LinkedIn职位摄取系统的设计,该系统每日处理数百万职位、超20TB原始数据。文章先梳理异构源、传输协议、安全、数据新鲜度等挑战,再介绍模块化事件驱动流水线和Job Intake、Job Processing Pipeline两大阶段。重点阐述Job Pull的orchestrator与专用Mining Node分离、抽取逻辑配置化、AI辅助Sitemap创建,以及基于START/JOB/END状态机的Mining Task和优先级队列。处理层通过静态/动态Job Field Processor和pre/mid/post三层实现清洗、增强与校验,并通过multiplexing生成衍生职位。文章以配置驱动扩展、上游背压和让用户掌控平台为关键经验,但偏高层架构,未深入具体实现与性能数据。

收录的直接证据在于文章展示了从异构数据摄取到标准化处理再到发布的全链路架构,包括orchestrator/worker分离、配置驱动抽取、优先级队列和动态处理器等可迁移设计。适合分布式系统、数据平台或集成工程师借鉴,尤其对需要快速接入多源数据、控制上游负载和将定制能力下放给非工程团队的系统有启发。风险是偏高层描述,缺少细粒度实现和量化验证,但整体技术深度满足长期参考要求。

工程实践Salesforce Engineering

How Standardizing Product Telemetry Reduced Time to Insight by 97%

文章介绍了Salesforce如何通过构建标准化的产品遥测平台(PDP)解决各产品团队各自定制遥测导致的数据孤岛、重复劳动和无法规模化的问题。PDP采用统一的遥测架构和自动化指标生成管道,要求团队遵循标准化的埋点规范,从而自动产出可信的产品采纳指标。技术上,它基于监控云基础设施构建了自定义模式,并处理每天450亿行事件数据,覆盖19000个事件和2000多个产品特性。实施后,洞察获取时间从约1个月缩短至每日刷新(降低97%),开发者埋点工作从数周减少到数小时,CSAT达9/10。标准化的数据基础也为AI分析工具和MCP集成提供了可信支撑。该工程案例适用于大规模多产品环境下集中式数据平台的建设与推广,但需注意组织推动和标准治理的复杂度。

本文是典型的工程实践复盘,提供了从问题识别、架构设计到规模化推广和量化的完整过程,尤其在统一数据标准、提升数据质量和自动化的权衡方面具有可迁移价值。适合负责数据平台、指标体系建设或开发者效率的工程师参考。量化结果(97%时间缩减)和推动团队采用的方法论具有说服力,有助于读者借鉴其建设可信数据基础、赋能AI工具的思路。

工程实践QuestDB Engineering

Read Streaming 500 million rows into Apache Arrow in 2.3 seconds

文章测试 QuestDB 新 QWP 协议将查询结果流式传输到 Apache Arrow 的性能,并与 ClickHouse、TimescaleDB 对比。作者用简单查询和并行读取器基准,测量 500M 行数据的导出速度。最初几轮结果受磁盘 I/O、Python GIL 等因素影响,修正后 QuestDB 达到 220M 行/秒,首批数据仅 32ms,比 ClickHouse 最快流式路径快 2.35 倍。文章还分析了每行字节数、存储占用、扩展性和协调成本,并指出测试的局限(单一 schema、低基数字符串等)。该文提供了可复现的测试方法和详实的过程反思。

推荐收录,因为它不是简单的产品宣传,而是深入的工程基准测试,展示了如何识别并消除磁盘、GIL、协调成本等测试伪影,并提供了可复现的仓库和明确的局限声明。适合数据库选型、性能评估或数据管道设计的读者,可迁移价值在于严谨的流式数据导出基准测试方法和工程分析框架。

工程实践GitHub Security Lab

How we took malware advisories beyond npm

文章介绍了 GitHub Dependabot 团队如何将恶意软件通告从仅支持 npm 扩展到覆盖八个主要包生态系统。核心方法是构建一个统一的 OpenSSF 恶意软件包仓库导入器,复用已有的仓库导入模式,通过严格验证 OSV 记录、映射生态系统名称、归一化版本范围,并利用 origin 元数据避免重复导入自身产生的通告。为应对自动发布可能引入的错误数据,设计了三层防护:批次创建上限的熔断、每个通告的可追溯性以及整批次可回滚。最终,用户可在仓库中启用 Dependabot 恶意软件警报,覆盖 npm、PyPI、Maven 等生态,该管道已在生产环境中运行。

推荐收录,因为本文详细记录了将恶意软件检测从单生态扩展到多生态的真实工程实践,包括导入器设计、数据归一化、去重策略和安全防护设计,展现了在自动发布高风险安全通知时的权衡与工程防护。适合关注软件供应链安全、安全告警管线或开源安全基础设施的工程师和架构师阅读,文中批量熔断、来源追溯和回滚机制可迁移至类似高敏感度自动化流水线。

工程实践知乎 - 腾讯技术工程

腾讯Omega:下一代“AI BI”的答案?

文章深度复盘了腾讯 Omega AI BI 系统从理念到落地的完整过程。针对传统 BI 操作门槛高、ChatBI 仅能完成单次查询的局限,Omega 将 AI 重建为分析工作的协作体:由 LLM 规划指标、组织页面并生成 HTML,同时通过 QueryRegistry 数据契约和 DTBridge 运行时解耦数据查询与界面,实现页面与真实数据的持续联动。文章详细阐述了指标证据链构建、语义模型接入、筛选器依赖图、多层安全防护、运行时契约(有界、可取消、可观测、可自纠)等关键设计,并分享了模型幻觉、慢查询误杀、成本权衡等真实事故与应对。结论强调 AI 生成页面仅是第一层,系统化地保证页面第二天仍可用、分析可延续、Agent 出错可体面恢复才是产品化的核心,适用于拥有数据底座且具备一定治理水平的企业场景。

本文是一份高质量的工程复盘,不是泛泛的产品介绍,而是细致拆解了 AI BI 系统从原型到可生产产品的核心矛盾与解决方案。对负责 AI 产品化、数据工程、系统架构或安全设计的读者有极强的可迁移价值,尤其在如何用确定性系统约束 AI、如何保证数据查询与界面长期可靠联动方面提供了可复用的模式。

工程实践知乎 - 千问云

理解归 AI,正确归引擎:从一句话到一条实时数据链路(0代码搭建实时任务)

本文以直播业务为背景,介绍了一套 AI 辅助、指标驱动的实时数据端到端开发系统。系统将业务需求抽象为“维度 + 指标”,通过依赖回溯自动构建 Flink SQL 任务拓扑,并支持增量 Hook 调整。文章详细展示了从自然语言需求到可发布任务的全流程,包括需求澄清、DSL 生成、SQL 生成、增量演进与任务发布。系统架构上,LLM 负责理解用户意图并生成结构化 DSL,确定性引擎保证 SQL 正确性,前端提供人工确认节点,三者通过 DSL 契约松耦合协同。文中还总结了指标驱动范式、理解与正确性分离、Hook 安全接入等可迁移方法论,以及实时资产沉淀路径。案例中开发周期从天级缩短至分钟级,但系统仍依赖人工校验,增量调整目前仅支持不改变拓扑的局部修改。

推荐收录,因为本文不是浅层工具介绍,而是围绕一个真实工程问题,系统化地展示了从架构设计、核心机制到方法论的完整实践。对从事实时数据开发、Flink 任务构建或探索 AI 辅助软件工程的读者来说,文中提出的指标驱动回溯、理解与正确性分离、Hook 协议等方案,可直接迁移到类似平台或工具的建设中,具有长期参考价值。

技术文章OpenTelemetry Blog

Lambda-powered functions land in OTTL

文章介绍了 OpenTelemetry Collector Contrib v0.157.0 为 OTTL(OpenTelemetry 转换语言)引入的 lambda 表达式能力。此前,处理集合操作需要为每个用例硬编码专用函数,而 lambda 让用户能够将内联逻辑传入通用高阶函数,从而以更可复用且简洁的方式实现复杂的数据转换。文中列出了随版本发布的八个新函数:Filter、MapEach、MapKeys、Any、All、Find、Reduce 和 When。这一增强标志着 OTTL 向函数式范式的转变,有助于简化遥测管道的配置与维护,但文章未详细讨论 lambda 在此场景下的性能开销或适用边界。

文章介绍了一项 OTTL 语言级别的重大增强,通过 lambda 和高阶函数提供了更通用的集合转换能力,对构建和维护复杂遥测管道的工程师具有直接参考价值。其所展示的函数式抽象思路可迁移至其他管道工具或 DSL 设计,适合可观测性实践者和平台工程师阅读,但读者需注意文中可能未涉及生产环境下的性能影响等边界讨论。

工程实践Yelp Engineering

Training Orchestrator: Unifying Model Training at Yelp

本文介绍了Yelp为统一机器学习模型训练而构建的Training Orchestrator系统。面对多团队使用各自Spark训练脚本、配置分散、代码重复和维护成本高的问题,Yelp核心ML团队在已有特征存储、统一训练库、MLflow等工具的基础上,设计了一套标准化的训练编排层。该平台提供了统一的作业调度、工作流执行和监控机制,将模型训练任务抽象为可复现的流水线,并与Spark和MLflow无缝集成。文章还讨论了系统架构的权衡、对团队效率的提升以及适用范围(主要服务于基于Spark的训练场景)。

推荐收录,因为该文不是泛泛的MLOps概念介绍,而是基于Yelp真实工程需求,详细展示了从分散脚本到统一训练平台的架构演进。文中对训练编排、与现有ML基础设施集成的设计权衡,以及规模化运营的考量,对正在构建或优化内部ML平台的数据与工程团队具有直接参考价值。其可迁移经验包括如何通过平台化手段降低维护成本、提升模型训练的一致性,但需注意其方案强绑定Spark生态。

工程实践Salesforce Engineering

How Informatica Reduced Data Integration Pipeline Development from Days to Minutes

本文以Informatica Copilot为例,介绍如何通过自然语言生成数据集成管道,将开发时间从数天缩短到数分钟。文章回顾了从微调模型转向OpenAI的架构决策、应对模型快速演进的测试策略,以及通过提示工程、上下文增强和验证层提升准确性的方法。客户已生成约10,000条管道,表达式自动生成采纳率约60%,表明AI辅助显著提升效率。核心结论是生成式AI的准确性更依赖上下文与防范机制而非模型规模,并提出未来将支持代码优先和代理式工作流。案例局限于数据集成领域,但工程思路具有可迁移性。

推荐收录,因为文章提供了从模型迁移、非确定性系统测试到提示调优与验证的完整工程案例,并附有客户采纳数据作为证据。适合正在构建AI特性尤其是LLM集成的工程师阅读,可借鉴其迭代适应基础模型、通过验证层保障准确性的实践。主要迁移价值在于揭示了提升AI系统精度不依赖更大模型,而在于上下文设计与保护机制。

工程实践Netflix TechBlog

The Data Canary: How Netflix Validates Catalog Metadata

文章介绍了 Netflix 为高频更新的 catalog metadata 构建“data canary”系统的工程实践,用真实生产流量验证数据变换后的最终输出是否会引入损坏。作者详细说明了为什么传统代码 canary 和影子流量不够用,以及如何通过独立 orchestrator、baseline/canary 双集群、混沌实验平台扩展、sticky canary 和实时中止机制,在 10 分钟内完成检测并阻断坏数据发布。文章还给出了主动注入故障的验证结果,说明该方案能在 2.5–4 分钟内识别回归,并把数据错误从“影响播放的事故”前移为“发布前拦截”。

推荐收录,因为它不是泛泛讲“数据质量重要”,而是给出了高频数据管道如何借助生产流量、行为指标和自动化闸门实现快速验证的完整方案。对于做数据平台、实时链路、SRE 或可靠性工程的读者,这篇文章在检测指标选择、实验窗口缩短、误伤控制和系统扩展性方面都有很强的迁移价值。

工程实践Spotify Engineering

Background Coding Agents: Supercharging Downstream Consumer Dataset Migrations (Honk, Part 4)

这是 Spotify 工程博客关于后台编码代理 Honk 系列的第四篇,复盘了用 Honk 配合 Backstage 与 Fleet Management 完成数据集消费者迁移的案例。为下线两个高频用户数据集并发布带新维度的版本,团队需在六个月内迁移约 1,800 条直接下游数据管道,涉及 BigQuery Runner、dbt、Scio 三种框架,原本估计约需 10 工程周。团队用 Backstage 的 endpoint 血缘与 Codesearch 定位目标仓库,用 Fleetshift 编排迁移;因 Scio 变异过大而放弃,针对较标准化的 dbt 与 BigQuery Runner 编写含明确字段映射表的上下文文件,并标注需人工判断处。最终产出 240 个自动化迁移 PR。核心教训是代理规模化依赖数据栈标准化与仓库级测试验证,否则代理无法自验证,只能依赖下游团队人工测试。

推荐收录:这是规模化后台编码代理落地的真实工程案例,给出 1,800 条下游管道、240 个自动 PR、约节省 10 工程周等具体数据,并如实披露三框架差异、代理无自定义技能、缺构建期测试等约束与取舍。对做 AI 编码代理工程化、平台工程或数据迁移的读者,其上下文工程、可验证性依赖和标准化前置条件等结论可直接迁移。

工程实践Instacart Tech Blog

Turning Data into Velocity: Caper’s Edge and Cloud Data Flywheel with Capsight

这篇文章介绍了 Instacart 为 Caper 智能购物车搭建的 Capsight 闭环系统,目标是把门店端产生的多模态数据快速转化为模型迭代能力。作者先指出三类痛点:端侧可观测性不足、真实门店数据覆盖不够、数据清洗标注训练链路过慢,因此设计了 Collect→Manage→Label→Train→Deploy 的数据飞轮。系统由 Collector、Depot、Learner 三部分组成:端侧用触发式采集和硬件编码避免性能回退,云端做数据处理检索与 VLM 预标注,训练侧用 Ray 自动化分布式训练和评测。文章给出量化结果:标注成本预计降低 70% 以上,训练阶段从一周缩短到两天,端到端迭代从约一个月压缩到一周,模型准确率在数周内提升超过 5%。它的适用边界也很明确,主要依赖高价值事件触发、稳定的门店网络与较强的多模态数据基础,后续还需要继续优化触发敏感度、传输成本和跨模态扩展能力。

文中直接给出了端侧采集、云端管理、AI 预标注和分布式训练的完整闭环,还附带了标注成本、训练周期和准确率提升的量化结果,属于可复用的 AI 工程化案例。适合做端云协同、MLOps 和多模态数据管线设计参考,但其触发采集与零售门店场景强绑定,迁移时需重新评估数据价值、带宽和误触发成本。

工程实践Yelp Engineering

Revenue Automation Series: Testing an Integration with Third-Party System

文章来自 Yelp 的 Revenue Automation 系列,聚焦在收入数据管道与第三方系统集成时的测试和验证方案。作者先说明现状:原本依赖 Redshift Connector 在报表发布后再同步到数仓,导致验证数据要延迟约 10 小时才能可见,严重影响迭代效率。基于这一约束,文章讨论了如何设计更稳健的生产测试与集成策略,以便在复杂转换逻辑下尽早发现问题。它的核心价值不在于单点工具,而在于围绕批处理数仓、外部系统联调和回归验证建立更短反馈闭环。该经验对类似的数据工程、财务/收入类流水线和第三方集成场景具有较强迁移性,但对实时系统或纯应用单测场景的直接参考有限。

文中直接给出旧方案通过 Redshift 同步带来约 10 小时验证延迟,这是重新设计测试链路的明确工程证据。适合做数据管道、数仓联调和生产验证的团队阅读,可借鉴其将反馈时延作为核心约束来优化测试策略的思路。

工程实践PlanetScale Blog

Building data pipelines with Vitess

文章围绕 Vitess 在数据管道中的用途展开,先说明 Vitess 更擅长支撑 OLTP,而分析、报表和跨系统同步这类 OLAP/集成场景需要借助 CDC/ETL 来补足。作者重点介绍了 Vitess 的 VReplication 与 VStream 能力:通过 VTGate 暴露统一的变更流,把一个可能由大量 shard 组成的逻辑库抽象成单一数据源。文中进一步解释了 Debezium、Airbyte、Fivetran 等工具如何依赖这些底层原语把 Vitess 的变更传播到数仓或其他系统。文章还给出可运行的本地示例,展示快照、增量变更和分片后的统一流输出,帮助读者理解复制与重分片过程中的事件形态。其边界在于它更偏架构说明和实践入口,较少讨论容错、延迟、乱序等生产级细节。

文中直接给出了 Vitess 的 VStream/VReplication 作为 CDC 基础、以及 Debezium/Airbyte/Fivetran 的对接方式,证据明确且可操作。适合需要在分片 MySQL 上构建同步、数仓或跨系统集成的工程师,迁移价值在于理解“统一变更流+连接器”的实现路径,但生产细节仍需补充验证。

科研议题Stanford Hazy Research

Data Wrangling with Foundation Models

这篇文章介绍了斯坦福 Hazy Research 将基础模型用于结构化数据清洗与整合的研究,目标是把 schema matching、entity matching、错误检测、缺失值补全和数据转换等传统数据 wrangling 任务统一起来。作者先把表格行和字段序列化为文本,再把各类结构化任务改写成自然语言问答式提示,从而直接调用 GPT-3 进行 zero-shot 或 few-shot 推理。实验显示,即使不做专门微调,模型在多个基准上也能取得可用结果;仅用 10 个人工挑选示例,就能在 14 个数据集中的 11 个上追平或超过既有方法。文章同时指出两类主要局限:小模型效果明显落后于大模型,而大模型推理成本高;提示格式和示例选择又十分脆弱,性能波动较大。整体上,这是一篇把 LLM 引入结构化数据处理流程的早期方法总结,适合关注数据管理、提示工程和 AI4DB 的读者参考。

文中给出了清晰的研究问题、方法设计和基准结果,尤其是“序列化表格+任务改写为生成式提示”这一直接证据,说明 LLM 可在结构化数据任务上产生可迁移价值。适合做数据工程、提示工程和 AI for Data Management 的入门参考,但也要注意其对模型规模和提示格式较敏感,落地时仍需评估成本与稳定性。