atlas-stream-processing

What problem does it solve?

This skill automates the end‑to‑end management of MongoDB Atlas Stream Processing workflows, eliminating the need for manual API calls to provision workspaces, configure data sources and sinks, and control processor lifecycles.

Core Features & Use Cases

• Workspace provisioning – create and configure ASP workspaces with appropriate tier and region settings.
• Connection management – set up and validate Kafka, Atlas clusters, S3, HTTPS, and Lambda connections for both source and sink roles.
• Processor lifecycle – build, start, stop, modify, and safely teardown processors with built‑in diagnostics and tier‑sizing recommendations.
• Use case example – Build a real‑time fraud detection pipeline that reads from a Kafka topic, applies tumbling‑window aggregation, and writes alerts to an Atlas collection.

Quick Start

Create a new workspace, add a Kafka connection, build a simple $source‑$merge processor, and start it.