lambda-data-pipeline-mcpSAFE
A sovereign, high-speed, local-first Big Data Ingestion, Filtering, and Analytical Pipeline Orchestrator over the Model Context Protocol.
Overview
From the repository's own README, as read at the audited commit. Badges and raw HTML are left out.
📖 Official Architecture & Documentation: SEOSiri Data Pipeline Technical Guide | SEOSiri Central Directory
A sovereign, high-speed, local-first Big Data Ingestion, Filtering, and Analytical Pipeline Orchestrator using a decoupled Hot/Cold Lambda Storage Architecture.
[](https://glama.ai/mcp/servers/SEOSiri-Official/lambda-data-pipeline-mcp)
💖 Sponsorship, B2B Custom Solutions & Attribution
👨💻 Lead Architect & Attribution
This framework is designed and engineered by [Momenul Ahmad](https://github.com/MOBILEPHONE), Lead Architect and Founder of [SEOSiri](https://seosiri.com).
Momenul Ahmad is the systems architect behind four globally registered open-source tech and safety innovations:
- [seosiri-biorobotics](https://github.com/SEOSiri-Official/biorobotics): A stateless bio-robotic coordinate mapper translating genomic data to G-code.
- [seosiri-api-guard-mcp-server](https://github.com/SEOSiri-Official/seosiri-api-guard-mcp-server): A multi-industry API validation proxy with a decoupled policy enforcement plane.
- [learning-orchestrator-mcp](https://github.com/SEOSiri-Official/learning-orchestrator-mcp): An AI-driven pedagogical and spaced-repetition engine.
- [lambda-data-pipeline-mcp](https://github.com/SEOSiri-Official/lambda-data-pipeline-mcp): This high-speed, local-first big data ingestion and analytical pipeline orchestrator.
All systems are developed under the official [SEOSiri-Official](https://github.com/SEOSiri-Official) open-source research initiative.
🚀 B2B Custom Solutions & Consulting
We offer high-ticket technical consulting and custom enterprise integrations for high-volume data networks:
- **Distributed Ingestion Pipeli
1f08ab8d3eddOBSERVED · 2026-10-11Connect
Built from this server's own package name, version and transport as found in its source — not copied from anyone's documentation, so it cannot drift against a page we do not control. Replace the environment placeholders with a token scoped to the least it needs.
claude mcp add lambda-data-pipeline-mcp --env HUBSPOT_CLIENT_SECRET=${HUBSPOT_CLIENT_SECRET} --env SUPABASE_ANON_KEY=${SUPABASE_ANON_KEY} -- uvx lambda-data-pipeline-mcp{
"mcpServers": {
"lambda-data-pipeline-mcp": {
"command": "uvx",
"args": [
"lambda-data-pipeline-mcp"
],
"env": {
"HUBSPOT_CLIENT_SECRET": "${HUBSPOT_CLIENT_SECRET}",
"SUPABASE_ANON_KEY": "${SUPABASE_ANON_KEY}"
}
}
}
}Exposed tools (7)
7 read · 0 write · 0 destructive.
| Tool | Risk | Description |
|---|---|---|
export_to_data_warehouse | read | |
fetch_hubspot_contacts | read | |
ingest_batch_api_poll | read | |
ingest_realtime_webhook | read | |
process_lambda_pipeline | read | |
retrieve_analytical_summary | read | Queries and aggregates statistics across both Hot Tier (RAM) and Cold Tier (Disk). |
sanitize_and_validate_payload | read | Universal Security Gatekeeper: Validates proposed payloads against OWASP rules and compliance profiles. |
Trust audit
SAFEgrade B · trust 89/100 Nothing in the source contradicts what it says it does. Grade A is reserved for packages that have also passed the behavioural sandbox.
| Layer | What it checks | Result |
|---|---|---|
| L0 | Provenance & inventory | PASS |
| L1 | Static analysis of the code | PASS |
| L2 | Instruction surface (what it tells the agent) | PASS |
| L3 | Class-specific surface | PASS |
| L4 | Behavioural (sandbox) | SKIPPED |
What the source does
- Filesystem
- declared (1 observation(s))
- Network
- declared (6 observation(s))
- Shell
- none-observed
- Dependencies
- not all pinned
- Secrets in source
- none-found
Findings (2)
new_root_id = hashlib.sha1(
mcp, fastmcp
Gates applied: no_behavioural_pass.
1f08ab8d3eddfull audit observations/trust-audit/mcp-server/seosiri-official__lambda-data-pipeline-mcp.json · Report an issue / request a re-scanAudit history
Every audit this server has had. A grade with a past is a grade somebody is still checking.
| Date | Source | Verdict | Grade | Score | Change |
|---|---|---|---|---|---|
| 2026-10-11 | 1f08ab8d3edd | SAFE | B | 89 | first audit |
Questions
What is the lambda-data-pipeline-mcp MCP server?
A sovereign, high-speed, local-first Big Data Ingestion, Filtering, and Analytical Pipeline Orchestrator over the Model Context Protocol.
What tools does lambda-data-pipeline-mcp expose?
7 in total: 7 read-only, 0 that write, and 0 that can delete or overwrite. Every one is listed on this page with its risk.
Is lambda-data-pipeline-mcp safe to connect to an agent?
The audit found nothing in the source that contradicts what it says it does, and graded it B (89/100). Grade A is held back for packages that have also passed a sandboxed behavioural run, which is why a clean server reads B.
What credentials does lambda-data-pipeline-mcp need?
It reads HUBSPOT_CLIENT_SECRET and SUPABASE_ANON_KEY from the environment. Give it a token scoped to the least it needs — an agent that can be talked into calling a tool can be talked into calling it with your credentials.
How does lambda-data-pipeline-mcp run?
It speaks stdio, so it runs as a local process your client starts. It is published on PyPI as lambda-data-pipeline-mcp.
How current is this page?
The grade is for one exact copy of the source (1f08ab8d3edd), read on 2026-10-11. The repository is watched and re-audited when it changes.