applied_ai_automation

ETL先提取后加载;ELT先加载原始数据以支撑AI规模化

What problem does a data pipeline solve before AI can work at all?

ETL先提取后加载;ELT先加载原始数据以支撑AI规模化

Photo: Poppy Thomas-Hill / Wikimedia Commons / CC BY 2.0

数据管道在AI能够工作之前,解决了什么问题?

它填补了原始数据与可用数据之间的鸿沟。模型不会从装满噪声的仓库中学习。它们从干净、经过塑造且足够可靠以值得信任的数据中学习。

对于EuroOp LLC来说,这是人们常常忽略的AI工作部分。人们关注的是模型,而管道承担了繁重的工作。它从数据库、API、文件、日志和传感器中获取数据,然后将这一团糟转化为软件可用的形式。这就是为什么管道处于应用AI的中心,而不是边缘。

一种有用的思考方式很简单。管道是数据在支持预测、报告或自动化行动之前所经过的路径。如果这条路径断裂、缓慢或不一致,上面的系统就会开始以静默的方式失效。错误的标签混入其中。重复的行堆积起来。新的信号到达太晚。模型可能仍在运行,但业务结果会变弱。

管道之所以重要,原因是基本的。AI系统需要体量、结构和一致性。原始数据很少以这种状态到达。它通常以不均匀的格式出现,带有缺失字段、额外噪声和冲突值。管道使这些数据变得可用,而无需让人工逐行手动清理。

这就是ETL和ELT发挥作用的地方。

ETL代表提取(Extract)、转换(Transform)、加载(Load)。工作始于从源中提取数据。然后对数据进行清理、重塑和检查。只有在那之后,它才会被加载到目标系统中,例如数据仓库或数据库。这种风格非常适合较旧的商业智能设置,特别是在团队希望在数据落地目的地之前拥有严格控制权的情况下。

ELT使用不同的顺序。它提取数据,首先以原始形式加载,然后在存储后进行转换。这在可以容纳大量原始数据集并在稍后使用更多计算能力处理它们的云系统中效果很好。它还保留了原始数据的可用性。当不同团队希望以不同方式查看同一来源时,这很重要。

区别不在于一个好一个坏。而在于工作发生在哪里。

ETL适合那种希望在下游任何人看到数据之前就对其进行塑造的工作流。ELT适合那种在摄取方面追求速度并在稍后追求灵活性的工作流。在传统环境中,ETL感觉更自然,因为数据量通常较小,流程更为固定。在云原生环境中,由于原始数据保留下来供新用例使用,ELT通常更容易扩展。

一个小例子可以说明这一点。

想象一家收集客户支持日志的公司。日志来自票务系统、聊天工具和呼叫中心导出。在ETL中,团队会首先提取这些记录,清理时间戳,删除重复项,标准化字段,并在加载到仓库之前应用业务规则。在ELT中,团队会首先将原始日志存入存储,然后在稍后为分析、搜索或模型训练进行转换。

业务影响是不同的。ETL在加载前提供更可控的路径。ELT为以多种方式重用相同的原始记录提供了更多空间。对于AI工作,这种重用通常是重点。一个团队可能需要一个报表表。另一个团队可能需要模型的特征。第三个团队可能需要原始记录用于后续实验。ELT让这扇门保持敞开。

这就是为什么管道与AI规模紧密相关。当数据从几个文件增长到数百万条记录时,手动清理不再现实。当数据实时移动时,仅基于批次的思维变得太慢。当模型依赖于文本、图像、音频或传感器流时,管道成为使数据集首先适合使用的部分。

同样的模式出现在几个AI工作中。

文本、图像和音频准备依赖于大规模预处理。实时分析依赖于能够足够快地摄取和检查从而产生影响的流。特征工程依赖于可重复的转换,为预测创建可用的输入。大型语言模型的知识库依赖于准确、结构化的数据流向训练和检索系统。在每种情况下,管道都是让AI层得以工作的静默系统。

工具反映了这种工作分工。像Talend、Informatica Power Center、Apache NiFi和Microsoft SSIS这样的ETL系统长期以来支持预加载转换。像dbt、Snowflake、BigQuery和Databricks这样的ELT系统是为云优先工作负载构建的,转换可以在数据落地后发生。像Apache Airflow、Prefect、Dagster和Luigi这样的编排工具帮助保持作业按顺序运行。像Kafka、Flink、Spark Streaming和AWS Kinesis这样的流式传输工具处理不能等待夜间批处理的数据。

只有当管道本身被视为架构时,该堆栈才有用。它不是一项辅助任务。它是保护模型质量、保持作业可重复并使在不从头重建一切的情况下实现增长成为可能的层。良好的管道还需要错误处理、清晰的日志、质量检查和可重用的模块化部件。没有这种纪律,数据流很快就会变得脆弱。

EuroOp LLC将此视为一条实用教训,而非口号。AI并非始于模型提示或训练运行。它始于数据在到达模型之前所经过的路径。ETL和ELT是构建该路径的两种方式,正确的选择取决于工作负载、系统设计和数据规模。

理解这一点的读者现在可以区分首先准备数据的管道和首先存储原始数据的管道。这是对如何评估AI系统的真正改变。它将注意力从单纯的模型转移到使模型可用的基础设施上。

这正是EuroOp Insights不断回归的模式:一个应用研发模式,一个来自EuroOp LLC产品背后管道的实用要点。

探讨该话题