Data Engineering

76 篇内容

技术文章DuckDB Engineering Blog

Ducks in a Column

文章以 DuckDB 的列式存储为线索,解释分析查询为何只需读取命中的列,并串联起文件原地查询、通配符与 Hive 分区、投影/分区裁剪、列级 SQL、聚合快捷语法、窗口函数与 QUALIFY、ASOF JOIN,以及写出高压缩 Parquet 的排序、分区、窄类型和 EXPLAIN ANALYZE 验证。核心结论是让查询只读取所需列和值,可同时减少 I/O、提升压缩率并利用 zonemap 跳过数据块。文中示例具体、可操作,适合作为 DuckDB/SQL 分析实践参考;但内容偏官方特性导览,主要覆盖 DuckDB 方言和 Parquet 场景,对底层内核实现与其他数据库的差异讨论有限。

推荐收录:文章把列式存储原理与 DuckDB 的原地查文件、列级 SQL、聚合/窗口/ASOF、Parquet 分区排序等具体用法对应起来,并用 EXPLAIN ANALYZE 展示投影裁剪和分区跳过,证据充分。适合做数据分析、ETL 或本地/湖上查询的工程师作为可迁移的 SQL 与文件组织参考;风险是 DuckDB 方言和产品特性较强,跨数据库迁移时需注意等价语法与底层差异。

工程实践ClickHouse Engineering

How OpenRouter observes, understands, and acts on 740 million LLM requests a day with ClickHouse Cloud

文章以 OpenRouter 为例,说明其用 ClickHouse Cloud 统一承载 LLM 网关的可观测性、公开模型排行、内部 AI Agent 和路由决策数据。请求遥测通过同步/异步批量插入、ClickPipes 与 Fivetran 进入原始表,再由物化视图生成活动、端点健康和任务类型汇总,并用 dbt 与 Airflow 构建数仓。内部 Agent 通过受控 API 查询数据,支持请求失败追踪和错误归因。路由形成闭环:读取用户偏好、评估供应商、选择端点并回写结果;Jev Router 还按任务分类、真实使用排名、约束过滤和端点选择来选模型。文章属于厂商案例,缺少详细 schema、性能成本对比和失败边界。

推荐收录:文章给出了从多源摄取、物化视图汇总、dbt 数仓到 Agent 查询和路由反馈闭环的具体链路,能作为 LLM 网关与实时可观测数据平台的架构参考。适合数据工程、ML 平台和可观测性团队读者。需注意其来自 ClickHouse 厂商案例,缺少 schema、成本和故障细节,迁移时应补充压测与取舍验证。

工程实践Microsoft Research Blog

From synthetic enterprise data evaluations to real Microsoft Copilot AI confidence

文章介绍 Microsoft Copilot 的企业级评测基础设施:为规避真实客户数据隐私风险,团队构建全合成企业租户环境,并用 O*NET、招聘信息和 SEC 文件等公开数据校准组织结构、角色与业务上下文。平台包含动态合成工作区、自动化查询流水线和质量框架,覆盖制药、资本市场和 IT/软件三类行业,强调时间演化、行业术语和内容安全。六阶段流水线把通用任务模板转成有数据依据、自然且去重的评测查询,再从结构保真、上下文相关性、行为真实性和内容安全等维度评估质量。作者报告合成数据综合质量提升 39%,部分环境得分超过 0.9,数据集创建从数天人工降至自动运行,单数据集约节省 10 万美元。该平台已成为 Copilot 的标准化评测基线,但文章主要给出内部指标,缺少外部复现、与真实企业数据的直接对照及失败案例分析,跨行业适用边界仍需验证。

推荐收录:文章具体拆解了合成企业环境、六阶段查询生成流水线、质量维度和隐私设计,并给出质量分数、成本节省与标准化基线等证据。对做 LLM/Agent 评测、合成数据和企业 AI 工程化的读者,“公开数据校准—动态合成—自动查询—安全筛查”的流程可直接迁移到内部评测平台建设;风险是结果主要来自厂商内部指标,外部复现和真实数据对照有限。

技术文章QuestDB Engineering

Read One table, three readers: QuestDB, Polars and DuckDB on the same Parquet

文章围绕一张按天分区的 FX trades 表,演示 QuestDB 将旧分区转为 Parquet 后,QuestDB SQL、Polars 与 DuckDB 三种读取方式能对每日 VWAP、成交笔数、成交量和高低价得出一致结果。作者给出完整步骤:通过 QWP 写入 150 万行数据、建立物化视图、执行 CONVERT PARTITION TO PARQUET、直接读取 data.parquet,并用 SQL 与两种 Python/分析引擎交叉验证。文章重点说明 Parquet 分区仍是活表的一部分:迟到写入会被接受并触发 row group 重写,去重 upsert 生效,但 UPDATE 会被拒绝,后台 compaction 会回收空间。Enterprise 部分进一步展示同一批 Parquet 文件迁移到对象存储、采用 Hive 分区供 Trino/Spark/BigQuery/Snowflake/DuckDB 读取的路径,并强调 QuestDB 是唯一写入者、seal 后迟到写会被跳过、远程读取延迟更高。适用边界是时间分区表、以顺序写入为主且能接受对象存储查询延迟的场景;文中数据为合成数据,文件大小和性能结论不应直接外推。

推荐收录,因为它不是单纯的产品介绍,而是用可运行示例和交叉验证展示 Parquet 分区在数据库、Polars、DuckDB 之间的互操作细节,并明确写出迟到写入、UPDATE 限制、文件重写、compaction 和冷存储 seal 等边界。适合正在评估时间序列数据库冷存储、Parquet 湖仓互操作或 DuckDB/Polars 分析工作流的数据工程师参考。主要风险是厂商立场和合成数据,性能与容量数字只能作为示意,不应视为中立基准。

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

TiDB 多表查询数据分析:一家网店的销售数据是怎么被扒明白

文章以网店销售分析为例,解释业务表为何拆分,并用 users、orders、order_items、products、categories 五张表演示 INNER JOIN 与 LEFT JOIN。它给出建表、造数、品类 GMV、城市贡献、复购和沉睡用户等 SQL,再用 Python、SQLAlchemy 和 pandas 连接 TiDB,完成宽表读取、分组聚合、透视表与用户分层。文中强调 WHERE 过滤、GROUP BY 聚合、ORDER BY 排序的分析顺序,并指出 LEFT JOIN 右表条件应放在 ON、TiDB Cloud 需 SSL 等要点。整体适合入门复现,但偏通用 SQL/pandas 教程,对 TiDB 执行计划、索引和大数据量性能边界讨论不足。

推荐收录,因为文章提供了从五表建模、JOIN 查询到 pandas 分析的完整可运行链路,并明确点出 LEFT JOIN 过滤条件位置和 SSL 连接等易错点。适合 SQL/数据分析初学者和需要快速搭建 TiDB 演示环境的开发者作为可复现参考;不过它偏基础教程,缺少查询优化和大数据量边界,长期价值主要在入门教学与代码模板。

工程实践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 官方博客的客户访谈,缺少独立压测与迁移后量化结果,引用其结论时应结合自身负载验证。

技术文章DuckDB Engineering Blog

From JSON Strings to Typed Columns

文章面向以 VARCHAR 存储 JSON 的列,介绍如何在 DuckDB 中不落盘、不 COPY 到文件,直接推断结构并转换为类型化列。核心流程是用 json_group_structure 汇总 JSON 结构,再用 json_merge_patch 覆盖字段类型,随后用 json_transform 解析并通过 unnest 展开字段。文中还讨论了递归展开的列名冲突、对象数组展开、json_transform 与 strict 版本对转换失败的不同处理,以及 VARCHAR 与 JSON 类型在存储和校验上的差异。结论是一次装载时完成 JSON 解析,后续查询直接使用普通类型化列,可避免重复解析并提升可读性。适用边界是大表可采样推断但可能漏掉稀有键,宽松转换会静默产生 NULL,需确认数据异常是否可接受。

推荐收录:文章给出了从 JSON 文本列到类型化列的完整 SQL 流程,包含结构推断、类型覆盖、递归展开和错误处理等可直接复用的操作细节。适合使用 DuckDB 或做 JSON/半结构化数据清洗的工程师参考,其中“采样推断可能漏键、宽松转换会静默置 NULL”的边界说明也便于迁移时评估风险。

工程实践Netflix TechBlog

DataJunction as Netflix’s answer to the missing piece of the modern data stack

Netflix 工程团队复盘在实验平台引入开源语义层 DataJunction 的经历,目标是解决指标定义分散、难发现和难信任的问题。旧系统要求业务知识、实验约定和复杂工程流程,新增指标耗时数周;团队评估 Mando、Minerva、DJ,最终因 DJ 具备 SQL 解析/生成和连通图元数据存储而选用。架构上坚持 API 优先、语义图核心优先,暂缓 UI、缓存等外围能力,并以 cube 作为消费协议,支持与 Druid、Superset 等工具集成和指标定义回链。DJ 源自 Facebook 内部 MDF 项目,2021 年开源后在 Netflix 扩展,先在实验域落地,再计划统一全公司分析指标。文章属于经验性架构复盘,缺少性能基准、部署细节和失败案例,适合了解语义层选型与平台演进思路,不宜当作完整实现指南。

推荐收录。文章给出了真实平台演进证据:从旧实验指标流程数周交付,到评估多个语义层方案,并以 SQL 解析/生成、连通元数据图和 API 优先作为 DataJunction 的核心取舍;它还说明了 cube 服务接口、Druid/Superset 集成等可迁移设计。适合数据平台、分析工程和实验平台团队参考,风险是缺少性能指标与落地细节,不能替代实现文档。

工程实践Netflix TechBlog

Running Apache Spark experiments in my sleep (and on a plane)

文章复盘 Netflix 会员会话化 Spark 流水线升级中大规模 OOM、shuffle 溢出与阶段重试的工程案例。因小样本无法复现问题,作者根因定位到数据倾斜与长尾会话,并利用 Dataflow 分支名实现实验隔离,在同一时间窗并行运行多个全量实验。借助 AI Agent 与 tmux 自动化部署、轮询、对比与恢复,把多日串行调试压缩为一天内多轮实验。技术层面定位到 collect_list 按事件袋缓冲、Option 装箱和冗余字符串导致内存膨胀,通过去装箱、精简事件袋、Window 前截断及将 AQE 运行时广播阈值降至 10MB,使峰值内存从 112% 槽位降至 58%。文章还记录“变窄反而更快 OOM”与广播连接累积占约 3.1GB 等反直觉发现,并指出调优只能买时间,事件袋无界增长时架构必须改变。

推荐收录。文章以真实生产 OOM 为起点,完整呈现了从“小样本无法复现”到分支隔离并行全量实验、用 AI Agent 自动化操作,再到 collect_list/Option 装箱/AQE 广播阈值等根因定位与修复的工程闭环。对大数据平台、Spark 性能优化和 AI 辅助运维读者,其中“一次实验只改一个变量”“关注单行宽度与累积广播内存”等经验可直接迁移;局限是流程依赖 Netflix 内部 Dataflow/Maestro 环境。

工程实践NVIDIA Technical Blog

How to Rewrite Apache Spark UDFs for GPU Acceleration with AI Agents

文章分析 Apache Spark UDF 破坏声明式抽象、迫使 GPU 管道回退 CPU 及列行转换开销的问题。作者给出三种重写路径:SQL 表达式、RapidsUDF/cuDF Java API 列式操作、JNI 自定义 CUDA 内核,并按复杂度与场景对比。为降低改写成本,文章介绍 cuDF skills 的四阶段代理工作流:生成测试、转换、基准测试和优化,每阶段用可执行验证与性能数据作反馈。某消费科技公司用它改写 30+ 生产 UDF,示例在 6000 亿行负载上把算子时间从 274.55 小时降至 12.78 小时,约 22 倍。边界是依赖 GPU/cuDF 环境和测试基准,复杂逻辑可能仍需 CUDA,性能结论也来自单一厂商案例。

推荐收录。文章不仅解释 UDF 回退机制,还给出 SQL、cuDF、CUDA 三类重写路径及四阶段代理技能反馈闭环,并附 30+ 生产 UDF、22 倍加速的实测证据,能帮助 Spark 与数据工程读者设计 GPU 迁移和验证流程。主要风险是 NVIDIA 厂商视角且性能数据来自单一案例,读者需结合自身 GPU 环境和测试集判断可迁移性。

工程实践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 用户不具代表性,商品到症状映射也不确定,因此必须本地验证并保留专家解释权。

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

技术文章DuckDB Engineering Blog

What Is Inside an Iceberg Table?

本文以 DuckDB 的 iceberg 扩展为例,拆解 Apache Iceberg 表的磁盘结构:顶层 metadata.json、每快照一个 Avro manifest list、若干 manifest,以及底层 Parquet 数据文件和删除文件。作者用本地 REST catalog 创建按日期分区的示例表,执行两次插入和一次删除,再用 SQL 逐层读取,展示 snapshot 演进、摘要计数、manifest 内容、列统计与分区统计。核心结论是 Iceberg 文件不可变、提交只移动 catalog 指针,删除采用 merge-on-read 的 position delete 文件,统计信息用于跳过文件和分区。文章也提醒小提交与删除文件过多会拖慢查询,并说明 summary 字段可选、format-version 3 的 Puffin 删除向量未展开。

推荐收录。文章给出了可复现的 SQL 步骤,从 catalog 指针一路查到 manifest、列/分区统计和 position delete 文件,直接证据充分,能帮助数据工程师在查询变慢、行数异常或跨引擎写表时定位 Iceberg 表内部原因。其文件树、快照提交与统计跳过机制可迁移到 Iceberg 表布局审查和性能诊断;局限是示例较小且依赖本地 fixture,未覆盖所有引擎差异。

工程实践Daniel Lemire

Parsing JSON at tens of gigabytes per second… in Python

Daniel Lemire 用 GH Archive 八小时 7.6 GB NDJSON、220 万事件做实测,统计新开 Pull Request 的仓库语言。方法是用 Python 3.14t 无 GIL 版本和 fastsimdjson 的 map_many,以 64 线程并行解析;每线程维护独立 Counter,最后合并,并通过 lazy=True 只创建访问字段的 Python 对象。单核下 lazy 版达 2.13 GB/s,明显快于标准 json 0.18、orjson 0.42、非 lazy 0.63 和 msgspec 1.29;64 线程下 lazy 版达 65.7 GB/s,7.6 GB 约 0.12 秒,约为单核 31 倍,并快于 msgspec 的 24.6 GB/s。结论是在特定库、无 GIL Python 和惰性解析条件下,Python 可达到数十 GB/s JSON 解析;但依赖 fastsimdjson、free-threaded 版本和内存中数据,且延迟与内存开销等边界未充分展开。

推荐收录:文章给出可复现基准、完整代码和与 json/orjson/msgspec 的横向对比,直接证据是 64 线程 lazy 解析 65.7 GB/s、约 0.12 秒处理 7.6 GB。它适合 Python 性能、数据管道和 JSON/NDJSON 处理读者,可迁移每线程累加器、惰性视图和并行基准方法;但方案依赖无 GIL Python 3.14t 与 fastsimdjson,需评估兼容性和内存开销。

工程实践ClickHouse Engineering

How iSAM Funds built an options research platform for a 10,000x data problem with ClickHouse Cloud

文章介绍 iSAM 期权研究团队如何将数据平台从 Postgres 原型迁移到 ClickHouse Cloud,以应对约一万个相关期权合约带来的万倍数据放大。团队指出交易所产品成交量分布不均,简单分片难以均衡负载。迁移后按时间序列存储获得 35-50 倍压缩,单核写入从每秒 8000 行提升到 80 万行,并可直接用 Arrow/Parquet/JSON 进出数据。因列存与向量化执行足够快,团队取消了预聚合、物化视图和下采样管线,把复杂度集中到业务侧。托管服务满足认证、网络隔离、备份与弹性扩容;但作为厂商客户案例,文章缺少表结构、查询模式和失败边界等可复现细节。

推荐收录,因为文章给出了可迁移的工程决策证据:从 Postgres 迁移到列存数据库后获得 35-50 倍压缩、单核写入提升百倍,并因查询足够快而删除预聚合与物化视图管线;同时讨论了负载不均、托管服务与弹性扩容等取舍。适合数据工程师和架构师评估大规模金融时序/期权数据的 OLAP 选型与迁移路径。需注意其厂商客户案例属性,缺少 schema、查询样例和失败边界,复现与独立验证价值有限。

技术文章SelectDB 技术分享

Apache Doris x Fluss:面向湖流一体的统一查询与分析 实时分析如何同时兼顾最新事件、历史数据和不断更新的状态?Apache Doris 5.0 新增 Fluss Catalog,支持直...

文章介绍 Apache Doris 5.0 的 Fluss Catalog 与湖流一体查询方案:Fluss 用日志表追加事件、主键表维护当前值及变更日志,数据分 Log 与 Lake 两层;Doris 可直接查询 Fluss,Union Read 以 Paimon 湖快照为基线拼接 Fluss 增量,并支持表名、$lake、$log 三种读取范围及 auto/required/disabled 模式。作者以自动驾驶路测为例说明异常排查,并给出单机性能对比:Union Read 在计数、分组统计上比纯 JNI 读快数倍,但全表明细优势有限。未开启湖表自动合并时可能 OOM,可用 enable_jni_heap_admission 控制堆内存。当前功能仍为实验性,湖端仅支持 Paimon,测试为单机环境,实际使用需关注快照就绪、日志保留和主键尾部合并上限。

推荐收录:文章不仅介绍 Doris 5.0 Fluss Catalog 的产品集成,还展开 Fluss 日志表/主键表语义、Union Read 的湖快照与增量衔接、$lake/$log 读取范围及三种模式,并用单机测试量化纯 JNI 读与 Union Read 的耗时、CPU、磁盘和 OOM 边界。对做 OLAP、流式存储或湖仓一体的数据工程师和架构师有较高参考价值,读取范围选择、资源控制和验收模式可迁移到类似湖流查询系统。主要风险是厂商视角、单机 benchmark 绝对数值有限,且功能仍为实验性。

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

Oracle 11g R2 → TiDB 8.x 迁移实施步骤

本文给出从 Oracle 11g R2 迁移到 TiDB 8.x 的端到端实施步骤,覆盖迁移前评估、环境与工具规划、对象与 DDL 改造、全量导入、增量同步、数据校验、性能压测、切换演练、正式割接和回退预案。文章强调空字符串与 NULL 语义差异、自增主键热点、大事务、存储过程/触发器/JOB 需下沉应用层等关键风险,并指出 TiDB DM 不能直接作为 Oracle 11g 的标准增量同步工具,通常需结合 OGG、Flink CDC 或自研链路。文中还给出全量导出导入、增量同步配置、行数与字段级校验、压测调优、割接和回退的具体操作及 DBA 交付物清单。其适用边界是异构关系型数据库迁移场景,尤其是 Oracle 到 MySQL 兼容分布式数据库的替换,需先在测试环境完整演练后再执行。

推荐收录:文章不是产品发布或概念介绍,而是把 Oracle 11g 到 TiDB 8.x 迁移拆成可执行阶段的工程手册,包含兼容性风险、同步工具边界、校验方法、压测调优和回退演练等直接证据。适合正在做异构数据库替换的 DBA、后端与 SRE 读者,可迁移其评估清单、DDL/SQL 改造顺序和割接回退流程;不过具体工具版本和参数仍需按实际环境验证。

工程实践NVIDIA Technical Blog

Building Reliable Data Analytics Agents: Lessons from the KDD Cup

NVIDIA KGMON 团队复盘其在 KDD Cup 2026 Data Agents 竞赛中获得第二名的系统设计,核心论点是把 agent 的 harness 做得更小、更清晰、更易验证,而不是让模型更开放。针对赛方指定的固定中小型开源 LLM,团队遵循两条原则:约束动作空间,并让每次尝试可被检查。具体手段包括把 CSV/JSON 统一进单一 SQLite 查询面、用只读 schema 预扫描提前给出连接键与数据质量上下文、只暴露 schema()/sql(query)/write_answer(df)/prose_helper() 等少量工具并持久化中间状态、将散文文档与结构化数据分离处理、必要时离线预处理视频、记录执行轨迹供 inspector agent 归类失败,以及按任务价值有选择地做多次尝试。文章也明确指出该方案受竞赛条件(固定模型、无网络、价值级评分、长预算)塑造,并提醒自主改进循环容易过拟合基准、多次尝试会推高 token 与算力成本,需保留集验证与人工审核。

推荐收录,因为文章以真实竞赛系统为证据,给出了统一数据访问、schema 预扫描、受约束工具集、文档与结构化数据分离、轨迹审计等可操作手段,并交代了成本、过拟合与适用边界。适合正在构建 LLM 数据分析 agent、关注可靠性与可观测性的工程师,其 harness 设计思路可迁移到生产级 agent 系统。

工程实践Salesforce Engineering

Apache Spark Resource Optimization: Lessons From Eight Million Jobs a Day

文章复盘 Salesforce Data 360 每天约八百万次 Spark 作业的资源优化。团队不改应用代码,在提交网关 DPC 注入基于 DataFlint 的 listener,将驱动遥测经 Kafka 汇入 Iceberg,并用 Silver 层统一应用、作业、stage attempt 与 executor 语义。文章指出成功完成不等于配置高效,需区分零任务 executor、CPU 空闲、shuffle fetch 失败与 spill,并在完整可比运行内归因成本。基于证据,团队把某作业 initialExecutors 从 40 降至 4,另一队列最大 executor 降约 20%,保留动态分配;生产观察一月余无不可接受回退,匹配窗口周成本降 31%,DPC 启动数增逾 7%。作者强调这是前后对比而非受控实验,且非通用 Spark 参数。

推荐收录:文章以每天八百万次 Spark 作业为背景,给出从共享提交网关采集遥测、建立语义分析层、定位零任务 executor 与 CPU 空闲,再到生产灰度和成本收益的完整证据链。适合数据平台、SRE 和大数据性能工程师参考,其“把资源估算当假设、用执行证据选择变更、用后续运行验证”的方法可迁移到其他 Spark/Kubernetes 负载。风险在于 31% 降幅来自前后对比而非受控实验,读者不应照搬具体参数。

技术文章DuckDB Engineering Blog

A DuckDB Database with No Data in It

文章介绍如何创建一个不存储任何数据的 DuckDB 数据库文件,只用视图定义指向对象存储上的 Parquet 文件,从而把几百 KB 的文件当作整个数据湖的共享目录。作者演示安装 httpfs、创建持久化数据库、定义远程视图、上传目录文件以及只读 attach 的完整流程,并说明查询会按需读取远端列与行组。文章还展示当文件从单文件改为按年分区或列名变化时,只需替换视图即可保持消费者查询稳定。最后给出适用边界:消费者需能访问目录和所有底层数据、HTTPS/S3 连接只读、性能受网络和远端文件布局影响。

推荐收录。文章以可执行 SQL 和工作流说明 DuckDB 仅存视图的目录模式,涵盖创建、托管、只读挂载、schema 演化和限制,属于可迁移的数据湖共享目录设计。适合数据平台、DuckDB 用户和希望减少数据复制、向消费者暴露稳定关系集的工程师;但需注意网络凭证、只读限制与远端查询性能风险。

工程实践ClickHouse Engineering

How LinkedIn extended ClickHouse from distributed tracing to metric discovery and analytics

LinkedIn将ClickHouse从分布式追踪扩展到指标元数据发现与分析。追踪系统每天约0.8万亿span和200TB数据,在三数据中心、每集群22分片部署,通过列排序和重分区将查询优化到2秒内。随后团队把超130亿指标、30%日更替的遗留RRD元数据从三个独立服务迁移到单一ClickHouse集群,用ReplacingMergeTree去重、变更捕获和别名切换实现透明迁移,并用投影支撑重聚合。新系统每分钟服务15万+查询,平均延迟68ms,内存和计算分别降至约1/5和2/3,且有余量翻倍指标量。该案例技术细节具体,但来自ClickHouse官方博客,且单分片设计和大规模迁移的后续演进未充分展开。

推荐收录,因为该文给出LinkedIn超大规模使用ClickHouse的完整工程细节:追踪系统分片、red-black部署与查询优化,指标元数据迁移的ReplacingMergeTree去重、变更捕获、别名切换和投影设计,以及150k QPM/68ms、内存降至1/5等可验证结果。适合可观测性、大规模数据平台和OLAP选型的工程师参考,迁移策略和Schema设计可迁移。主要风险是官方博客可能有宣传倾向,且单分片扩容细节未展开。

工程实践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 数据管道、性能优化或存储格式选型的读者,可迁移“按新行切帧+多线程解压解析”的方案,同时注意合成数据重复性带来的速度上限与压缩率取舍。

工程实践Datadog Engineering

How we extended Apache DataFusion to execute one query across many machines

Datadog 为统一查询栈,选择 Arrow 作为内存格式、Substrait 作为执行计划格式、Apache DataFusion 作为可组合查询引擎,但 DataFusion 只能在单机执行查询,无法支撑其最大的交互式负载。为此团队开发了开源 Rust 框架 Distributed DataFusion,仅作用于物理计划层,复用 DataFusion 分区模型并把分区扩展到多机,引入 stage、task、DistributedLeafExec 等概念,以及 NetworkShuffle、NetworkCoalesce 等节点完成跨机重分区与结果汇聚,支持分区连接、广播连接、分布式 union 和树形归约聚合。文章给出在 12 节点 c5n.2xlarge 集群上基于 TPC-H/TPC-DS(1GB–100GB)与其他引擎的对比,并说明生产中重查询最高提速 10 倍,而计划器会在分布收益不足时让轻查询留在单机。作者还解释了为何放弃 ClickHouse、Spark、Ballista、Trino:需要的是可扩展框架而非完整引擎,且必须低延迟、零拷贝、与 Arrow/Substrait 及自有网络栈集成。其边界在于面向交互式低延迟场景,而非后台容错批处理作业。

推荐收录:文章基于真实生产约束(低延迟交互式查询、DataFusion 单机瓶颈)给出了完整的设计取舍、物理计划改造细节和可复现的 TPC-H/TPC-DS 基准,并明确说明何时不分布。对构建查询引擎、数据基础设施或评估分布式执行框架的工程师,其分区扩展、网络 shuffle/coalesce 机制与引擎选型理由都可迁移参考。

工程实践Jane Street Tech Blog

What the TDOE interns have wrought, 2026 edition

本文是 Jane Street 交易台运营工程师(TDOE)2026 年暑期实习项目综述,用三个案例说明实习生如何在陌生复杂领域中快速交付。其一,将内部电话成交记录与无标识的公开成交带按时间、数量和价格匹配,识别被拆成多笔打印的情形,主动发现对账差异;其二,梳理 MEMX 与 IEX 对 Primary Peg 订单类型的不同定义,用 OCaml 与 FIX 实现此前未编码的属性并测试验证;其三,为成分股横跨五大洲、假期日历各异的 ETF 合并计算可下单、可交易、可结算日期,并借 Webs 让业务规则可由终端用户修改。文章只做项目综述,未给出实现细节与量化结果。

推荐收录:文中给出可迁移的问题建模证据——无标识公开成交带的对账与拆分打印识别、同一字段名在两交易所语义不同导致的编码歧义、跨市场假期的结算日历合并,对从事交易系统、数据对账或规则建模的读者有参考价值。需注意本文属实习生项目综述并带招聘导向,缺少实现细节与验证数据,宜作领域复杂度与问题拆解的参考,而非实现指南。

工程实践Cloudflare Blog

How fast is the web? Explore billions of real-user measurements with BEACON

Cloudflare 发布 BEACON 公开数据集,基于 10,000 个大型网站的数十亿次真实用户性能测量,按 RUM Archive 标准每日更新到 Google BigQuery,覆盖主流浏览器引擎。文章介绍 Core Web Vitals 的 LCP、CLS、INP 直方图,支持任意分位数分析,并给出 LCP 与 INP 的子阶段拆解。关键发现包括 WebKit 在部分国家落后于 Blink、软导航比硬导航快 2-3 倍但首屏更重、带宽与 LCP 相关,以及非洲的传输体积较小。还说明去标识化、站点规模归一化和聚合等隐私与方法边界,适合性能工程、数据分析和 Web 研究参考。

推荐收录,因为它提供可公开查询的 BEACON 数据集、BigQuery 示例查询,以及 Core Web Vitals 子阶段和软/硬导航等可迁移的性能分析框架。适合 Web 性能工程师、浏览器/标准研究人员和数据团队评估真实用户体验、长尾分位数与架构取舍。需注意其样本限定为 Cloudflare 前 10,000 个站点,归一化与聚合会影响结论外推。

技术文章QuestDB Engineering

Read Which time-series join? ASOF, WINDOW, HORIZON, LT or SPLICE

文章系统比较 QuestDB 的五种时序 JOIN:ASOF、WINDOW、HORIZON、LT、SPLICE,并说明 LATERAL JOIN 如何按行复用它们。作者以 FX 交易与行情表为例,在公开 demo 上给出可运行 SQL,解释每种连接的时间匹配方式、返回行数、聚合行为和典型用途:ASOF 取事件时刻的最新值,WINDOW 聚合时间窗口内多行,HORIZON 在多个固定偏移上重复 ASOF,LT 取严格早于当前时间戳的前值,SPLICE 实现双向全外 ASOF。文章还讨论 TOLERANCE、EXCLUDE PREVAILING、CTE 组合限制、WINDOW 与 HORIZON 的混淆、LT 避免前视偏差等边界。最后提醒 demo 数据为合成数据,应关注查询语义而非市场结论。

推荐收录:文章不是泛泛介绍,而是用一组可运行 SQL 和返回行数直接证明五种时序 JOIN 的语义差异,并给出选择依据与组合限制。它适合数据库、时序数据分析、量化/监控系统开发者作为查询设计与选型参考,ASOF/WINDOW/HORIZON 的区别和 LT 防前视偏差等方法可迁移到其他时序系统;主要风险是语法和部分行为绑定 QuestDB。

技术文章DuckDB Engineering Blog

DuckDB and Hugging Face: Querying Datasets Directly

文章介绍 DuckDB 通过 hf:// 协议直接查询 Hugging Face Hub 数据集的集成方案。自 v0.10.3 起,DuckDB 在 httpfs 扩展上支持 hf:// 路径,可把数据集仓库解析为 CSV、JSONL 或 Parquet 文件,无需先下载即可用 SQL 读取,并支持通配符扫描多文件、列裁剪、@ 版本固定和 ~parquet 分支。文章给出探索数据集、过滤采样、基准评测、与自有表连接和可复现分析等典型用例,还说明私有/门控数据集可通过 Secrets Manager 配置 token。边界在于公共数据集开箱即用,重复查询建议物化为本地表,整体更偏重官方用法与操作指南,未深入讨论远程读的性能模型和异常处理。

推荐收录:来源为 DuckDB 官方工程博客,提供了可直接运行的 SQL 代码、版本固定与私有数据集配置等具体证据,展示如何把 Hugging Face 数据集纳入本地 SQL 分析工作流。适合数据工程、ML 工程和需要快速探查/采样训练数据的读者,方法可迁移到其他远程 Parquet 数据集场景;主要不足是内容偏用法指南,缺少性能边界与失败模式的深入分析。

工具笔记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 迁移。需注意它偏功能公告,缺少性能与取舍验证,版本锁定可能带来后续适配成本。

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

山东政务协同、聊城烟草与企业知识库背后:五类场景共用一套 TiDB 底座

文章整理山东腾安信息的 TiDB 实践:政务协同、烟草数据中台、企业知识库、异构迁移和数据库安全五类场景共用一套数据库底座。做法包括将 12 套政务系统收敛为两个隔离集群,用 RU 配额与优先级做多租户调度;烟草中台以 TiKV 行存和 TiFlash 列存同时支撑交易与分析;知识库把 SQL 权限过滤与 HNSW 向量检索结合在同一份数据上。迁移侧用 TiDTS 编排全量与增量同步,安全侧用 DBNginx 将连接入口变为访问治理入口,结论是共性数据能力应下沉为可调度、可分析、可迁移和可治理的基础设施。不足是文章为厂商实践分享,缺少性能、成本、故障和量化收益对比,方案有效性需结合自身规模验证。

推荐收录。文章给出了多系统收敛为两个集群、HTAP 行存列存协同、SQL 权限过滤与 HNSW 向量检索结合、TiDTS 迁移编排和 DBNginx 访问治理等具体证据,适合数据库平台、数据中台和安全治理工程师参考。其可迁移价值在于把重复建设问题拆成资源调度、分析、检索、迁移与安全等可治理能力;风险是厂商视角明显,缺少量化收益与失败边界,选型时仍需独立验证。

工程实践知乎 - SmartCode 得物技术

指标平台:从语义底座到智能消费的实践路径|得物技术

文章复盘得物内部指标字典从 0 到 1 的落地实践,核心是把业务隐性口径转化为结构化、唯一可信的语义资产。业务侧逆向梳理存量报表并用“沉淀—观察—转正”机制收编隐性指标,数仓侧通过血缘核查与分批改造把散射依赖收敛到域内精品宽表,产品侧用 YAML 解析、维度管理和多技术来源物理映射把上架流程工程化,并在提报环节以语义相似度检测拦截口径二义性。作者给出 Text2SQL 与 AI Coding 两条消费主线的验证证据:系统测评 SQL 准确率从 85%+ 提升到 95%+,且与条件拼接修复、时间解析固化等治理动作一一对应,OneData 建设全流程提效 40%+。文末提出以消费热度反哺治理优先级、元数据下沉到消费方式等闭环方向,但结论高度依赖得物自身组织与数据规模,跨公司可迁移性仍需验证。

推荐收录:文章提供了从语义底座建设、二义性拦截到 Text2SQL/AI Coding 消费验证的完整工程链路,并用 85%+→95%+ 的准确率趋势和 40%+/70%+ 的提效数据作为直接证据,而非泛泛方法论。适合负责数据平台、指标治理、Text2SQL/RAG 语义层或 AI 辅助研发的工程师与架构师参考,其中“消费驱动治理”“多技术来源统一交付”“血缘核查先行”等做法可直接迁移;但需注意结论基于得物自身组织与数据规模,跨团队落地要重新评估边界。

技术文章Oxide Public RFDs

RFD 0463: The Oximeter Query Language

本文是 Oxide 的 RFD 463,描述用于查询和加工机架遥测数据的领域特定语言 OxQL。oximeter 采集硬件与软件指标并存入 ClickHouse,OxQL 以表、时间序列、字段和数据点为核心模型,支持 gauge、cumulative counter、delta 与 histogram,并在读取 cumulative 数据时自动转为 delta,以便对齐、聚合和连接。语言采用 Unix 管道式表操作(get、filter、align、group_by、join)和子查询,配合字面量、比较/逻辑运算符及 EBNF 语法定义。文档强调自研 DSL 的理由:现有 SQL 和各类指标查询语言不适配时序数据且集成成本高。其边界是目前不支持 raw cumulative 选择和 outer join,且作为发布后不再更新的规范,主要面向 Oxide 内部与用户文档。

推荐收录。该 RFD 不是新闻或营销稿,而是完整给出了 OxQL 的设计动机、数据模型、语法定义、示例和查询语义,包含 cumulative 到 delta 的自动转换、对齐/分组/连接等可迁移概念。适合做可观测性、时序数据库、DSL 或后端查询系统的读者参考。注意其内容与 Oxide 机架和 ClickHouse 强绑定,且 RFD 声明发布后不再更新,迁移时需结合具体数据模型取舍。

工程实践Salesforce Engineering

How AI Agents Get Trusted Customer Context with Data 360 Data Graphs

文章以 Q&A 介绍 Salesforce 如何用 Data 360 data graphs 为 AI Agent 提供可信客户上下文。核心是在上游连接身份、账户、产品、权益、合同与订单等关系并执行业务逻辑,再用分区架构隔离客户数据,仅向 Agent 暴露过滤后的客服视图。为应对不可预测提问,方案按访问模式拆分多图、建立索引并支持语义/关键词检索,使 P50 延迟从约 400ms 降至 200ms 以下;同时通过自动化部署和可复用校验,在六个月内交付五个数据图。局限是来自厂商访谈,缺少 schema、失败案例和成本细节,适合作为 Agent 上下文与数据图谱架构参考。

推荐收录:文章给出了 Agent 可信上下文落地的具体工程证据,包括按访问模式拆分多图、分区隔离身份数据、语义/关键词检索,以及 P50 延迟低于 200ms 的指标,并总结六个月交付五个数据图的可复用实践。适合 AI Agent、客户数据平台、数据图谱和低延迟服务的设计者参考,可迁移到上下文供给、数据隔离与性能取舍;但来自厂商访谈,缺少 schema、成本与失败细节,落地前需验证。

工具笔记ClickHouse Engineering

Loading Parquet data into MySQL with ClickHouse

文章介绍如何借助 clickhouse-local 与 ClickHouse 的 mysql 表函数,把 S3 上的 StackOverflow 投票 Parquet 数据直接写入并在 MySQL 中查询,因为 MySQL 本身没有原生导入 Parquet 的方式。作者用 Docker 启动 MySQL 8.4,下载 ClickHouse 二进制,并通过 ch-config.yaml 定义命名集合 mysql_demo 保存连接凭据。核心步骤包括用 DESCRIBE url() 探查 Parquet schema、在 MySQL 建表,再执行 INSERT INTO FUNCTION mysql(...) SELECT ... FROM url() 导入约 230 万行数据。文章重点区分两种查询方式:在 FROM 中写 ClickHouse 子查询时,ClickHouse 会解析并改写成 MySQL 合法 SQL;而通过 query() 传入字符串则原样下发,因此含 tuple 等 ClickHouse 特有函数会直接报错。作者也说明示例为本地演示环境,凭据以明文参数传入,生产系统应改用环境变量。

推荐收录,因为它给出可复现的完整方法,解决 MySQL 无法原生导入 Parquet 的真实数据搬运问题,并明确划出 mysql 表函数的两条边界:ClickHouse 子查询会被改写为 MySQL SQL,而 query() 字符串原样下发,这一区别容易踩坑。适合做 ETL、跨库迁移或用 clickhouse-local 做临时数据处理的工程师参考,命名集合与批量 INSERT 写法可直接迁移;不足是偏操作步骤,性能与生产安全约束讨论有限。

工程实践QuestDB Engineering

Read DuckLake and QuestDB: the same Parquet, a different table format

文章对比两种开放表格式在元数据存放位置上的根本差异:Iceberg 把元数据写成对象存储中的 metadata JSON、manifest list 和 Avro manifest 文件,目录只保存指向当前元数据文件的指针;DuckLake 则把全部元数据(文件列表、schema 历史、快照、统计信息)存放在 SQLite、Postgres 或 DuckDB 这类 SQL 数据库中,目录即元数据本身。作者由此推导出三点后果:查询规划退化为对索引表的 SQL 查询、不存在元数据小文件堆积因而无需 compaction、但读取方必须能连接该数据库导致生态覆盖较窄。文章随后给出把 QuestDB 冷存储的 Hive 分区 Parquet 通过 ducklake_add_data_files 零拷贝注册进 DuckLake 的具体脚本,并讨论增量同步、删除单文件时需重新注册存活集合、关闭 auto_compact 保护原始文件,以及纳秒时间戳在 DuckDB 视图中降为微秒的边界。

推荐收录。文章不是产品宣传,而是把“表格式即 Parquet 之上的元数据层”这一抽象讲清楚,并用 Iceberg 与 DuckLake 元数据存放位置的差异推导出查询规划、运维成本和生态覆盖上的具体取舍。附带的注册与同步脚本、零拷贝约束和版本相关注意事项,对做数据湖、冷存储分层或 lakehouse 选型的工程师有直接可迁移价值;需注意示例仓库明确非生产工具,且结论带有 QuestDB 自身存储的视角。

工程实践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、市场撮合或定价系统的工程师有直接可迁移价值,九时段分桶与预取权衡也提供了可复用设计模式。

工程实践SelectDB 技术分享

Apache Doris+ Paimon 2.0:构建 Agentic AI 数据闭环 通过统一 SQL 打通向量检索、实时分析与结果写回,共同为 Agent 构建新鲜、可信、可验证的业务上下文 湖仓...

文章围绕“Agentic AI 需要持续可行动的数据闭环”这一目标,指出传统 BI 只回答因果、RAG 只返回相关文档,而 Agent 还需要结合订单、库存、设备状态等实时业务事实进行关联分析和决策,并能够写回行动结果。为此,文章提出 Paimon 2.0 与 Apache Doris 的分工共治方案:Paimon 2.0 通过 BLOB、VECTOR、VARIANT、Data Evolution、Global Row ID 和 Global Index 支持多模态数据的持续演进与索引;Doris 通过 Paimon Catalog 保持快照读取语义,将 Vector Index 作为查询计划中的候选生成阶段,在 MPP 引擎中完成过滤、Join、聚合与全局 Top-K,并支持标准 SQL 的 INSERT、UPDATE、DELETE、MERGE 等写回操作,从而形成“感知—检索—分析—行动—反馈”闭环。文章还以工业故障诊断场景为例,介绍了快手在 Paimon 湖表上做千万到亿级向量检索的生产实践:召回率 96.0%~99.6%,在远端 Alluxio 缓存下与 Doris 内表对比的查询耗时为后者的 1.07~4.18 倍。文末给出了建目录、查询和写回的简单 SQL 示例。需要说明的是,部分能力仍属发版预告,性能数据依赖缓存配置,读者需结合实际版本和场景验证。

推荐收录。文章不是简单的产品宣传,而是具体展示了如何用 Paimon 2.0 的开放数据格式与 Doris 的 SQL 执行能力构建 Agent 可用的实时上下文,包括向量索引下推、候选裁剪、快照一致读取和 SQL 写回等关键设计,并给出了快手亿级向量检索的召回率与性能对比数据,证据相对直接。适合正在规划 Agent 数据平台、实时湖仓或多模检索架构的数据工程师和架构师参考;其“避免复制第二份数据进独立向量库”的架构思路具有可迁移价值,但能力成熟度和性能需要结合具体版本、缓存和硬件条件验证。

工程实践Salesforce Engineering

How Metadata and Runtime Telemetry Reveal Which Enterprise System Problems to Fix First

这篇文章介绍Salesforce工程团队如何构建Health Insights,用于大规模企业组织健康监控。核心难点在于配置元数据与运行时遥测分散在不同系统,没有统一身份模型、新鲜度和访问规则。团队采用附加式架构而非重建底层管道,通过统一协调层和连接器模式将运行时活动映射到具体组件,同时保留数据来源、新鲜度和访问要求。他们从约100个安全信号出发,结合Well-Architected原则和反模式清单扩展到约400个信号,覆盖安全、流程自动化、定制、数据模型和Agentic readiness等领域。优先级排序结合请求量、应用CPU、数据库CPU和峰值时段等运行时上下文,并通过无头架构以JSON和MCP接口输出可交互的下一步行动,支持应用内或Slack等场景。文章还指出方案边界:它依赖Salesforce生态和已有元数据管道,其他平台需自行适配身份模型与访问控制,且初始重点是预防反模式。

推荐收录,因为它展示了真实的大规模健康监控与遥测集成案例,包含明确的架构取舍、信号标准化和优先级排序方法,而不是泛泛谈论监控价值。适合负责系统健康平台、可观测性数据管道或企业级监控系统的工程师借鉴,其“保留数据来源与决策状态、结合运行时上下文排序”的思路可迁移到其他复杂系统。

技术文章QuestDB Engineering

Read Parquet and Iceberg: how a table format builds on a file format

文章系统解释 Parquet 文件格式与 Iceberg 表格式的分层关系。先讲 Parquet 的列式布局、统计信息与谓词下推优势,再指出以目录管理多个 Parquet 会在原子提交、并发写、快照、schema 演进和小文件上出问题,而 Iceberg 正是为了解决这些问题。Iceberg 不替代 Parquet,而是在文件之上增加元数据层,通过快照实现原子提交、时间旅行与多引擎互操作,且可直接注册已有 Parquet 而无需重写。文章以 QuestDB 冷存储为例,展示将历史分区转为 Parquet 放入对象存储、再用 PyIceberg 的 add_files 注册为 Iceberg 表的流程,并说明分区同步、纳秒时间戳和 UUID 兼容等运维边界。作者明确演示脚本是 demo,生产需自建带认证目录。

本文清晰区分了文件格式与表格式的职责边界,并用 QuestDB 冷存储配合 Iceberg 注册的完整示例证明 Parquet 可以无需重写即被 Iceberg 采用,概念解释与工程实践并重,属于长期可参考的数据工程内容。适合数据平台工程师、数据架构师及希望理解 Lakehouse 底层原理的读者。文中也提醒了分区同步和类型映射等落地风险,但厂商背景和 demo 代码需结合生产环境谨慎对待。

工程实践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 屏蔽平台差异、诊断与执行解耦的架构思路可迁移到其他数据基础设施。

工程实践DuckDB Engineering Blog

DuckDB Table Functions in Java

文章介绍 DuckDB Java 客户端新增的纯 Java 表函数能力,允许开发者将任意 Java 可访问的数据源注册为 SQL 表,从而在单节点上完成跨远程系统与本地文件的异构查询,无需导出或中间表。作者以 MongoDB 为例,通过 DuckDBFunctions.tableFunction() 注册 mongo_query 函数,并详细说明 bind、init、apply 三个回调:bind 声明输出列,init 打开游标,apply 将数据按 2048 行向量块写入结果。文章强调该方式复用官方 Java 驱动、过滤条件下推到源端,且避免了原生扩展的构建与 JVM 崩溃风险。同时明确当前限制:表函数无法打包为 DuckDB 扩展,只能在 Java 客户端内使用;bind/init 对象生命周期需手动管理;STRUCT、LIST 等复合类型尚未支持。

文章来自 DuckDB 官方工程博客,提供了完整的表函数生命周期实现示例、与本地文件的交叉连接演示以及清晰的局限性说明,属于有深度且可直接迁移的工程实践。适合需要在 JVM 环境中将既有 Java SDK 或 JDBC 数据源接入 DuckDB 的工程师,可避开 C++ 扩展开发,降低维护风险。注意该 API 仍在演进,使用前应确认当前版本对生命周期管理和复合类型的支持。

工程实践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 仍属相对年轻的开源项目,并且部分性能结论来自官方或商业方的公开数据,迁移到大生产规模前应做独立验证。

技术文章SelectDB 技术分享

Apache Doris 4.1 全面增强 Iceberg:支持 UPDATE、MERGE INTO 与 Iceberg V3 在已有查询能力的基础上,Doris 进一步支持了 UPDATE、DELETE、MERGE INTO 等数据...

本文介绍 Apache Doris 4.1 对 Iceberg 的能力扩展,从仅支持查询扩大到 UPDATE、DELETE、MERGE INTO 等 DML、表结构管理与日常维护,并完整支持 Iceberg V3。文章重点解析 Deletion Vector 机制:V3 用位图记录失效行并写入 Puffin 文件,使删除文件数量与数据文件同阶,文中测试显示文件数从336降至17、删除信息存储从98MiB降至3.8MiB、高删除比例查询时间降至约1/3。同时介绍 Row Lineage 提供的 _row_id 和 _last_updated_sequence_number 系统列,用于稳定行标识和增量变化识别,可配合 Time Travel 定位记录。作者也说明这些能力仅适用于 format-version=3 且需 Doris 4.1+,收益受数据规模和文件布局影响,Row Lineage 不等同审计系统。文章最后给出五分钟入门步骤并展望 Variant 读写和增量物化视图。

推荐收录,因为文章不是单纯的产品发布,而是提供了 Iceberg V3 关键机制(Deletion Vector、Row Lineage)的清晰解释、具体 SQL 示例和量化测试结果,并明确标注了版本、格式和场景边界。适合从事湖仓一体、Doris 或 Iceberg 数据管线的工程师理解如何在 OLAP 引擎中收敛查询、修改和维护,其关于减少删除文件开销和行级增量识别的思路具有可迁移价值。

技术文章SelectDB 技术分享

宽表元数据膨胀怎么解?Doris Segment V3 对比 Parquet、Lance 要让查询真正只为目标列付出元数据成本,思路无非有三种:让 Footer 更容易定位,把重型列元数据...

文章围绕宽表场景下 Footer 元数据膨胀问题展开,对比 Parquet、Lance 与 Doris Segment V3 的解决思路。作者首先指出列式存储中 Footer 会随列数和 Row Group 增长,在数千列、复杂 JSON/Variant 子列时可达数 MB 甚至数十 MB,拖慢查询启动与元数据解析。随后分析三种格式的约束:Parquet 受生态兼容限制,通过 FlatBuffer 随机访问、裁剪冗余和兼容扩展降低开销;Lance 从文件结构重设计,将列元数据独立存储并放弃传统 Row Group;Doris 则在保留 OLAP 能力前提下,将每列 ColumnMetaPB 外置到独立 Column Meta Region(CMR),并在 Footer 中仅保留轻量目录,同时为 Variant 增加路径索引。性能测试显示极端宽表下 Segment 打开时间从 65 秒降至 4 秒,内存从 60 GB 降至不足 1 GB。适用边界是数千列宽表、复杂 Variant 和大量 Segment 场景,窄表收益有限。

推荐收录,因为文章对列式存储元数据膨胀问题提供了清晰的问题拆解和三种主流格式的取舍对比,并详细说明了 Doris Segment V3 的 CMR 外置、Variant 路径索引以及性能验证数据。适合数据库内核、存储引擎、数据仓库以及对宽表/半结构化数据查询优化感兴趣的工程师阅读。可迁移价值在于理解文件格式设计中的兼容性、功能完整性与查询性能之间的权衡;主要风险是内容带有 Apache Doris 厂商视角,但对 Parquet 和 Lance 的分析仍较客观。

技术文章SelectDB 技术分享

Apache Doris Python UDF:让 SQL 直接调用 Python 生态,支撑 Agent 时代复杂业务逻辑 Doris Python UDF 提供的不只是一个函数扩展机制,而是一条连接 Doris 高...

文章系统介绍 Apache Doris 的 Python UDF 功能,旨在让 SQL 直接调用 Python 生态以应对 AI 和实时分析中日益复杂的业务逻辑。核心方法是通过 Arrow RecordBatch 批量传输数据到独立 Python Server 执行,并支持 Pandas Series 向量化计算,减少跨语言和跨进程开销。Doris Python UDF 完整支持标量 UDF、UDAF 和 UDTF,提供内联与 ZIP 模块化加载方式,并内置进程隔离、复用和自愈机制以保证生产环境稳定性。文中给出支付风险分级和金额分桶等示例,展示在数据不离开分析链路的情况下完成规则判断、特征加工和模型打分。该能力已在 SelectDB 商业化产品中提供,适合需要将 Python 逻辑嵌入实时分析查询的场景,但部署前需在所有 BE 节点配置 Python 环境并安装 pandas/pyarrow。

本文对 Doris Python UDF 的设计机制、使用方式和生产化保障做了完整阐述,包含 Arrow 批量执行、向量化优化和故障恢复等关键细节,而非泛泛介绍。适合数据库内核开发者、数据工程师和需要在 SQL 引擎中集成 Python 生态的读者,可迁移到其他分析型数据库的扩展机制设计,帮助理解如何平衡灵活性、性能与可运维性。

工程实践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工具的思路。

工程实践Grab Tech

How AI is transforming analytics at Grab

文章系统阐述了Grab如何将AI代理深度嵌入数据分析工作流,以实现智能民主化和分析师角色进化。作者提出五级自主性阶梯(L2 AI辅助到L5端到端自主),定义了执行、知识、控制、审查和学习五大核心能力,并展示了Spartan、Scarlet、ContextIQ、BriX等实际系统的架构与效果。通过Slack中的自然语言分析、自愈数据管道、上下文生命周期管理和分析师自建工具门户,Grab将机械性工单占比从44%降至30%,周期时间缩短约33%,自助分析率大幅提升。文章强调自治不消除问责,人类始终负责问题框架、指标定义和业务决策。该实践适用于具备可认证指标和持续上下文投入的大型数据工程环境,但对团队协作和执行力的要求较高,非轻量级方案。

推荐收录。本文不是简单工具介绍,而是一份完整的工程案例,包含明确的自主性分级、核心能力拆解和可度量的业务影响,展示了从实验到规模化落地的真实路径。对关注数据工程智能化、分析师角色转型或AI工程化的读者极具参考价值,所提出的阶梯框架和上下文治理模式可迁移至其他数据分析密集型组织。

工程实践Netflix TechBlog

Modeling Device Capabilities for Analytics

Netflix 面临设备多样性带来的功能支持挑战,为此构建了设备能力数据模型。核心方法包括使用累计表高效存储每台设备的最新能力状态(如屏幕分辨率、视频编解码器支持等),以及构建直方图记录 28 天内活跃设备数并按能力维度分布,用于分析功能覆盖率(如仅 20% 设备支持 UHD)。基于这些数据集,团队开发了分析产品,为 4K、空间音频、云游戏等特性在特定设备上的启用提供数据驱动决策,以平衡性能与可靠性。该模型适用于大规模流媒体服务下的设备洞察,但未深入底层存储或查询优化细节。

本文展示了 Netflix 从设备数据建模到聚合分析的完整工程实践,提供了可复用的数据结构设计和分布分析方法,对需要处理异构设备、评估功能渗透或进行数据驱动决策的工程师有直接参考价值,适合数据分析、平台工程或流媒体团队迁移应用。

工程实践Grab Tech

Crowdsourced taxonomy verification: A feedback-driven framework for refining knowledge graph relationships via online search interactions

文章提出了一种基于用户反馈的知识图谱关系验证框架,用于在快速变化的领域(如外卖菜单)中检测和消除自动化构建所产生的错误关系。核心方法是将图谱边分为已验证和候选两类,通过搜索界面以探索与利用策略注入候选边,并采集点击、购买等加权交互信号,计算置信度分数来自动推广或剪枝边。该闭环系统无需人工干预,利用众包隐式反馈大规模纠正AI幻觉,并在食品配送场景中验证了其有效性。适用边界包括依赖充足用户流量的动态目录搜索,且需要精细控制注入以避免影响体验。

收录理由:文章详细描述了一个将搜索界面作为验证环境的工程方案,包含假设生成、候选注入、信号聚合和图更新等完整模块设计,并通过加权交互信号和置信度阈值实现自动图结构演化。对负责搜索系统、知识图谱构建或数据工程团队具有直接参考价值,其探索-利用设计和无人工干预的规模化验证思路具备可迁移性。

工程实践知乎 - 千问云

从超级个体到超级组织:1688 数据中心 Multi-Agent 研发小队实录

文章分享了1688数据中心在数据研发领域构建Multi-Agent系统的完整实践。核心通过知识工程KST三层架构(领域知识、行为规范、工作流配置)解决语义资产沉淀与Agent行为可预期性问题,并借助Harness Engineering为NL2SQL流水线增加工程约束,配合Loop Engineering实现全自动冒烟测评驱动的知识回流与飞轮迭代。在宙斯AperCoop平台之上,通过可fork的研发小队市场模式降低Multi-Agent冷启动成本,使个体经验沉淀为组织能力。文中展示了实际需求交付案例、安全网设计及度量数据,也坦诚讨论了知识冷启动最后一公里、AI能力悬崖等未解挑战。该实践虽聚焦数据研发,但其知识分治、约束编码、闭环自治的方法论对AI工程化、Agent协作等领域具有可迁移的长期参考价值。

本文并非泛泛介绍Agent概念,而是提供了从超级个体到超级组织的工程化落地实录,详细拆解了知识工程分治、Harness约束编码、Loop闭环测评等可复用方案,并附有真实数据与反思,对正在探索Multi-Agent生产化、数据平台智能化或AI工程化的团队极具启发性。其KST体系与Harness分离的设计原则,以及通过平台化实现经验回流的思路,可直接迁移至其他领域的AI协作系统建设。

工程实践Spotify Engineering

Indexing the Data Lake for Online Point Queries

文章介绍 Spotify 提出的 Random Access Parquet(RAP)方案,让数据湖中的 Parquet 文件直接支持在线点查询,服务个性化功能与 AI Agent 的上下文检索。作者指出瓶颈不在存储层,而在 Trino、BigQuery 等分布式 SQL 引擎的调度与查询规划开销,以及文件内查找所需的链式依赖读取。RAP 通过外部索引把 key 直接映射到文件与行号,再发起精确的 ranged read,索引实现为可追加的 multimap。文章进一步给出面向预写文件的优化(按 key 排序、co-grouping、粗粒度分区、每 key 一页、ZSTD frame reset、存储对齐、blob/Variant、列交织、覆盖索引)及其对分析负载的取舍。结论是同一份 Parquet 文件可同时服务分析与交互式访问,避免重复存储,但部分优化会牺牲列裁剪等分析能力。

推荐收录:文章来自 Spotify 一线实践,清晰定义了数据湖点查询这一真实工程问题,并给出索引结构、文件布局优化与逐项取舍,证据具体。适合数据平台、存储与后端工程师,尤其在构建低延迟检索或为 AI Agent 供给上下文时,其“一份数据双访问模式”思路与 Parquet 改造技巧可直接迁移。

科研议题知乎 - 微软亚洲研究院

大模型时代,数据不仅要选得好,还要排得好

本文解读了 ACL 2026 论文《Demystifying Data Organization for Enhanced LLM Training》,系统探讨大模型训练中数据顺序对模型能力的影响。作者将问题拆解为数据评分、数据选择与数据组织,并复用已有样本分数,提出边界锐化、循环调度、课程连续性、局部多样性四条可迁移法则。在此基础上设计了 STR 和 SAW 两种排序策略,在预训练(FineWeb-Edu)和 SFT(数学推理、代码生成)任务上,相比随机排序取得一致的准确率提升和更低的测试损失。文章还讨论了方法的适用前提:依赖于可靠的样本分数,不改变数据内容和模型规模,仅优化训练顺序。研究为大模型数据效率优化提供了新的维度,强调数据‘何时出现’与‘如何出现’的重要性。

推荐收录,因为文章将数据组织从零星经验提炼为系统化的四条法则,并给出可复用的 STR 和 SAW 排序策略,实验覆盖多规模模型和多种任务,证据充分。适合从事大模型训练、数据效率方向的研究者和工程师,其指南可直接迁移到现有数据筛选流程中,且代码开源,可操作性强。

工程实践ClickHouse Engineering

Replacing the HDB: ClickHouse for historical ticker data

文章以 Binance 公开行情归档为数据源,演示如何用 ClickHouse 承载历史 tick 数据:实时层之外的历史层是低风险试验场,适合引入新数据库。核心手段是列式存储配合针对性编码——LowCardinality 处理低基数 symbol,DoubleDelta 压缩单调递增的 ts 与 trade_id,ZSTD/LZ4 利用重复字节模式。作者给出完整建表、写入与查询示例,覆盖 VWAP、OHLC K 线、ASOF JOIN 计算滑点等交易台常用分析,并用量表统计验证:一个月 191 GiB 原始 CSV 压缩至约 10 GiB,十个月 162 亿行仅 76 GiB,Cloud 成本约每月 1.88 美元,且查询延迟不随数据量增长,因为主键 (symbol, ts) 稀疏索引将扫描裁剪到万分之一。边界在于不按 symbol 与时间过滤的查询仍需全表扫描。

收录理由:文中不仅有可直接复用的建表结构、编码选择与 VWAP/OHLC/ASOF JOIN 查询,还给出压缩比、成本与查询计划等可验证证据,属于有取舍、有量化的真实工程案例。适合从事时序/行情数据、OLAP 选型与压缩调优的读者迁移到类似高写入、按维度过滤的分析型负载。风险在于内容为厂商博客,读者需注意其面向 ClickHouse 的视角,未与其他方案横向对比。

工程实践Grab Tech

Scaling Grab's Data Lake: Our journey to Apache Iceberg adoption

文章详细介绍了 Grab 从 Hive Parquet 向 Apache Iceberg 迁移数据湖的完整工程实践。首先分析了原始架构在目录延迟、小文件碎片、运维负担和信息一致性上的瓶颈,然后说明了选择 Iceberg 的决策依据。迁移采用按表优先级逐步推进的策略,在导航数据集上通过 Z-ordering 获得约 10 倍查询性能提升,并在运营表上节省了 95% 的 S3 API 成本。为应对 Iceberg、Delta、Hudi 等多格式共存的开发体验问题,团队自研并开源了 UnifiedSparkCatalog,透明路由不同表格式操作。文中还分享了 Hive 锁竞争、时间戳兼容性、存储层级成本等实际坑位和解决方案。案例适合大型数据平台的可扩展存储架构改造,迁移策略和工具设计具有较高的可迁移性。

本文提供了从中型数据湖到现代表格式转型的完整路线图,包含明确的性能与成本量化证据、自研工具的架构取舍和开源发布,以及生产环境踩坑经验。适合数据平台工程师和架构师参考,尤其对计划从 Hive 迁往 Iceberg、需要多格式兼容的团队有直接借鉴价值。

工具笔记Simon Willison

simonw/browser-compat-db

这篇文章记录了作者把 Mozilla 的 mdn/browser-compat-data 兼容性数据仓库转换成一个约 66MB 的 SQLite 数据库的实践。作者借助 Claude Code 和 sqlite-utils 生成转换脚本,再用 Codex Desktop 编写 GitHub Actions 工作流,在构建后把数据库强制推送到一个独立的 orphan 分支。这样做的目的不是做可写数据库,而是利用普通 GitHub 仓库文件可通过 CDN 访问且带开放 CORS 的特性,方便浏览器端直接下载和在 Datasette Lite 中在线探索。文章的核心价值在于展示了“结构化数据仓库 + SQLite + 静态托管 + 前端可直接查询”的发布链路。它更适合静态、可再生成的数据集分发场景,不适合高频写入或需要事务服务化的系统。

文章给出了可直接复用的证据:SQLite 生成脚本、GitHub Actions 自动构建、orphan 分支静态发布,以及利用 GitHub CDN 的开放 CORS 让浏览器端直接访问。对需要发布可下载数据集、做前端只读查询或搭建轻量数据浏览器的工程实践很有参考价值。

工程实践Netflix TechBlog

Data Projects: Managing Data Assets at Netflix Scale

这篇文章介绍了 Netflix 如何在超大规模数据平台中用“Data Projects”重构数据资产管理:把表、工作流、密钥等相关资产聚合到项目这一更高层级,并用项目级的合成、可持续身份替代绑定个人的权限与执行身份。文章重点解释了它如何缓解组织调整导致的权限维护灾难、如何避免工作流因人员流动而失效,以及“gravity”机制如何让新资产自动归属到项目中,从而降低后续治理成本。结论是,在拥有海量表和成千上万批处理任务的环境里,管理单元必须从“单个资产/单个人”上移到“项目”,并可进一步扩展到成本、健康度和审计等平台能力。

推荐收录,因为它不是单纯的产品介绍,而是基于 Netflix 真实规模约束提出的数据平台治理架构:权限、身份、工作流和资产归属如何统一建模,思路具有很强的迁移价值。对做数据平台、权限系统、工作流编排或企业内部平台建设的读者而言,这篇文章能直接启发“管理边界应该放在哪一层”的设计判断。

工程实践Netflix TechBlog

The Evolution of Cassandra Data Movement at Netflix

这篇文章复盘了 Netflix 将 Cassandra 数据搬迁从旧的 Casspactor 架构演进到新的分层数据移动引擎的过程,核心目标是提升可靠性、可扩展性和成本效率。文章重点解释了新方案如何直接从 S3 中的备份元数据读取单一事实来源、在 Spark DataFrame 层处理数据、通过 Connector Factory 支持多种数据抽象,以及如何解决大分区、元数据脆弱、间接表膨胀和时间回溯等问题。文中还系统总结了迁移方法论:通过 shadow 验证、可观测性建设和 Decider pattern 实现对线上用户零影响切换,适合作为大型数据平台重构与平滑迁移的参考案例。

推荐收录,因为它不是简单的系统替换公告,而是完整展示了一个高风险数据平台迁移如何从架构、验证、观测和回滚机制四个层面设计。对做数据基础设施、平台工程和大规模迁移的读者来说,文中的分层架构、单一事实来源、shadow 对比和安全切换方法都具有很强的可迁移价值。

工程实践Lyft Engineering

Metric Semantic Layer: How Lyft Governs and Scales Key Data Definitions

这篇文章介绍 Lyft 如何构建内部 Metric Semantic Layer(MSL)来统一关键指标定义,核心目标是解决不同团队对同一指标口径不一致、定义分散和变更难以治理的问题。文章给出了较完整的实现思路:用 YAML 存储指标元数据、用 Jinja 模板生成 SQL、通过 Python 包和 API 对外提供访问能力,并结合“Business Owner / Operational Owner”的双责任模型来管理指标生命周期。文中还进一步说明了如何接入数据目录、自助 BI 工具以及 MCP/AI Agents,使标准化指标定义既能支持分析与运营,也能作为 AI 工具的可靠知识源。

推荐收录,因为它不是泛泛而谈“数据治理”,而是把指标定义、版本管理、权限责任、访问接口和下游集成串成了一套可落地的工程方案。对做数仓、指标平台、BI 基础设施或 AI 数据工具的读者来说,这篇文章提供了很强的可迁移经验,尤其适合理解“单一事实来源”如何在组织规模化时真正落地。

工程实践Spotify Engineering

Encoding Your Domain Expert: The Context Layer Behind Spotify's Data Assistant

文章介绍 Spotify 内部 AI 数据助手 Vedder 背后的上下文层设计。面对 7 万多个数据集和海量数据,作者指出仅把 schema 塞进 LLM 并不可行:上下文窗口有限,且 schema 无法传达业务语义。为此他们提出“集群”模型,由领域专家维护三类上下文——带抽样与分区信息的数据集、经审核的问题-SQL 样例对、补充业务文档,并以 ReAct 循环生成可追溯的查询与来源。实验证明了人工审核的必要性:从查询历史自动生成的样例对仅 12.5% 被专家接受,其余多为探索、调试或错误模式。系统还通过集群健康分与反馈闭环持续维护上下文。该架构不依赖 Spotify 特有设施,但前提是已有成熟的数据目录与治理。

推荐收录。文章提供了完整的工程分析与可量化证据:自动生成样例对仅 12.5% 被专家采纳、集群健康分指标体系和反馈闭环,清楚说明在超大规模数据仓库上为何必须由领域专家审核上下文,而非依赖原始查询历史。适合构建 LLM 数据分析助手、上下文/RAG 层或数据平台工程化的读者参考。

工程实践Cloudflare Blog

How we built Cloudflare's data platform and an AI agent on top of it

这篇文章系统介绍了 Cloudflare 如何搭建统一数据平台 Town Lake,以及其上的 AI 数据代理 Skipper。核心方案是以 Trino + Iceberg + R2 构成湖仓式数据底座,再叠加 DataHub 元数据、Lifeguard 权限控制、Skimmer PII 扫描、Transformer ELT 和 Ingestion 管道,实现默认关闭、可审计、按会话授权的数据访问。文章进一步说明 Skipper 如何利用多层上下文、代码模式 MCP 接口和运行时验证,把自然语言问题转成可追溯的 SQL 查询与图表,并总结了工具设计与提示词工程的经验教训。

推荐收录,因为它不是单纯的产品宣传,而是完整讲清了超大规模企业数据平台从架构、治理到 AI 查询代理的实现方式与权衡。对做数据平台、内部分析系统、权限治理或企业级 AI Agent 的读者,都有较强的可迁移参考价值。

工程实践Yelp Engineering

How Partition Access Visualizations Reduced our Data Lake S3 Cost by 33%

这篇文章介绍了 Yelp 如何通过“分区访问可视化”来分析数据湖中表分区的真实使用模式:把分区键取值与访问事件时间进行对齐,从而识别出临时查询、每日批处理和周期性回填等不同访问签名。基于这种可观测性,团队进一步推进了大规模表迁移到 Apache Iceberg,并发现了存储和访问层面的优化机会,最终将 S3 成本降低了 33%。文章的核心价值在于把数据资产的“被谁、何时、如何使用”变成可视化、可操作的工程信号,但其效果依赖于较完整的访问日志和分区化数据湖场景。

推荐收录,因为它不是泛泛讲成本优化,而是给出了一种可迁移的数据使用分析方法:通过分区访问模式可视化来指导表格式迁移、生命周期管理和存储优化。对做数据平台、湖仓治理和成本治理的工程师来说,这篇文章能直接启发指标设计、治理流程和架构决策。

工程实践知乎 - SmartCode 得物技术

BP Claw 破解 AI 编码输入难题 ——FlinkSpec 需求智能化实践|得物技术

文章介绍了得物在实时数仓场景下构建的 BP Claw:一个位于 FlinkSpec 上游的“AI 数据 BP”中间层,用来把产品经理提交的非标 PRD 自动转成 AI Coding 可消费的标准化需求文档。作者重点讲了它如何通过知识库语义召回、需求转化、PRD 质量评分、自动拉群和多 Skill 编排,把“需求口径不清”这个源头问题前置解决,从而降低后续 FlinkSQL 生成、评审和验收阶段的返工。

推荐收录,因为它不是泛泛讲“用 AI 提效”,而是围绕真实的实时数仓开发链路,给出了从需求输入、语义对齐到生成与校验的完整工程方案。文章对 PRD 规范化、幻觉控制、分段生成、质量评分和工作流融合的处理方式具有较强的可迁移价值,适合做 AI 工程化落地参考。

工程实践知乎 - 携程技术

9亿数据归因分析跑进15秒:携程智能归因系统如何用 Ray+DuckDB 破解算力危机?

这篇文章复盘了携程智能归因系统在9亿+数据规模下的性能重构:原先依赖 ClickHouse 的集中式重计算导致查询超过40秒并影响集群稳定性,随后通过将数据提前导出为 Parquet、放到 S3/Ceph 中,并用 Ray 负责任务调度、DuckDB 负责单节点高性能执行,把归因分析压到15秒以内。文章不仅解释了 Ray + DuckDB 的分工、任务拆分、分区剪枝、Actor 共享本地磁盘等实现细节,还展示了在 K8s/KubeRay 上的弹性伸缩、可观测性和 CI/CD 集成方式,适合大规模分析计算与资源隔离场景参考。

推荐收录,因为它不是单纯的技术宣传,而是一个有明确前后对比、瓶颈定位和架构取舍的真实工程案例。对于做大规模分析、工作负载隔离、分布式任务拆分和嵌入式分析引擎选型的团队,这篇文章具有较强的可迁移参考价值。

工程实践知乎 - 携程技术

告别“黑盒评审”:我们让LLM为数据仓库模型打了分,效率提升70%+

文章围绕数据仓库模型评审效率低、标准难统一的问题,提出用LLM结合元数据、血缘、需求文档和DQC信息构建可量化的模型评价体系。作者把评审拆成合理度、规范度、重复度、准确度四个维度,并通过MCP+Cursor+内部知识库的工作流实现人机协同评审,据称将新建表评审效率提升了70%+。文章的核心价值在于把“黑盒式人工评审”转化为可复用的规则框架和工具链,适合数据平台、数仓治理和AI工程化场景参考。

推荐收录,因为它不是单纯宣传LLM,而是把数仓评审拆解为可执行的特征提取、规则定义和人机协同流程,具有明确的工程方法论价值。对于数据平台、数仓治理和内部开发效率优化,这套“知识库 + 规则引擎 + LLM”的思路可迁移性很强。

工程实践Lyft Engineering

How We Built a Smarter Pickup Experience for Gated Communities

这篇文章复盘了 Lyft 如何改善封闭社区内的叫车接送体验。作者先指出两个核心问题:默认选点会把乘客引到围栏内,而上车说明只能临时聊天补充,导致司机找不到入口、等待和取消率上升。为此,团队把门禁社区编码进地图数据,生成门区边界,并在乘客端提供“门内/门外”两类更贴近真实行为的上车点建议。随后又在路由中加入经过大门的中间停靠点,并在司机接近门口时及时展示简洁的门禁说明,同时加入可删除、不可跨行程保留等隐私保护。上线实验显示该流程未显著增加下单流失,且降低了取消、缩短了等待,说明把现实约束显式纳入地图、推荐、路由和交互链路是可复用的工程方法;但当前覆盖仍依赖地图数据完整性,且多入口社区的最优选门仍有改进空间。

收录价值在于它给出了一个完整的工程闭环:从地图建模、路径改造到交互时机和隐私控制,并用实验和指标验证效果。适合做地图、出行、位置服务或复杂前端/后端协同系统的参考,但也要注意其方案强依赖本地地理数据质量与覆盖。

工程实践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 编码代理工程化、平台工程或数据迁移的读者,其上下文工程、可验证性依赖和标准化前置条件等结论可直接迁移。

工程实践Lyft Engineering

Beyond A/B Testing: Using Surrogacy and Region-Splits to Measure Long-Term Effects in Marketplaces

本文讨论 Lyft 在双边市场中如何评估价格、补贴等决策对长期供需的影响,而不是只看短期 A/B 结果。作者把“市场中介效应”拆成两步:先用残差化回归估计政策变化如何改变等待时长、surge、取消率等负面体验,再用 AIPW 等双重稳健方法估计这些体验对未来乘车量、留存和司机时长的影响。为验证这条因果链,文章分别使用 switch-back、user-split 和 region-split 实验做校准,并提出前向选择算法来改进区域分组的预实验拟合与统计功效。最后将中介效应与直接长期效应合并,用于预算分配和情景规划。其主要边界在于“长期中介效应完全通过负面体验传递”的假设,以及 region-split 天然存在拟合差、功效低的问题。

收录理由明确:文章给出了从观测因果推断到多种实验验证的完整链路,直接面向市场供需、补贴定价和长期效应评估。适合做 marketplace、增长实验和因果分析团队的参考,但读者也应注意其强假设与区域实验功效不足的风险。

工程实践Lyft Engineering

Lyft’s Feature Store: Architecture, Optimization, and Evolution

这篇文章系统复盘了 Lyft Feature Store 的架构、演进和优化实践,重点解释了如何用统一的特征平台支撑大规模 ML 训练与在线推理。文章把系统拆成批处理、在线服务和流式三条路径:批特征由 Spark SQL+JSON 配置生成 Airflow DAG,在线侧以 DynamoDB 为持久存储、ValKey 作写穿缓存,并为 embedding 引入 OpenSearch。作者进一步说明了特征治理机制,包括版本、血缘、元数据、数据质量检查、Amundsen 可发现性,以及 Kyte 本地开发和 SDK 提升迭代效率。平台演进部分展示了从 Flyte 迁移到 Astronomer、收缩少数边缘能力、增加 staging、数据契约和实时特征抽象的取舍。性能优化则聚焦于缓存现代化、payload 精简、pod 规格调整、重试/超时策略和 TTL 管理,最终把读路径 P95 降低约三分之一。文章的边界在于大量方案高度依赖 Lyft 内部工具链与 AWS 生态,但整体方法论具有较强可迁移性。

文章给出了特征平台从架构、治理到性能优化的完整工程证据,不是泛泛介绍概念,而是包含具体存储选型、缓存策略、DAG 生成和迁移取舍。适合数据平台、ML 平台和基础设施团队参考,尤其可迁移的是“统一接口+分层存储+可观测治理+围绕 P95 做瘦身”的方法。

工程实践Yelp Engineering

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

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

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

工程实践Datadog Engineering

How we built the Datadog heatmap to visualize distributions over time at arbitrary scale

这篇文章讲的是 Datadog 如何把“随时间变化的分布热力图”做成可在任意规模数据上工作的可视化。作者先指出传统 heatmap 在高基数、长时间窗和细粒度分桶下会遭遇内存、计算和渲染压力,且容易丢失分布形状。为此,他们引入 DDSketch,把原本需要精确直方图的聚合改造成带相对误差保证的近似分布表示,从而在保持尾部分布与整体趋势可读性的同时显著降低存储和计算成本。文章还讨论了桶设计、时间维度聚合和前端展示之间的配合方式。其适用边界也很明确:它更适合观测分析和趋势探索,不适合要求绝对精确数值的场景。

文中直接给出了用 DDSketch 改造 heatmap 的工程方案、问题来源和规模化收益,属于可复用的观测系统设计案例。适合做可视化、指标聚合或高基数分布分析的工程师参考,尤其能迁移到需要在精度与成本之间权衡的场景。

科研议题Stanford Hazy Research

In The ChatGPT Era, Your Data is More Valuable Than Ever

这篇文章讨论 ChatGPT 时代的 AI 竞争重心如何从“模型”转向“数据”,核心判断是通用基础模型会逐步标准化,而真正稀缺的资产将变成企业与用户交互过程中沉淀的数字痕迹。作者认为,随着开源模型和可复用训练配方普及,训练同等级模型的门槛下降,下一阶段的壁垒不在更大参数量,而在如何选择、清洗、验证并低成本利用私有数据。文章进一步提出“GPT-You”和“EnterpriseGPTs”的趋势,预测 copilots 会渗透邮件、设计、数据管道、财务等流程,并推动“先验证、再构建”的软件交付方式。结尾强调,幻觉、缺失数据和结构化数据高精度建模仍是难点,因此数据质量、验证工具和数据炼制能力会重新变得关键。整体判断具有较强方向性,但明显带有趋势推演和观点表达色彩,部分结论仍依赖作者对行业演化的乐观预期。

文章直接围绕基础模型开源化、企业数据资产价值和数据炼制工具展开,给出了可验证的行业判断,而不是泛泛谈论大模型热点。适合关注 AI 平台、MLOps、企业智能化和数据战略的读者参考,但需要注意其结论偏趋势研判,更多是方向启发而非实证研究。

科研思考Stanford Hazy Research

First-Mile vs. Last-Mile AI Systems in the Era of Foundation Models

文章提出“基础模型是 first-mile,传统机器学习是 last-mile”的框架,用来解释两类 AI 系统在目标上的差异:前者擅长人机交互、探索、改写和搜索式任务,后者更适合需要严格正确性、稳定质量和可预测成本的生产流水线。作者强调,当前基础模型在“通用性”上进步明显,但在细粒度指标、可靠性和误差收敛上仍远不如专用模型,尤其从 85% 提升到 99% 这种跨数量级改进并不容易。文章进一步类比搜索与数据库长期共存的历史,说明基础模型未必会替代传统系统,而更可能与之分工协作。作者还指出,推动基础模型进步的关键仍是数据:RLHF、指令微调、弱监督和数据集工程本质上都是在用数据“编程”。文末给出若干研究方向,包括基础模型+弱监督、长上下文、推理效率、数据分析工作流与 FMOps,但也承认这些方向的边界、成本和统一路径仍未被证明。

这篇文章直接给出“first-mile/last-mile”的系统分工框架,并用搜索/数据库类比、误差数量级和数据中心化实践支撑论点,适合做 AI 系统设计和研究方向判断的长期参考。它的价值不在具体实现,而在帮助读者把基础模型、弱监督、数据工程与可靠性要求放到同一张图里理解。

工程实践Stanford Hazy Research

Meerkat and the Path to Foundation Models as a Reliable Software Abstraction

这篇文章提出一个核心判断:随着基础模型进入日常工作流,技术团队需要的不只是模型 API,而是能把非结构化数据、模型输出和人工反馈放在同一界面里的交互式数据系统。作者指出,传统 DataFrame 擅长结构化数据,但面对图片、PDF、网页、音频等对象时,单靠代码既难以验证模型结果,也难以高效标注和迭代。为此他们设计了 Meerkat:一种可存储复杂对象及其向量表示的异构 DataFrame,并通过 Python 内嵌 GUI 让搜索、填充、错误分析等 FM 操作可视化、可交互。文章用艺术图像分析、PDF 信息抽取和图像分类误差分析三个 demo 说明其工作流优势,但整体仍偏系统原型展示,缺少大规模基准和严谨定量评估。

收录价值在于它把“基础模型如何作为软件抽象使用”具体落到数据结构、交互界面和人机协同反馈机制上,而不是停留在概念讨论。适合做 AI 工程、数据工具和交互式系统设计的参考,但也要注意它更像原型与理念展示,缺少完整性能与可扩展性证据。

科研议题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 的入门参考,但也要注意其对模型规模和提示格式较敏感,落地时仍需评估成本与稳定性。

科研思考Stanford Hazy Research

How Foundation Models Changed our Work

这篇文章从斯坦福 Hazy Research 团队的视角,回顾 foundation models 如何改变他们的研究重心,尤其是围绕数据与系统的工作方式。作者将相关工作分成两类:一类是理解和改进基础模型本身,如 FlashAttention、S4、长序列建模和跨地域的去中心化训练;另一类是把 foundation models 作为数据工具,用于弱监督、数据探索、数据清洗与集成,以及隐私敏感场景中的新型学习方式。文章的核心判断是,FM 不只是更大的模型,而是在重新定义“如何编程数据”和“如何做研究”。不过它更像研究进展综述与方向宣言,缺少统一实验框架和系统性比较,适合把握研究趋势,不适合作为单点结论依据。

文章直接给出了 FlashAttention、S4、弱监督和数据清洗等具体研究线索,说明 foundation models 正在同时重塑模型、系统与数据工作流。适合做研究选题、方向梳理和跨领域方法迁移的读者,但需注意它是团队视角的阶段性总结,证据更偏方向性而非严格综述。

科研议题Stanford Hazy Research

Foundation Models are Entering their Data-Centric Era

这篇文章讨论基础模型进入“数据中心时代”的判断:随着模型架构和工程逐步商品化,真正拉开差距的会越来越是数据的描述、组织和利用方式。作者先回顾“garbage in, garbage out”和“参数越多越易过拟合”这两条旧经验,指出在基础模型和大模型时代,它们都不再足够解释实际效果。文章以 Snorkel 的弱监督和数据中心 AI 为例,强调知识注入并不只发生在训练前的数据清洗,也可以通过噪声数据建模、test-time prompt 设计、检索与上下文构造来完成。作者进一步提出,探索阶段应通过更好的数据策划与测试时计算让通用模型更可用,落地阶段则应把基础模型输出蒸馏成面向私有数据和特定任务的专用模型。文中判断带有明显研究观点和推测性,未给出严格理论证明,但对理解大模型应用开发的边界、数据价值与迁移路径很有参考意义。

文章直接以 Snorkel、弱监督、Chinchilla 和 AMA prompting 等案例说明:当模型能力趋于可得时,数据策划和 test-time 数据组织才是主要差异来源。适合关注大模型研究趋势、数据中心 AI 和基础模型落地的读者;需要注意的是,它更多是研究视角的判断而非严格实验论文。