pgframx 0.2.0

Flask-based event management orchestration framework with scaffold generator

pgframx

Flask-based event management orchestration framework.

Orchestrate events, not chaos.

Install

pip install pgframx

Quickstart

from pgframx import Orchestrator, create_app

orc = Orchestrator()

@orc.on("order.placed")
def handle_order(event):
    print(f"Order received: {event.data}")

app = create_app(orc)

if __name__ == "__main__":
    app.run(port=5050)

CLI

pgframx init        # Create a new project scaffold in current directory
pgframx run         # Start the Flask orchestrator server
pgframx emit <event> --data '{}'  # Emit event from CLI to running server
pgframx list events               # List all registered events
pgframx list listeners            # List all registered listeners
pgframx schedule list             # List scheduled cron/interval jobs
pgframx schedule add <event> --interval 10  # Schedule recurring events
pgframx schedule remove <job_id>  # Remove scheduled jobs

Features

• Decorators: Event registration, before hooks, and after hooks.
• Wildcard matching: Match events using wildcards (user.*).
• Scheduling: Chronological/interval-based triggers via APScheduler.
• REST API: Mountable blueprints exposing route endpoints for events, listeners, and health checks.
• Dynamic Webhooks: Register webhooks dynamically via the REST API or CLI.
• Full CLI: Manage your event broker process from the terminal.