atlas-stream-processing

Create and manage MongoDB Atlas data streaming pipelines for real-time processing.

166|30|Updated Feb 26, 2026
One-click install
npx skills add https://github.com/mongodb/agent-skills --skill atlas-stream-processing-mongodb
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: atlas-stream-processing
Source: https://github.com/mongodb/agent-skills/tree/main/skills/atlas-stream-processing
Command: npx skills add https://github.com/mongodb/agent-skills --skill atlas-stream-processing-mongodb

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes scripts (resource) and references (resource) components.

What problem does it solve?

This Skill enables users to build, operate, and debug MongoDB Atlas Stream Processing (ASP) pipelines efficiently for streaming data workloads.

Core Features & Use Cases

  • Pipeline Management: Provision, start, modify, and troubleshoot Atlas Stream Processing pipelines.
  • Resource Integration: Connect to Kafka, Atlas clusters, S3, HTTPS endpoints, and Lambda functions for comprehensive streaming solutions.
  • Use Case: Automate real-time analytics for IoT device data by configuring streams, setting up windowed aggregations, and routing alerts through Atlas or external APIs.

Quick Start

Use the atlas-stream-processing skill to create a streaming pipeline that detects anomalies and writes alerts to the Atlas database.

Frequently Asked Questions about atlas-stream-processing

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I build a real-time data pipeline with MongoDB Atlas and Kafka?

You can create and manage Atlas Stream Processing pipelines to connect Kafka topics with Atlas clusters, enabling continuous real-time data ingestion, processing, and analytics.

Can I route streaming data to HTTP APIs and cloud storage from MongoDB Atlas?

Yes, Atlas Stream Processing pipelines support connecting to HTTP APIs, cloud storage, and serverless functions, allowing you to route processed streaming data and alerts to external endpoints.

Do I need an MCP server with Atlas API credentials to process streaming data?

Yes, managing Atlas Stream Processing pipelines requires an MCP server configured with proper Atlas API credentials and resource configurations to authenticate and execute stream workflows.

What is the best way to set up real-time anomaly detection for IoT data in MongoDB?

The best way to set up real-time anomaly detection for IoT data is to configure Atlas Stream Processing pipelines that perform windowed aggregations on streaming data and route anomaly alerts to the Atlas database or external APIs.

How do I troubleshoot a MongoDB Atlas stream processing pipeline that is not working?

To troubleshoot an Atlas Stream Processing pipeline that is not working, you can operate and debug the stream workflows by verifying connections to Kafka, Atlas clusters, and HTTP APIs to identify and resolve processing failures.