MCP For Claude Marketplace
PipeStream

PipeStream MCP Connector for Claude

F

Streamline real-time data flows — create streams, publish events, and fetch historical data directly from your AI agent.

4 tools Official Updated Jun 28, 2026 Official Vinkius Partner
More Details Connect to Claude

Connect PipeStream to your AI agent to manage high-throughput data streams and event logging through natural language.

What you can do

  • Stream Management — List all active data channels and create new streams with custom retention policies.
  • Event Publishing — Send JSON payloads and events to specific streams instantly.
  • Data Retrieval — Fetch historical events from any stream with support for pagination and time-based filtering.
  • Real-time Monitoring — Inspect the flow of data across your infrastructure without leaving your chat interface.

How it works

  1. Subscribe to this server
  2. Enter your PipeStream API Key
  3. Start managing your data pipelines from Claude, Cursor, or any MCP-compatible client

Who is this for?

  • DevOps Engineers — quickly check event logs and stream statuses during incident response.
  • Data Scientists — publish experimental results or fetch sample data for analysis directly in-context.
  • Backend Developers — verify event delivery and create new testing channels without switching to a CLI or dashboard.
event-streamingreal-time-datadata-pipelinesloggingapi-integration

4 tools expose this connector's capabilities to your AI agent.

create_stream

Create a new stream

fetch_events

Fetch events from a stream

list_streams

List all active streams

publish_event

Publish an event to a stream

See how to talk to your AI agent using PipeStream.

List all my active PipeStream channels.

I've retrieved your active streams. You have 3 streams: 'user-signups' (ID: st_1), 'system-logs' (ID: st_2), and 'payment-events' (ID: st_3).

Create a new stream named 'production-alerts' with 48 hours retention.

Successfully created the stream 'production-alerts'. It is now active with a 48-hour data retention policy. The assigned Stream ID is st_99.

Fetch the last 5 events from stream st_1.

I've fetched the 5 most recent events from 'user-signups'. They include payload data for user registrations from the last hour. Would you like me to summarize the data?

Yes! Use the `create_stream` tool. You can specify the name and the `retention_hours` to define how long data should be stored in that logical channel.

Related Connectors

ZC

Zoho CRM Service MCP

7 tools Official

Manage support cases and knowledge base solutions — customer service operations through Zoho CRM.

A+ View details →
ED

Eurostat Discovery — Dataset Catalog Explorer MCP

3 tools Official

Explore Eurostat's catalog of 7,000+ official datasets: search by keyword, inspect dataset dimensions and code lists, and query any dataset with flexible filters — the master key to all European Union statistics.

A+ View details →
TR

Transloadit MCP

12 tools Official

Versatile file uploading and processing API.

A+ View details →
ZI

Zoho Inventory MCP

9 tools Official

Manage inventory items, sales orders, and stock levels via the Zoho Inventory API.

A+ View details →