Storage Intelligence MCP
Read-only Azure storage intelligence MCP server enabling scoped investigations, risk analytics, cost savings simulation, data health checks, and admin tenant-wide discovery across a synthetic storage estate.
README
Storage Intelligence MCP/A2A Agent
Production-like, read-only Azure storage intelligence pilot with a 2,500-account synthetic estate spanning 339 subscriptions across Dev, QA, Perf, and Prod, deterministic analytics, private Foundry tools, and an Entra-protected web application.
The same deterministic agent is available through REST, an official MCP Streamable HTTP server, and A2A v1 JSON-RPC/HTTP+JSON endpoints. See MCP and A2A integration for client configuration, authentication, discovery, and request examples.
Live MCP and A2A endpoints
The Sweden Central deployment uses this Entra-protected base URL:
https://ca-storage-intel-kxlgam3w.wittyforest-55ec85c1.swedencentral.azurecontainerapps.io
| Protocol | Endpoint |
|---|---|
| MCP Streamable HTTP | https://ca-storage-intel-kxlgam3w.wittyforest-55ec85c1.swedencentral.azurecontainerapps.io/mcp/ |
| A2A Agent Card | https://ca-storage-intel-kxlgam3w.wittyforest-55ec85c1.swedencentral.azurecontainerapps.io/.well-known/agent-card.json |
| A2A JSON-RPC | https://ca-storage-intel-kxlgam3w.wittyforest-55ec85c1.swedencentral.azurecontainerapps.io/a2a |
| A2A HTTP+JSON | https://ca-storage-intel-kxlgam3w.wittyforest-55ec85c1.swedencentral.azurecontainerapps.io/a2a/rest |
External clients must request a Microsoft Entra token for the web application's
api://<WEB_AUTH_CLIENT_ID> audience and send it as a bearer token. Use /mcp/
as the canonical MCP URL; /mcp redirects to the mounted transport path.
Product experience
- PepsiCo-branded responsive dashboard with pinned, locally served React assets.
- Persistent English/Spanish language switch in the top-right header for globally distributed teams in Hyderabad, Barcelona, Mexico, the US, and the UK. Navigation, forms, statuses, accessibility labels, dynamic counts, risk factors, built-in questions, and deterministic answer summaries render in the selected language without changing API identifiers or resource names.
- Manual pilot onboarding by storage account name, tenant ID, management group, subscription, environment, subsidiary/business unit, region, and access tier.
- Authenticated selection-list management for adding tenants, management groups, subscriptions, subsidiaries/business units, plus the complete customer-facing Azure public-region catalog in every region selector.
- Bulk XLSX/CSV onboarding for avoiding repetitive manual entry. Imports are validated atomically, reject duplicates, and update only the in-memory pilot inventory.
- Administrator-only tenant discovery that runs read-only Azure CLI commands across all authorized subscriptions and imports tenant, management-group, subsidiary/business-unit, environment, storage account, region, tier, SKU, access/network posture, and project-governance tags.
- Tiny Databricks, Fabric Lakehouse, SAP, Azure Data Factory, SFTP, and Application
Insights badges on linked storage accounts. The synthetic estate deterministically
randomizes these relationships; discovery reads native
isSftpEnabled/isHnsEnabledproperties plusApplicationInsights/AppInsightstag aliases. - Deterministic capacity, cost, risk, Databricks, forecast, anomaly, tier-savings, evidence, confidence, and freshness investigations.
- Risk concentration lists Growth, Cost, Freshness, Operations, Databricks, Configuration, Security, and Governance categories with a calm low-saturation palette. Security explicitly scores SAS/shared keys, public access, missing private endpoints, NSG/ASG links, and missing service-principal access. Governance uses project, business-unit, last-accessed, and defunct tags. A donut-style pie chart summarizes the dominant-risk distribution, while every scoped account scoring at least 20 remains in the ranked, vertically scrollable list. Hovering a pie segment displays the risk description, account count, and percentage; keyboard focus shows the largest segment.
- Actionable Data Health posture tiles: Stale accounts, Missing lifecycle, SAS Key, Public Access, No Private Endpoint, No Service Principal, No GRS/GZRS, NSG/ASG linked, and Defunct Projects plus SFTP Enabled and AppInsights Data are buttons. Selecting one immediately loads every matching account for the active scope into a risk-sorted, vertically scrollable panel directly below the tiles on the Data Health page. Overview remains focused on estate capacity, cost, savings, risk concentration, and onboarding. The former standalone stale-account details panel is removed because Stale accounts now uses this common drilldown.
- Priority findings explains the Growth and Operations component scores. Operations is the 0–100 throttling/latency subscore; the right-side value is the overall weighted account risk score out of 100.
Manual and spreadsheet onboarding never create or change Azure Storage resources.
The Container Apps web workload uses one always-ready Consumption replica with
1 vCPU and 2 GiB memory. This keeps A2A task lookup and cancellation consistent with
the SDK's process-local task handler. Ingress targets port 8000, matching Uvicorn and
the Dockerfile, and probes allow 10 seconds for transient load. Private Function deployment
and Foundry smoke tests are intentionally decoupled from web startup so the public
Entra-protected UI cannot be blocked by a private dependency. Application version
0.1.0 remains unchanged.
Functional views
- Agent Investigation runs scoped deterministic tools, displays the full trust envelope and structured result, explains why every returned account was flagged, keeps evidence citations aligned with all unique returned accounts, offers a broad reusable catalog of operational/financial/platform questions, saves new authenticated questions for future sessions, and retains the latest eight investigations in-session.
- Savings Simulator models 1-100% tiering adoption, compares 10/25/50% baselines, ranks the top 20 candidates, and retains retrieval/retention caveats.
- Findings combines risk, robust growth anomalies, data freshness, and savings actions into a severity-sorted inbox. Total Findings, Data Freshness, Growth Anomaly, Risk, and Savings Action are clickable summary tiles; selecting one immediately filters the scrollable results panel below. The former duplicate filter-button row is removed.
- Data Health shows freshness coverage, connector/source status, lifecycle and assumed tier gaps, and a scrollable stale-account remediation list. For administrators, the visible Disabled status is a button: clicking it enables that connector, changes the status to Enabled, and reveals a clickable Run action. A completed pilot-fixture run changes the status to Healthy and shows synced/eligible counts and last-run time. Security posture cards expose SAS/shared keys, public access, missing private endpoints, missing service-principal access, non-GRS/GZRS replication, NSG/ASG links, defunct projects, missing last-access tags, SFTP-enabled endpoints, and Application Insights-linked storage.
- Data Health places Synthetic pilot, Azure CLI discovery, Azure Resource Graph, Blob Inventory, Azure Monitor Metrics, Cost Management exports, and Databricks system tables immediately after the global filters/reset row.
Tenant-wide admin discovery
Administrators see a dedicated Admin item in the left navigation. Its
Pull Tenant Wide Storage Account Details action uses Azure CLI argument arrays (never
a shell command string) to enumerate every enabled subscription visible to the
authenticated identity and run az storage account list for each subscription. Results
are ingested idempotently into the pilot inventory and upserted into the private Cosmos DB
storage-intelligence/storage-accounts container.
Configure the runtime with:
| Variable | Purpose | Default |
|---|---|---|
ADMIN_ROLE |
Entra app role required by admin endpoints | StorageIntelligence.Admin |
DISCOVERY_TENANT_IDS |
Optional comma-separated tenant IDs; empty means every tenant visible in the CLI account cache | empty |
DISCOVERY_USE_MANAGED_IDENTITY |
Run az login --identity with AZURE_CLIENT_ID |
true |
DISCOVERY_CRON |
Initial five-field discovery schedule | 0 */6 * * * |
DISCOVERY_SCHEDULE_PATH |
Persisted admin schedule configuration | data/discovery-schedule.json |
DISCOVERY_OUTPUT_PATH |
Scheduled CLI snapshot path | data/discovered-storage-accounts.json |
AZURE_CLI_PATH |
Azure CLI executable | az |
COSMOS_INVENTORY_ENABLED |
Persist manual and scheduled discovery results to Cosmos DB | false locally; true in Azure |
COSMOS_ENDPOINT |
Private Cosmos DB account endpoint | required when persistence is enabled |
COSMOS_DATABASE |
Inventory database name | storage-intelligence |
COSMOS_CONTAINER |
Storage-account container name | storage-accounts |
SAVED_QUESTIONS_PATH |
Atomic localhost question-library file when Cosmos is disabled | data/saved-agent-questions.json |
The managed identity or automation principal must be granted read-only access in every
target subscription/tenant. This project deliberately does not assign tenant-wide
Reader roles. Cross-tenant discovery works only after the identity is explicitly
authorized in each tenant.
Run discovery directly:
.\scripts\run-storage-discovery.ps1
Administrators can edit the five-field cron expression directly in the dashboard. The
schedule is validated with croniter, persisted atomically, and used by the in-process
scheduler after restart. The next execution time and common UTC cron examples are shown
in the role-gated Admin view. Provisioning creates the StorageIntelligence.Admin Entra
app role and assigns it to the deploying user. Each completed pull reports the number of
Cosmos DB upserts. Cosmos uses the web app's managed identity, a database-scoped built-in
Data Contributor assignment, /subscription_id partitioning, and no account keys.
For an external automation host, install the supplied six-hour fallback cron:
crontab config/storage-discovery.cron
The external scheduled command writes an atomic JSON snapshot. The in-app scheduler upserts the same account details to Cosmos DB. Neither path requests storage keys or mutates estate resources.
Discovery recognizes Databricks, Fabric Lakehouse, SAP, Azure Data Factory, and
Application Insights tag aliases plus native SFTP/HNS state.
It also reads Project/ProjectName, BusinessUnit, LastAccessedDate,
ProjectStatus/ProjectDefunct, UsesSASKeys, ServicePrincipalAccess,
NetworkSecurityGroup/NSG, and ApplicationSecurityGroup/ASG. Azure resource
properties supply shared-key access, public network/blob access, private endpoint state,
and replication SKU. Linked accounts appear in a dedicated dashboard section with compact
accessible badges.
The navigation footer displays © 2026 PepsiCo. All rights reserved. followed by tiny,
accessible Microsoft, Azure, and the supplied Azure AI Foundry image mark. The Foundry PNG
is committed under src/web/static/assets with a SHA-256 manifest.
Spreadsheet format
Upload an .xlsx workbook or UTF-8 .csv file with a header row and these columns:
| Column | Example |
|---|---|
name |
stfinancearchive01 |
tenant_id |
11111111-1111-4111-8111-111111111111 |
management_group |
mg-americas-platform |
subscription |
platform-prod |
environment |
Prod |
subsidiary |
PepsiCo Beverages North America |
region |
eastus2 |
tier |
Cool |
The importer accepts up to 10,000 rows or 5 MB per file. Friendly header aliases such
as storage_account_name, tenant, managementgroup, subscription_name,
environment/stage/env, Business unit, azure_region, and access_tier are
normalized automatically.
business_unit is a compatibility alias for subsidiary. Every hierarchy value must
exist in the pilot catalog; known synthetic subscriptions are validated against their
tenant, management group, environment, and subsidiary. Regions may use any code from the complete
Azure public-region selector; tiers must use an available access tier.
The versioned synthetic catalog contains exactly 339 subscriptions. Each subscription has
a deterministic UUID, tenant, management group, subsidiary, and one of Dev, QA,
Perf, or Prod. All 339 names appear in the global subscription selector.
Investigation question library
GET /api/questions returns the built-in and saved question catalog.
POST /api/questions accepts a new 3-500 character question, normalizes whitespace,
rejects case-insensitive duplicates, and caps the shared library at 100 custom questions.
Azure stores custom questions as saved-agent-question documents in the existing private
Cosmos container under the __agent_questions__ partition. Localhost uses the atomic JSON
path above. Saving a question does not execute it or mutate an Azure resource.
Local run
Python 3.13 is required. Node.js and npm are not used.
python -m venv .venv
.\.venv\Scripts\python -m pip install -e ".[test]"
$env:AUTH_DISABLED = "true"
.\.venv\Scripts\python -m uvicorn web.app:app --host 127.0.0.1 --port 8000
Open http://127.0.0.1:8000. Run acceptance tests with:
.\.venv\Scripts\python -m pytest
The language preference is stored in browser localStorage under
storage-intelligence-language. English (en) is the default; Spanish (es) updates the
document language and title. Built-in Spanish questions are canonicalized back to their
English deterministic intent before API submission, while the backend also recognizes
common Spanish intent phrases for newly authored questions.
Architecture
src/storage_intelligence: synthetic generator, connectors, analytics, query router.src/protocols/service.py: protocol-neutral read-only agent facade.src/protocols/mcp_server.py: MCP tools, resource, prompt, HTTP mount, and stdio entry point.src/protocols/a2a_server.py: A2A Agent Card, JSON-RPC/REST routes, task executor, and artifacts.src/protocols/README.md: code-adjacent MCP/A2A endpoint, authentication, and usage reference.src/web: FastAPI and vendored React 18.3.1 browser UI.src/function_app.py: private OpenAPI tools and durable fan-out/fan-in collection.src/agent: Foundry instructions, OpenAPI contract, deploy/invoke scripts, and evals.infra/foundry: official template 19 baseline and unmodified supporting modules.infra/functions-base: preserved official Flex Consumption base modules.infra: composed workload Bicep and AZD parameters.
See product specification, architecture, and protocol integration.
Azure workflow
The approved .azure/deployment-plan.md is the source of truth. Deployment uses:
azd env new storage-intel-pilot
azd env set AZURE_LOCATION swedencentral
azd env set AZURE_SUBSCRIPTION_ID c82406dd-f84c-42df-9586-c6f02abda6df
azd provision --preview --no-prompt
azd provision --no-prompt
azd deploy --no-prompt
The deployment scripts create or reuse secretless Entra application registrations,
enable ID-token issuance for Container Apps Easy Auth, deploy the web image and Functions
package, then create the Foundry prompt-agent version. Easy Auth accepts both the
application client ID and its api:// identifier URI as token audiences.
Production connectors remain disabled unless their explicit flags and least-privilege
roles are configured.
Cost caveats
Private Foundry Standard requires fixed-cost AI Search Standard and Premium ACR. Cosmos DB, monitoring ingestion, model tokens, private endpoints, and Container Apps add usage-based costs. The pilot avoids estate API and Databricks query charges by using synthetic data.
推荐服务器
Baidu Map
百度地图核心API现已全面兼容MCP协议,是国内首家兼容MCP协议的地图服务商。
Playwright MCP Server
一个模型上下文协议服务器,它使大型语言模型能够通过结构化的可访问性快照与网页进行交互,而无需视觉模型或屏幕截图。
Magic Component Platform (MCP)
一个由人工智能驱动的工具,可以从自然语言描述生成现代化的用户界面组件,并与流行的集成开发环境(IDE)集成,从而简化用户界面开发流程。
Audiense Insights MCP Server
通过模型上下文协议启用与 Audiense Insights 账户的交互,从而促进营销洞察和受众数据的提取和分析,包括人口统计信息、行为和影响者互动。
VeyraX
一个单一的 MCP 工具,连接你所有喜爱的工具:Gmail、日历以及其他 40 多个工具。
graphlit-mcp-server
模型上下文协议 (MCP) 服务器实现了 MCP 客户端与 Graphlit 服务之间的集成。 除了网络爬取之外,还可以将任何内容(从 Slack 到 Gmail 再到播客订阅源)导入到 Graphlit 项目中,然后从 MCP 客户端检索相关内容。
Kagi MCP Server
一个 MCP 服务器,集成了 Kagi 搜索功能和 Claude AI,使 Claude 能够在回答需要最新信息的问题时执行实时网络搜索。
e2b-mcp-server
使用 MCP 通过 e2b 运行代码。
Neon MCP Server
用于与 Neon 管理 API 和数据库交互的 MCP 服务器
Exa MCP Server
模型上下文协议(MCP)服务器允许像 Claude 这样的 AI 助手使用 Exa AI 搜索 API 进行网络搜索。这种设置允许 AI 模型以安全和受控的方式获取实时的网络信息。