RoadSafety BC DataHub API. A series of Python components for handling and processing digital forms.

Open-the-chests is a training environment for event-patterns recognition.

An application-agnostic, open-source tool designed to build incremental indices from continuously streaming event data.

Arion is a service to transform a set of Esper EPL queries into EQMN models. With a graphical model, even non-computer scientists can comprehend event queries, event types and the cause for an event.

Python challenge: merge user events into sessions with deep meta merge, ordered type counts, and Dockerized tests.

A Wishbone output module to write data to the Elasticsearch document store

AWS Lambda solution that automatically creates and manages Dead Letter Queues (DLQs) for EventBridge rules. Ensures failed events are captured for analysis with scheduled reconciliation and real-time enforcement.

Minimalistic event processing framework on pure Python. Supports async and sync modes.

A command-line utility for analyzing timestamped event logs and producing time-based activity summaries. This tool was built as a foundational analytics utility and learning project, focusing on schema-first design, separation of concerns, and incremental feature development.

"High-performance cognitive computing platform..."

A Wishbone output module to send events to Twitter

A wishbone input module to consume messages from Azure queue storage

A wishbone output module to submit messages to Azure queue storage

Streaming event pipeline around Apache Kafka and its ecosystem, simulating Real-time Data Streaming

🚀 Simplify data ingestion with Smart Ingest Kit, a lightweight toolkit that uses intelligent chunking for optimized, layout-aware RAG processes.

A data processing pipeline to parse the input event files from local and process them based on business requirements and export the output for further analysis and processing.