RConnect

Event-Driven Integration & Analytics Platform for R

Overview

RConnect is an R-native event-driven integration and analytics platform that allows organizations to integrate data sources, automate workflows, and analyze events in real time using R's statistical and machine learning ecosystem.

Installation

# Install dependencies
install.packages(c("redux", "duckdb", "dplyr", "tidymodels", "shiny", 
                   "targets", "jsonlite", "logger", "purrr", "tibble", 
                   "tidyr", "glue", "R6", "later", "promises"))

# Install RConnect
devtools::install_github("danymukesha/RConnect")

Quick Start

library(RConnect)

# Start the event bus
bus <- start_event_bus()

# Create storage
storage <- connect(":memory:")

# Run churn prediction pipeline
result <- run_churn_pipeline()

# Run dashboard
run_dashboard(storage)

# Stop pipeline
stop_churn_pipeline(result)

Architecture

• Event Bus: Redis-based pub/sub messaging
• Agents: Modular R processes for event processing
• Storage: DuckDB for persistent data
• Analytics: tidymodels for ML
• Dashboard: Shiny for real-time visualization

Example: Customer Churn Pipeline

See R/example_churn.R for a complete example.