Skip to content

PlainsightAI/openfilter

Repository files navigation

OpenFilter

PyPI version License: Apache 2.0 Build Status

OpenFilter is an universal abstraction for building and running vision workloads in modular image/video processing pipelines. It simplifies communication between components (called filters) and supports synchronization, side-channel paths, metrics, and load balancing — all in pure Python.

Jump to:


Features

  • 🔁 Easily pluggable filter components
  • 🧪 Develop and test filters locally with Python
  • ⚡ High-throughput synchronized pipelines
  • 📡 MQTT/REST visualization and data publishing
  • 🧵 Parallel processing via load-balanced filter branches
  • 📊 Built-in telemetry and metrics streaming (coming soon)

Installation

Install OpenFilter with all utility filter dependencies:

pip install openfilter[all]

Install directly from GitHub:

pip install git+ssh://git@github.com/PlainsightAI/openfilter.git@main#egg=openfilter[all]

To install a specific version:

pip install git+ssh://git@github.com/PlainsightAI/openfilter.git@v1.3.17#egg=openfilter[all]

Editable install for development:

git clone git@github.com:PlainsightAI/openfilter.git
cd openfilter
make install

Quick Start

Here’s a minimal example that plays a video and visualizes it in the browser:

from openfilter.filter_runtime.filter import Filter
from openfilter.filter_runtime.filters.video_in import VideoIn
from openfilter.filter_runtime.filters.webvis import Webvis

if __name__ == '__main__':
    Filter.run_multi([
        (VideoIn, dict(sources='file://video.mp4', outputs='tcp://*')),
        (Webvis,  dict(sources='tcp://localhost')),
    ])

Run it with:

python script.py

Then open http://localhost:8000 to see your video stream.


Alternatively, simply use the CLI:

openfilter run - VideoIn --sources 'file://video.mp4!loop' - Webvis

Note: Ensure that a video.mp4 file exists. A simple example is available at examples/hello-world/video.mp4.

Examples

Explore real-world examples covering:

  • Frame-by-frame video processing
  • Writing frames to JPEG or output video
  • Dual-video pipelines with multiple topics
  • Load balancing using multiple filter processes
  • Sending metrics to MQTT
  • Ephemeral side-channel processing
  • S3 integration for cloud video processing
  • Fully declarative + class-based configuration

➡️ See docs/overview.md for all examples.


Documentation


Contributing

We welcome contributions of all kinds — new filters, bugfixes, or documentation improvements!

Please see the contributing guide for details on how to get started.

If you encounter issues, open an issue.


License

Apache License 2.0. See LICENSE for full text.

About

Universal Vision Workloads

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Contributors 9