10 个仓库
Defining data workflows as static graphs optimized before execution.
Explore 10 awesome GitHub repositories matching data & databases · Declarative Pipeline Construction. Refine with filters or upvote what's useful.
Pathway is a high-performance data processing framework designed for building unified batch and streaming pipelines. It functions as an orchestrator for complex data transformations, utilizing a differential dataflow engine to process updates incrementally. By treating static datasets and continuous event streams with identical logic, the platform ensures exactly-once processing semantics and consistent results across diverse data sources. The framework distinguishes itself through its specialized support for real-time artificial intelligence and retrieval-augmented generation. It features in
Defines complex data transformation workflows as static, optimized graphs before execution.
FFmpeg is a cross-platform multimedia framework designed for the recording, conversion, and streaming of audio and video content. It functions as a comprehensive toolkit that provides both a command-line utility for direct media manipulation and a collection of low-level libraries for integration into custom applications. At its core, the project utilizes a packet-based stream engine and a format-agnostic abstraction layer to handle diverse media standards, containers, and network protocols. The framework distinguishes itself through a modular, graph-based filter execution model that allows f
Constructs non-linear processing pipelines that support multiple inputs and outputs to perform advanced tasks like video overlaying or audio mixing.
This tool is a command-line processor designed for querying, updating, and transforming structured data files. It functions as a versatile engine for manipulating YAML, JSON, TOML, and XML documents, allowing users to perform complex operations directly from the terminal. By utilizing a path-based expression language, it enables precise navigation and modification of data structures within configuration files and infrastructure-as-code workflows. What distinguishes this tool is its ability to perform in-place document mutations while preserving original formatting, comments, and metadata. It
Chains multiple data operations through standard input and output streams to enable complex transformations via shell piping.
Taskflow is a C++ task-parallel framework designed to build high-performance parallel workflows and complex dependency graphs. It provides a programming model that organizes computational work into directed acyclic graphs, enabling developers to manage concurrency, resource scheduling, and task dependencies across multi-core CPUs and GPU accelerators. The framework distinguishes itself through its ability to orchestrate heterogeneous systems, allowing for the integration of hardware-accelerated kernels and memory operations into unified execution pipelines. It supports dynamic runtime subflow
Builds multi-stage data processing pipelines where stages execute either serially or in parallel to transform data.
Benthos is a stream processing engine and data integration pipeline used for routing, transforming, and connecting data streams between diverse sources and sinks. It functions as event routing middleware and a change data capture tool, streaming real-time database modifications as discrete events for downstream processing. The system utilizes a declarative pipeline configuration, where data flow and processing logic are defined in a single static file. It features a specialized domain-specific language for mapping, filtering, and enriching data payloads, allowing for complex transformations w
Defines data workflows as static graphs via a single configuration file that is optimized before execution.
node-fluent-ffmpeg 是一个 FFmpeg 的 Node.js 包装器,为执行媒体命令和处理文件提供了流畅的接口。它充当进程管理器,处理外部 FFmpeg 二进制文件的生命周期,通过 ffprobe 实现程序化媒体转码、视频缩略图生成和元数据提取。 该库通过一个将 JavaScript 方法调用转换为命令行参数的命令构建器脱颖而出。它具有用于跟踪已处理帧和吞吐量的事件驱动进度监控功能,以及将处理后的媒体数据直接路由到可写流以进行实时处理的能力。 该项目涵盖了广泛的媒体处理功能,包括用于音频和视频属性的编码配置、用于视觉和音频效果的复杂滤镜图定义,以及用于连接多个源的输入管理。它还包括用于探测媒体容器和流以检索技术元数据的工具。
Enables the construction of non-linear processing pipelines using complex filtergraphs for media mixing and overlays.
该项目是一个综合性教育计划和深度学习框架,旨在通过 Notebook 和代码示例教授 PyTorch 深度学习实践。它作为一个用于构建、训练和部署神经网络的高级库,充当模型训练编排器,协调 PyTorch 模型、优化器和损失函数。 该项目为计算机视觉、自然语言处理和表格数据预处理提供了专门的工具包。它通过高级训练控制脱颖而出,例如判别式学习率、用于自定义训练逻辑的双向回调系统,以及自动化设备放置和训练循环的高级学习器抽象。 该框架涵盖了广泛的能力面,包括自动化数据流水线构建、模型架构分析以及跨分类、回归和分割任务的性能评估。它还包括用于跨多个 GPU 进行分布式训练的工具、用于内存优化的混合精度训练,以及对医学影像数据的专门支持。 该项目以一系列 Jupyter Notebook 的形式交付。
Utilizes structured data block blueprints to declaratively define how raw data is assembled into model-ready batches.
docetl is an AI-powered document ETL tool and map-reduce orchestrator designed to transform large collections of unstructured documents into structured, queryable tables using language models. It provides a declarative pipeline framework for extracting, cleaning, and transforming data from sources such as PDFs and text files into predefined schemas. The project distinguishes itself through a semantic data integration suite that enables joining datasets and resolving duplicate entities based on embedding-based similarity. It includes an interactive prompt playground for developing and optimizi
Implements a declarative interface for defining complex data operations and workflows to transform unstructured datasets into tables.
This is a structured deep learning curriculum for programmers, delivered as a collection of Jupyter notebooks. It teaches the fundamentals of training neural networks for computer vision, natural language processing, tabular data analysis, and collaborative filtering using PyTorch and the fastai library. The course is designed to be hands-on, guiding learners from building a training loop from scratch to fine-tuning pretrained models for a variety of practical tasks. The curriculum distinguishes itself by covering the full lifecycle of a deep learning project, from data preparation and augmen
Constructs custom data processing pipelines using a declarative block API.
Dag-factory is a framework for constructing and managing Apache Airflow data pipelines through declarative configuration files. By replacing manual procedural code with structured YAML definitions, it enables the programmatic generation of complex workflow structures, task dependencies, and execution schedules. The project distinguishes itself by mapping configuration keys directly to Python class constructors and operators, allowing for the dynamic instantiation of objects and custom logic. It supports hierarchical configuration inheritance to standardize settings across environments and pro
Constructs data pipelines by parsing configuration files, allowing users to define workflow structures without manual procedural code.