Awesome GitHub RepositoriesDistributed Processing

Open WebUI is a self-hosted, web-based platform designed for interacting with local and remote artificial intelligence models. It functions as a unified interface and orchestration suite, enabling users to build, deploy, and manage specialized AI agents equipped with custom instructions, external tool access, and private knowledge bases. The platform distinguishes itself through a modular architecture that supports complex AI workflows. It features a plugin-based framework for custom logic and pipeline-based request processing, allowing developers to filter or transform data streams before th

Airflow is a workflow orchestration platform for authoring, scheduling, and monitoring complex data pipelines as code using Python. It employs a DAG-based task scheduler to manage execution timing and dependencies via directed acyclic graphs, utilizing a distributed task execution engine to run workloads across a cluster of worker nodes. The platform provides a data pipeline monitor for tracking the health and execution history of programmatic workflows. This includes a web interface for workflow progress visualization and health monitoring to identify and troubleshoot pipeline failures. The

Fastai is a high-level deep learning library built on PyTorch that provides a unified interface for managing the entire machine learning lifecycle. It functions as a comprehensive training toolkit, abstracting hardware management and automating complex training loops to simplify the construction and execution of neural network models. The framework is distinguished by its notebook-centric development environment and a type-dispatching data pipeline that automatically applies transformations based on input data formats. It emphasizes transfer learning through discriminative layer-wise optimiza

Bull is a Node.js library for managing distributed jobs and message queues using Redis as the primary data store. It functions as a distributed task worker, job scheduler, and priority queue manager designed to handle asynchronous workloads across multiple processes. The project distinguishes itself by providing a persistent communication channel that decouples servers through the exchange of serializable data objects. It ensures distributed system reliability by detecting stalled tasks and recovering from process crashes to ensure every queued job is completed. The system covers a broad ran

ImageMagick is a comprehensive software suite for the creation, editing, composition, and conversion of digital images. It functions as both a command-line utility for batch processing and automation, and as a programming library that allows developers to integrate advanced image manipulation capabilities into external applications. The project is distinguished by its modular architecture, which supports hundreds of image formats through a pluggable coder system and external delegate libraries. It is designed for high-performance environments, utilizing memory-mapped pixel caching, stream-ori

Nightingale is a Prometheus-compatible monitoring and alerting platform designed to centralize telemetry management across multiple time-series databases. It functions as a multi-source alerting engine and metric data pipeline that ingests telemetry via remote write protocols and triggers alarms based on data from sources such as Prometheus, Elasticsearch, Loki, and ClickHouse. The system is distinguished by its automated alert healing system, which executes predefined scripts and RPC-based corrective actions when monitoring thresholds are breached. It supports distributed alert processing, a

Meshroom is a node-based photogrammetry software designed to transform collections of two-dimensional images into three-dimensional models and scene geometry. It provides a visual interface for constructing and managing modular data pipelines, allowing users to automate complex computer vision tasks such as feature extraction, depth map estimation, and mesh generation. The software distinguishes itself through a distributed computational framework that dispatches resource-intensive tasks across local hardware or remote render farms. By utilizing a directed acyclic graph execution model, it en

Synapse is a decentralized communication server implementation that enables real-time messaging and data exchange across the global Matrix federation. It functions as a homeserver, allowing operators to host their own nodes while maintaining control over personal data and user identity within a distributed network. The server utilizes a federated messaging protocol to exchange messages and user data with independent servers, ensuring consistent state across the network. To support high-traffic environments, it employs a distributed service architecture that offloads tasks to independent backg

Colyseus is a real-time multiplayer game framework for Node.js that provides an authoritative server model, delta-compressed state synchronization, and room-based session orchestration. It is designed to handle the core infrastructure of multiplayer games, including matchmaking, state management, and scalable process distribution across multiple servers. The framework distinguishes itself through its schema-based state definition, which enables automatic serialization and change tracking, combined with a binary WebSocket protocol for low-latency updates. Its matchmaking pipeline routes player

KBEngine बड़े पैमाने पर मल्टीप्लेयर ऑनलाइन एनवायरनमेंट के लिए डिज़ाइन किया गया एक डिस्ट्रीब्यूटेड गेम सर्वर इंजन और बैकएंड इंफ्रास्ट्रक्चर है। यह एक साझा वर्चुअल वर्ल्ड के भीतर उच्च खिलाड़ी समवर्ती (concurrency) और रियल-टाइम इंटरैक्शन को संभालने के लिए एक मल्टी-प्रोसेस आर्किटेक्चर प्रदान करता है। इस सिस्टम में एक स्क्रिप्टेबल गेम लॉजिक फ्रेमवर्क है जो एक उच्च-प्रदर्शन कोर को एक हाई-लेवल स्क्रिप्टिंग भाषा के साथ जोड़ता है। यह एक हॉट-फ़िक्सेबल रनटाइम के माध्यम से गेम व्यवहार संशोधनों की अनुमति देता है जो सर्वर पुनरारंभ की आवश्यकता के बिना लॉजिक को अपडेट करता है। यह इंजन कई हार्डवेयर नोड्स पर डायनामिक लोड बैलेंसिंग के माध्यम से सर्वर स्केलिंग का प्रबंधन करता है और सर्वर और गेम क्लाइंट्स के बीच रियल-टाइम स्टेट सिंक्रोनाइज़ेशन के माध्यम से एक सुसंगत वर्ल्ड व्यू सुनिश्चित करता है। इसमें गेम डेटा पर्सिस्टेंस के लिए तंत्र भी शामिल हैं, जैसे कि निर्धारित एंटिटी बैकअप और सर्वर स्टेट स्नैपशॉटिंग। प्रशासनिक क्षमताओं में सिस्टम स्थिति की निगरानी और सर्वर जीवनचक्र को प्रबंधित करने के लिए लाइव सर्वर डिबगिंग टूल्स शामिल हैं।

Tdarr एक डिस्ट्रीब्यूटेड वीडियो प्रोसेसिंग और मीडिया लाइब्रेरी ऑटोमेशन टूल है। यह एक सर्वर-नोड आर्किटेक्चर के रूप में कार्य करता है जो कस्टम नियमों के आधार पर ऑडियो और वीडियो फाइलों की स्कैनिंग, विश्लेषण और सामान्यीकरण (normalization) को मैनेज करता है। यह सिस्टम हार्डवेयर उपयोग को ऑप्टिमाइज़ करने के लिए कई रिमोट नोड्स में ट्रांसकोडिंग और हेल्थ चेक जैसे भारी कंप्यूट वर्कफ़्लो को वितरित करता है। यह फाइल फॉर्मेट और कंटेनर्स को मानकीकृत करने के लिए FFmpeg और HandBrake के माध्यम से मीडिया रूपांतरण को स्वचालित करते हुए, फिल्टर और ट्रांसफॉर्मेशन के अनुक्रमों को निष्पादित करने के लिए एक प्लगइन-आधारित पाइपलाइन का उपयोग करता है। यह प्रोजेक्ट फाइल अखंडता और प्लेबैक त्रुटियों को सत्यापित करने के लिए मीडिया लाइब्रेरी हेल्थ ऑडिटिंग, साथ ही वीडियो फाइलों से तकनीकी गुण निकालने के लिए मेटाडेटा-संचालित इंडेक्सिंग को कवर करता है। इसमें नई मीडिया का पता चलने पर प्रोसेसिंग जॉब्स को स्वचालित रूप से ट्रिगर करने के लिए फाइलसिस्टम मॉनिटरिंग शामिल है।

Bee-queue एक Node.js बैकग्राउंड प्रोसेसिंग सिस्टम है जो जॉब क्यूइंग और पर्सिस्टेंस के लिए Redis का उपयोग करता है। इसे एप्लिकेशन रिस्पॉन्सिवनेस बनाए रखने के लिए मुख्य निष्पादन थ्रेड से भारी कार्यों को बैकग्राउंड वर्कर्स पर ऑफलोड करने के लिए डिज़ाइन किया गया है। यह प्रोजेक्ट डिस्ट्रीब्यूटेड जॉब प्रोसेसिंग प्रदान करता है, जिससे वर्कर नोड्स को एक साथ बड़ी मात्रा में कार्यों को संभालने के लिए मल्टीपल प्रोसेसेस में चलने की अनुमति मिलती है। यह ऑटोमैटिक रिट्रायल्स और स्टॉल्ड प्रोसेसेस की रिकवरी के माध्यम से विश्वसनीय कार्य निष्पादन सुनिश्चित करता है। इसकी क्षमता सतह में विलंबित जॉब्स के लिए एसिंक्रोनस टास्क शेड्यूलिंग, वर्कर नोड्स के लिए कॉनकरेंसी कंट्रोल और जॉब लाइफसाइकिल मैनेजमेंट शामिल है। इसमें क्यू हेल्थ की निगरानी, जॉब प्रोग्रेस को ट्रैक करने और जॉब स्टेट के आधार पर परिणाम प्राप्त करने के लिए टूल्स शामिल हैं। यह सिस्टम नेटवर्क ओवरहेड को कम करने के लिए बल्क जॉब एनक्यूइंग को सपोर्ट करता है और कस्टम जॉब आइडेंटिफायर्स व विफल कार्यों के लिए कॉन्फ़िगर करने योग्य बैकऑफ रणनीतियों की अनुमति देता है।