Efficient Extract, Transform, Load (ETL) pipelines are essential for processing large-scale datasets in today's data-centric environments. Traditional ETL methods, relying on static data partitioning and sequential computation, often suffer from poor scalability, high resource consumption, and extended execution times. To address these limitations, this paper proposes an AI-enabled ETL optimization framework that integrates machine learning-based dynamic partitioning with parallel processing techniques using Python libraries such as Dask, PySpark, and multiprocessing. Experimental validation, conducted using the TPC-H benchmark dataset, demonstrates that the AI-driven ETL pipeline achieves up to a 40% reduction in execution time and a 30% improvement in resource utilization compared to the baseline of traditional static-partitioned and sequential ETL processes. These findings highlight the potential of AI-driven optimization to significantly enhance the scalability, efficiency, and performance of ETL workflows for large and complex data processing applications.

错误:搜索内容不能为空,请输入英文关键词
错误:关键词超出字数限制,请精简
高级检索

Optimizing ETL Pipeline Performance with AI-Driven Data Partitioning and Parallel Processing in Python

  • Teja Krishna Kota,
  • Samyukta Rongala

摘要

Efficient Extract, Transform, Load (ETL) pipelines are essential for processing large-scale datasets in today's data-centric environments. Traditional ETL methods, relying on static data partitioning and sequential computation, often suffer from poor scalability, high resource consumption, and extended execution times. To address these limitations, this paper proposes an AI-enabled ETL optimization framework that integrates machine learning-based dynamic partitioning with parallel processing techniques using Python libraries such as Dask, PySpark, and multiprocessing. Experimental validation, conducted using the TPC-H benchmark dataset, demonstrates that the AI-driven ETL pipeline achieves up to a 40% reduction in execution time and a 30% improvement in resource utilization compared to the baseline of traditional static-partitioned and sequential ETL processes. These findings highlight the potential of AI-driven optimization to significantly enhance the scalability, efficiency, and performance of ETL workflows for large and complex data processing applications.