Awesome GitHub RepositoriesReal-Time Event Processing

Pomelo is a distributed Node.js game server framework designed for building scalable multiplayer game backends and real-time web applications. It employs a multi-process architecture to distribute application logic horizontally across a cluster of machines, enabling high concurrency and balanced network traffic. The framework utilizes a WebSocket communication layer to manage bidirectional data exchange between diverse web clients and server clusters. It incorporates a remote procedure call system for triggering functions across remote server processes and uses Protocol Buffers for binary ser

RisingWave is a cloud-native streaming database and real-time analytics engine that uses standard SQL to process continuous data streams. It functions as a streaming data lakehouse, combining the capabilities of a streaming SQL database with a platform that integrates streaming ingestion with open table formats. The system is distinguished by its use of the PostgreSQL wire protocol, allowing it to integrate with existing SQL tools and drivers. It employs a decoupled compute and storage architecture, persisting streaming state and materialized views in cloud object storage to enable independen

Rx.NET is a reactive programming framework and library for the .NET ecosystem used to compose asynchronous and event-based programs. It provides an observable data stream API that treats live sequences of information as collections, allowing developers to coordinate asynchronous event workflows using a declarative syntax. The project functions as an extension of language integrated query patterns to asynchronous streams. This allows for the filtering and transformation of asynchronous notifications and event sequences through the application of query operators. The framework covers asynchron

Faust is a Python library for building distributed stream processing applications that integrate with Kafka. It functions as an asynchronous stream processor designed to handle high-throughput event streams and real-time data analysis using asynchronous functions. The system operates as a distributed stream processor and state store, utilizing sharding and partitioned topics to scale processing workloads horizontally across multiple worker nodes. It maintains state through a replicated key-value storage system backed by local databases to ensure high availability and fast recovery. The frame

Hazelcast is a distributed data platform that combines an in-memory data grid with a stream processing engine to support real-time analytics and event-driven applications. It functions as a partitioned, distributed key-value store that replicates data across cluster nodes to provide low-latency access and high availability. The platform also serves as a distributed SQL query engine, allowing users to execute standard SQL statements against both in-memory datasets and external data sources. What distinguishes Hazelcast is its use of a distributed consensus subsystem to maintain strongly consis

该项目是一个业务规则管理系统和规则引擎，旨在定义、执行和管理与应用程序源代码解耦的复杂业务逻辑。它提供了一个业务逻辑编译器，将人类可读的规则定义转换为可执行模型，以进行高性能的运行时评估。 该系统包含一个用于分析实时数据流以识别时间模式的复杂事件处理引擎，以及一个基于行业标准处理结构化逻辑以获得确定性结果的决策模型和符号执行器。它利用支持前向和后向链的推理引擎，通过评估复杂的逻辑依赖关系来自动化决策。 该平台涵盖了广泛的功能，包括规则会话管理、规则依赖分析和执行逻辑可视化。它还具有规则性能监控、规则格式转换以及通过可插拔持久化层进行会话状态恢复的工具。

OpenPanel is a self-hosted product analytics platform designed for tracking user behavior and visualizing product metrics on private infrastructure. It provides a comprehensive system for collecting events across web, mobile, and server environments while ensuring complete ownership of data. The platform distinguishes itself through a privacy-first approach, utilizing cookieless event tracking and regional data residency to simplify regulatory compliance. It integrates large language models via the Model Context Protocol, enabling users to query behavioral data and analyze trends using natura

CameraView 是一个高级 Android 相机库和硬件封装器，专为拍摄照片和视频而设计。它提供了一个用于管理相机硬件的抽象层，以及一个用于录制高分辨率视频和 RAW 照片（具有可配置比特率和分辨率）的媒体捕获 API。 该项目具有实时相机滤镜框架和预览管理器。这些系统允许将自定义着色器和视觉效果应用到实时相机流中，并渲染具有可自定义纵横比、覆盖层和构图网格的预览。 该库涵盖了广泛的硬件控制，包括传感器选择、变焦、曝光和自动对焦。它还管理媒体处理任务，如滤镜链、图形水印以及将地理位置元数据嵌入到 EXIF 数据中。 该工具包包含一个用于请求和管理相机硬件初始化所需的 Android 系统权限的系统。

CliWrap 是一个异步进程管理器和子进程包装库，用于执行外部命令并将命令行界面集成到应用程序中。它提供了一个框架，用于使用异步模式启动外部程序、管理子进程并验证退出代码。 该库的独特之处在于它能够将标准输入、输出和错误流路由到内存缓冲区或实时事件流。它支持对进程输出行进行实时监控，并支持通过取消令牌（cancellation tokens）终止进程。 该项目涵盖了广泛的外部进程管理功能，包括环境变量配置、标准流重定向以及捕获进程输出以作为应用程序内的数据使用。

GPUImage2 是一个 Swift 框架，用于使用 GPU 对图像和视频应用实时滤镜和效果。它提供了一个实时视频滤镜库、图像几何操作引擎以及用于在图形硬件上处理视觉数据的 OpenGL 着色流水线。 该框架支持通过将图像源链接到顺序流中的消费者来构建视觉效果流水线。它支持为定制图像处理开发自定义片段和顶点着色器，并提供通过基于图的分组将这些操作捆绑到可重用单元中的能力。 功能领域包括颜色调整、几何操作和合成图像生成。该系统还支持合成图像分层，允许使用 Alpha 混合和色度键控组合多个图像源。

Appium Desktop 是一个用于配置和管理 Appium 服务器以自动化移动应用程序测试的图形用户界面。它作为一个跨平台自动化管理器，用于控制跨不同移动操作系统和云提供商的会话。 该应用程序包括一个用于分析应用程序源树和识别元素属性的移动应用检查器，以及一个捕获用户交互以生成自动化代码的测试脚本记录器。 该工具涵盖服务器管理和生命周期控制，允许通过保存的预设管理网络配置和环境变量。它通过实时服务器日志监控提供可观测性，并具备会话管理功能，以初始化新会话或附加到现有会话。它还促进了与远程云测试平台的连接。

Jitsu 是一个客户数据平台，旨在收集、转换并将应用程序事件路由到数据仓库和营销工具。它作为一个事件摄取引擎和数据仓库路由器，通过 API 和 SDK 捕获行为数据以进行实时处理和存储。 该平台具有可编程的 JavaScript 数据流水线，允许在传输过程中对事件数据进行过滤、丰富和重塑。它包含一个客户身份拼接器，可合并匿名和已知的用户标识符，以在仓库中维护持久的客户画像。 系统涵盖了广泛的功能，包括来自 Web 和移动环境的多源事件收集、目标仓库的自动模式演进，以及到 SaaS 平台和 SQL 数据库的多目标路由。它为开发人员提供了一套用于测试转换逻辑的工具，并支持通过 Kubernetes 或自托管 Docker 环境进行部署。

Tetragon 是一个基于 eBPF 的运行时安全和可观测性工具集，专为 Linux 和 Kubernetes 环境设计。它作为安全策略管理器、可观测性代理和执行引擎，通过 Hook 内核函数和跟踪点来检测权限提升、容器逃逸和未经授权的系统活动。 该项目的独特之处在于其执行实时内核内（in-kernel）强制执行的能力，允许在系统调用完成前同步终止恶意进程或修改函数返回值。它通过同步容器身份并将底层内核事件直接映射到 Pod 和命名空间，提供了深度的 Kubernetes 集成。 其更广泛的功能涵盖了全面的系统调用审计、网络连接跟踪和文件完整性监控。系统支持动态策略管理，并提供用于监控 BPF 性能和资源利用率的诊断工具。 部署支持通过 Helm Chart 在 Kubernetes 集群中进行，也支持通过独立容器和原生操作系统包进行部署。

pyalgotrade is a Python algorithmic trading library designed for developing, backtesting, and executing automated trading strategies. It provides a comprehensive framework for financial strategy backtesting, a technical analysis library for computing mathematical indicators, and connectors for cryptocurrency exchange integration. The project distinguishes itself by supporting sentiment-based trading through the integration of real-time social media feeds and keyword streams. It features a quantitative trading visualization tool for plotting price action and portfolio equity curves, along with

ogl 是一个 WebGL 图形库和 3D 场景图引擎，专为渲染三维场景而设计。它提供了一个轻量级框架，用于在分层系统中管理几何体并协调空间变换。 该项目包括用于创建逼真材质的 PBR 着色器系统，以及用于在图形处理器上执行大规模通用计算和粒子模拟的 GPGPU 计算框架。它还具有一个后期处理套件，用于通过帧缓冲区将视觉滤镜应用于渲染场景。 该库涵盖了更广泛的功能，包括 3D 数学运算、3D 资源的导入和动画，以及通过射线投射和摄像机控制实现的用户交互。

Imageflow 是一个高性能图像操作库和合成引擎，可作为 C 兼容库、命令行图像处理器和动态图像处理服务器使用。它通过编程接口、JSON 作业文件或即时 URL 查询字符串，提供了解码、编码和对图像应用复杂视觉变换的方法。 该系统通过基于图的处理流水线脱颖而出，允许单次多格式编码，从单次解码中生成多种图像尺寸和格式，从而减少开销。它还具有资源受限的解码引擎，强制执行严格的内存和尺寸限制，以防止资源耗尽和拒绝服务攻击。 该项目涵盖了广泛的操作能力，包括尺寸调整、裁剪、旋转和颜色过滤。它支持高级合成任务，如水印、空白画布生成和几何形状渲染，以及使用直方图分析的自动色彩校正和白平衡调整。 核心逻辑通过外部函数接口绑定暴露，以实现跨语言集成。

Riemann 是一个基于 Clojure 的事件流处理器和实时分析引擎。它作为一个网络遥测管道和可扩展事件路由器，用于摄取、转换和路由来自分布式系统的事件数据。 该系统使用领域特定语言来计算连续流上的指标和统计模式，从而实现网络趋势分析和实时警报。它支持从类路径动态加载插件，并允许在不中断活动事件流的情况下实时重新加载配置。 功能包括集中式遥测聚合、事件元数据标记和有状态事件索引。该系统通过拆分、批处理和过滤处理事件流的调度，同时通过加密和身份验证提供安全的网络传输。

该存储库是用于将设备端机器学习 API 集成到移动应用程序中的示例应用程序和参考项目集合。它提供了 Android 和 iOS 的实现示例，演示了如何嵌入计算机视觉和自然语言处理模型。 该项目涵盖了移动计算机视觉的实现，包括文本识别、人脸检测和条形码扫描。它包括实时图像处理的工作流，以及集成在设备上本地处理数据的预训练模型。

SwiftBar 是一个 macOS 菜单栏自定义工具和基于插件的状态监视器，可直接在系统菜单栏中显示可执行脚本和 Shell 命令的输出。它作为一个 Shell 脚本仪表板，将实时数据和脚本结果渲染为交互式菜单项和下拉列表。 该项目作为一个自动化接口，与系统快捷方式和外部 URL Scheme 集成，以触发操作并更新状态指示器。它支持安装社区制作的脚本，并将复杂的插件资源打包到本地目录中。 该系统涵盖了广泛的功能，包括用于字体和颜色的元数据驱动渲染、基于间隔的轮询和实时数据流，以及在菜单界面中嵌入 Web 视图。它还提供用于动态逻辑的环境变量访问，并允许在终端模拟器中启动脚本执行结果以进行调试。