mirror of
https://github.com/PrefectHQ/fastmcp.git
synced 2026-08-09 07:09:11 +02:00
Add sales dashboard and live system monitor examples, bump prefab-ui to 0.17 (#3696)
This commit is contained in:
Jeremiah Lowin
GitHub
parent
493989f231
commit
27abe3c3f0
5 changed files with 456 additions and 14 deletions
233
examples/apps/sales_dashboard/sales_dashboard_server.py
Normal file
233
examples/apps/sales_dashboard/sales_dashboard_server.py
Normal file
|
|
@ -0,0 +1,233 @@
|
|||
from prefab_ui.components import (
|
||||
Card,
|
||||
CardContent,
|
||||
Column,
|
||||
Grid,
|
||||
Heading,
|
||||
Metric,
|
||||
Muted,
|
||||
Row,
|
||||
Separator,
|
||||
Text,
|
||||
)
|
||||
from prefab_ui.components.charts import AreaChart, ChartSeries, PieChart
|
||||
from prefab_ui.components.data_table import DataTable, DataTableColumn
|
||||
|
||||
from fastmcp import FastMCP
|
||||
|
||||
mcp = FastMCP("Sales Dashboard")
|
||||
|
||||
MONTHLY_REVENUE = [
|
||||
{"month": "Jul", "new_business": 182_000, "expansion": 74_000, "renewal": 210_000},
|
||||
{"month": "Aug", "new_business": 195_000, "expansion": 81_000, "renewal": 215_000},
|
||||
{"month": "Sep", "new_business": 224_000, "expansion": 93_000, "renewal": 208_000},
|
||||
{"month": "Oct", "new_business": 210_000, "expansion": 88_000, "renewal": 222_000},
|
||||
{"month": "Nov", "new_business": 248_000, "expansion": 102_000, "renewal": 230_000},
|
||||
{"month": "Dec", "new_business": 271_000, "expansion": 115_000, "renewal": 238_000},
|
||||
{"month": "Jan", "new_business": 235_000, "expansion": 97_000, "renewal": 241_000},
|
||||
{"month": "Feb", "new_business": 262_000, "expansion": 108_000, "renewal": 245_000},
|
||||
{"month": "Mar", "new_business": 289_000, "expansion": 121_000, "renewal": 252_000},
|
||||
{"month": "Apr", "new_business": 305_000, "expansion": 134_000, "renewal": 258_000},
|
||||
{"month": "May", "new_business": 318_000, "expansion": 142_000, "renewal": 263_000},
|
||||
{"month": "Jun", "new_business": 342_000, "expansion": 156_000, "renewal": 270_000},
|
||||
]
|
||||
|
||||
REVENUE_BY_SEGMENT = [
|
||||
{"segment": "Enterprise", "revenue": 3_840_000},
|
||||
{"segment": "Mid-Market", "revenue": 2_160_000},
|
||||
{"segment": "SMB", "revenue": 1_440_000},
|
||||
{"segment": "Startup", "revenue": 720_000},
|
||||
]
|
||||
|
||||
RECENT_DEALS = [
|
||||
{
|
||||
"company": "Meridian Health Systems",
|
||||
"amount": "$485,000",
|
||||
"stage": "Closed Won",
|
||||
"rep": "Sarah Chen",
|
||||
"close_date": "Jun 12, 2026",
|
||||
},
|
||||
{
|
||||
"company": "Atlas Financial Group",
|
||||
"amount": "$372,000",
|
||||
"stage": "Closed Won",
|
||||
"rep": "Marcus Rivera",
|
||||
"close_date": "Jun 10, 2026",
|
||||
},
|
||||
{
|
||||
"company": "Pinnacle Manufacturing",
|
||||
"amount": "$298,000",
|
||||
"stage": "Negotiation",
|
||||
"rep": "Aisha Patel",
|
||||
"close_date": "Jun 28, 2026",
|
||||
},
|
||||
{
|
||||
"company": "Crestview Logistics",
|
||||
"amount": "$264,000",
|
||||
"stage": "Proposal Sent",
|
||||
"rep": "James O'Brien",
|
||||
"close_date": "Jul 5, 2026",
|
||||
},
|
||||
{
|
||||
"company": "Northstar Retail",
|
||||
"amount": "$215,000",
|
||||
"stage": "Closed Won",
|
||||
"rep": "Sarah Chen",
|
||||
"close_date": "Jun 8, 2026",
|
||||
},
|
||||
{
|
||||
"company": "Ironclad Security",
|
||||
"amount": "$189,000",
|
||||
"stage": "Negotiation",
|
||||
"rep": "Lena Kowalski",
|
||||
"close_date": "Jul 1, 2026",
|
||||
},
|
||||
{
|
||||
"company": "Summit Analytics",
|
||||
"amount": "$176,000",
|
||||
"stage": "Closed Won",
|
||||
"rep": "Marcus Rivera",
|
||||
"close_date": "Jun 5, 2026",
|
||||
},
|
||||
{
|
||||
"company": "Brightpath Education",
|
||||
"amount": "$142,000",
|
||||
"stage": "Proposal Sent",
|
||||
"rep": "Aisha Patel",
|
||||
"close_date": "Jul 12, 2026",
|
||||
},
|
||||
{
|
||||
"company": "Vantage Media",
|
||||
"amount": "$128,000",
|
||||
"stage": "Closed Won",
|
||||
"rep": "Lena Kowalski",
|
||||
"close_date": "Jun 3, 2026",
|
||||
},
|
||||
{
|
||||
"company": "Redwood Hospitality",
|
||||
"amount": "$97,000",
|
||||
"stage": "Discovery",
|
||||
"rep": "James O'Brien",
|
||||
"close_date": "Jul 20, 2026",
|
||||
},
|
||||
]
|
||||
|
||||
|
||||
@mcp.tool(app=True)
|
||||
def sales_dashboard() -> Column:
|
||||
"""Company sales dashboard with KPIs, revenue trends, segment breakdown, and recent deals."""
|
||||
total_revenue = sum(
|
||||
row["new_business"] + row["expansion"] + row["renewal"]
|
||||
for row in MONTHLY_REVENUE
|
||||
)
|
||||
current_quarter = sum(
|
||||
row["new_business"] + row["expansion"] + row["renewal"]
|
||||
for row in MONTHLY_REVENUE[-3:]
|
||||
)
|
||||
prior_quarter = sum(
|
||||
row["new_business"] + row["expansion"] + row["renewal"]
|
||||
for row in MONTHLY_REVENUE[-6:-3]
|
||||
)
|
||||
growth_pct = (current_quarter - prior_quarter) / prior_quarter * 100
|
||||
|
||||
with Column(gap=6, css_class="p-6") as view:
|
||||
with Row(gap=2, align="center"):
|
||||
Heading("Sales Dashboard")
|
||||
Muted("FY2026 | Last updated Jun 15, 2026")
|
||||
|
||||
with Grid(columns=4, gap=4):
|
||||
with Card():
|
||||
with CardContent():
|
||||
Metric(
|
||||
label="Total Revenue",
|
||||
value=f"${total_revenue / 1_000_000:.1f}M",
|
||||
delta="+18.2% YoY",
|
||||
trend="up",
|
||||
)
|
||||
|
||||
with Card():
|
||||
with CardContent():
|
||||
Metric(
|
||||
label="Quarterly Growth",
|
||||
value=f"{growth_pct:.1f}%",
|
||||
delta="+3.8pp vs prior",
|
||||
trend="up",
|
||||
)
|
||||
|
||||
with Card():
|
||||
with CardContent():
|
||||
Metric(
|
||||
label="Active Customers",
|
||||
value="1,847",
|
||||
delta="+124 this quarter",
|
||||
trend="up",
|
||||
)
|
||||
|
||||
with Card():
|
||||
with CardContent():
|
||||
Metric(
|
||||
label="Avg Deal Size",
|
||||
value="$236K",
|
||||
delta="+12% vs H1",
|
||||
trend="up",
|
||||
)
|
||||
|
||||
with Grid(columns=3, gap=6):
|
||||
with Card(css_class="col-span-2"):
|
||||
with CardContent():
|
||||
Text(
|
||||
"Monthly Revenue",
|
||||
css_class="text-sm font-medium text-muted-foreground mb-2",
|
||||
)
|
||||
AreaChart(
|
||||
data=MONTHLY_REVENUE,
|
||||
series=[
|
||||
ChartSeries(data_key="new_business", label="New Business"),
|
||||
ChartSeries(data_key="expansion", label="Expansion"),
|
||||
ChartSeries(data_key="renewal", label="Renewal"),
|
||||
],
|
||||
x_axis="month",
|
||||
stacked=True,
|
||||
curve="smooth",
|
||||
show_legend=True,
|
||||
height=280,
|
||||
y_axis_format="compact",
|
||||
)
|
||||
|
||||
with Card():
|
||||
with CardContent():
|
||||
Text(
|
||||
"Revenue by Segment",
|
||||
css_class="text-sm font-medium text-muted-foreground mb-2",
|
||||
)
|
||||
PieChart(
|
||||
data=REVENUE_BY_SEGMENT,
|
||||
data_key="revenue",
|
||||
name_key="segment",
|
||||
show_legend=True,
|
||||
inner_radius=50,
|
||||
height=280,
|
||||
)
|
||||
|
||||
Separator()
|
||||
|
||||
Text("Recent Deals", css_class="text-lg font-semibold")
|
||||
|
||||
DataTable(
|
||||
columns=[
|
||||
DataTableColumn(key="company", header="Company", sortable=True),
|
||||
DataTableColumn(key="amount", header="Amount", sortable=True),
|
||||
DataTableColumn(key="stage", header="Stage", sortable=True),
|
||||
DataTableColumn(key="rep", header="Sales Rep", sortable=True),
|
||||
DataTableColumn(key="close_date", header="Close Date", sortable=True),
|
||||
],
|
||||
rows=RECENT_DEALS,
|
||||
search=True,
|
||||
paginated=True,
|
||||
)
|
||||
|
||||
return view
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
mcp.run()
|
||||
195
examples/apps/system_monitor/system_monitor_server.py
Normal file
195
examples/apps/system_monitor/system_monitor_server.py
Normal file
|
|
@ -0,0 +1,195 @@
|
|||
"""System monitor — live CPU, memory, and disk stats from the host machine.
|
||||
|
||||
Auto-refreshes every 3 seconds via SetInterval + CallTool.
|
||||
|
||||
Requires psutil: pip install psutil
|
||||
|
||||
Usage:
|
||||
fastmcp dev apps system_monitor_server.py
|
||||
"""
|
||||
|
||||
import platform
|
||||
import time
|
||||
from datetime import datetime
|
||||
|
||||
import psutil
|
||||
from prefab_ui.actions import SetInterval, SetState
|
||||
from prefab_ui.actions.mcp import CallTool
|
||||
from prefab_ui.app import PrefabApp
|
||||
from prefab_ui.components import (
|
||||
Badge,
|
||||
Card,
|
||||
CardContent,
|
||||
CardHeader,
|
||||
Column,
|
||||
Grid,
|
||||
Heading,
|
||||
Metric,
|
||||
Muted,
|
||||
Progress,
|
||||
Row,
|
||||
Select,
|
||||
SelectOption,
|
||||
Small,
|
||||
Text,
|
||||
)
|
||||
from prefab_ui.components.charts import AreaChart, ChartSeries
|
||||
from prefab_ui.components.control_flow import ForEach
|
||||
from prefab_ui.rx import RESULT, STATE, Rx
|
||||
|
||||
from fastmcp import FastMCP
|
||||
from fastmcp.apps.app import FastMCPApp
|
||||
|
||||
app = FastMCPApp("Monitor")
|
||||
|
||||
_history: list[dict] = []
|
||||
|
||||
|
||||
def _collect_stats() -> dict:
|
||||
"""Collect a full snapshot of system stats."""
|
||||
cpu = psutil.cpu_percent(interval=0.1)
|
||||
mem = psutil.virtual_memory()
|
||||
disk = psutil.disk_usage("/")
|
||||
|
||||
now = datetime.now().strftime("%H:%M:%S")
|
||||
_history.append({"time": now, "cpu": cpu, "memory": mem.percent})
|
||||
if len(_history) > 100:
|
||||
del _history[: len(_history) - 100]
|
||||
|
||||
top_procs = []
|
||||
for p in sorted(
|
||||
psutil.process_iter(["pid", "name", "cpu_percent", "memory_percent"]),
|
||||
key=lambda p: p.info.get("cpu_percent") or 0,
|
||||
reverse=True,
|
||||
)[:6]:
|
||||
info = p.info
|
||||
top_procs.append(
|
||||
{
|
||||
"pid": info.get("pid") or 0,
|
||||
"name": info.get("name") or "unknown",
|
||||
"cpu": f"{(info.get('cpu_percent') or 0):.1f}%",
|
||||
"memory": f"{(info.get('memory_percent') or 0):.1f}%",
|
||||
}
|
||||
)
|
||||
|
||||
return {
|
||||
"cpu": cpu,
|
||||
"mem_pct": mem.percent,
|
||||
"mem_used": mem.used // (1024**3),
|
||||
"mem_total": mem.total // (1024**3),
|
||||
"disk_pct": disk.percent,
|
||||
"disk_used": disk.used // (1024**3),
|
||||
"disk_total": disk.total // (1024**3),
|
||||
"uptime": _format_uptime(),
|
||||
"cores": psutil.cpu_count(),
|
||||
"platform": f"{platform.system()} {platform.machine()}",
|
||||
"hostname": platform.node(),
|
||||
"healthy": cpu < 80 and mem.percent < 90,
|
||||
"history": list(_history),
|
||||
"top_procs": top_procs,
|
||||
}
|
||||
|
||||
|
||||
def _format_uptime() -> str:
|
||||
elapsed = int(time.time() - psutil.boot_time())
|
||||
days, remainder = divmod(elapsed, 86400)
|
||||
hours, remainder = divmod(remainder, 3600)
|
||||
minutes, _ = divmod(remainder, 60)
|
||||
if days > 0:
|
||||
return f"{days}d {hours}h {minutes}m"
|
||||
return f"{hours}h {minutes}m"
|
||||
|
||||
|
||||
@app.tool()
|
||||
def refresh() -> dict:
|
||||
"""Collect fresh system stats."""
|
||||
return _collect_stats()
|
||||
|
||||
|
||||
@app.ui()
|
||||
def system_dashboard() -> PrefabApp:
|
||||
"""Live system dashboard with auto-refresh."""
|
||||
initial = _collect_stats()
|
||||
|
||||
with PrefabApp(state={"stats": initial, "interval": "500"}) as ui:
|
||||
with Column(
|
||||
gap=6,
|
||||
css_class="p-6",
|
||||
on_mount=SetInterval(
|
||||
duration=Rx("interval"),
|
||||
on_tick=CallTool(
|
||||
"refresh",
|
||||
on_success=SetState("stats", RESULT),
|
||||
),
|
||||
),
|
||||
):
|
||||
with Row(gap=3, align="center"):
|
||||
Heading("System Monitor")
|
||||
Badge(STATE.stats.hostname, variant="outline")
|
||||
with Select(name="interval", css_class="w-32"):
|
||||
SelectOption("0.5s", value="500")
|
||||
SelectOption("1s", value="1000")
|
||||
SelectOption("5s", value="5000")
|
||||
|
||||
with Grid(columns=4, gap=4):
|
||||
with Card():
|
||||
with CardContent():
|
||||
Metric(label="CPU", value=f"{STATE.stats.cpu}%")
|
||||
Progress(value=STATE.stats.cpu)
|
||||
|
||||
with Card():
|
||||
with CardContent():
|
||||
Metric(label="Memory", value=f"{STATE.stats.mem_pct}%")
|
||||
Progress(value=STATE.stats.mem_pct)
|
||||
Muted(f"{STATE.stats.mem_used}GB / {STATE.stats.mem_total}GB")
|
||||
|
||||
with Card():
|
||||
with CardContent():
|
||||
Metric(label="Disk", value=f"{STATE.stats.disk_pct}%")
|
||||
Progress(value=STATE.stats.disk_pct)
|
||||
Muted(f"{STATE.stats.disk_used}GB / {STATE.stats.disk_total}GB")
|
||||
|
||||
with Card():
|
||||
with CardContent():
|
||||
Metric(label="Uptime", value=STATE.stats.uptime)
|
||||
Muted(f"{STATE.stats.cores} cores")
|
||||
|
||||
with Grid(columns=[2, 1], gap=4):
|
||||
with Card():
|
||||
with CardHeader():
|
||||
Text("CPU & Memory", css_class="text-sm font-medium")
|
||||
with CardContent():
|
||||
AreaChart(
|
||||
data=STATE.stats.history,
|
||||
series=[
|
||||
ChartSeries(data_key="cpu", label="CPU %"),
|
||||
ChartSeries(data_key="memory", label="Memory %"),
|
||||
],
|
||||
x_axis="time",
|
||||
curve="smooth",
|
||||
show_legend=True,
|
||||
height=220,
|
||||
animate=False,
|
||||
)
|
||||
|
||||
with Card():
|
||||
with CardHeader():
|
||||
Text("Top Processes", css_class="text-sm font-medium")
|
||||
with CardContent():
|
||||
with Column(gap=2):
|
||||
with ForEach("stats.top_procs") as proc:
|
||||
with Row(justify="between", align="center"):
|
||||
with Column(gap=0):
|
||||
Small(proc.name)
|
||||
Muted(proc.pid)
|
||||
with Row(gap=2):
|
||||
Badge(proc.cpu, variant="outline")
|
||||
Badge(proc.memory, variant="outline")
|
||||
|
||||
return ui
|
||||
|
||||
|
||||
mcp = FastMCP("System Monitor", providers=[app])
|
||||
|
||||
if __name__ == "__main__":
|
||||
mcp.run()
|
||||
Loading…
Add table
Add a link
Reference in a new issue