mongodb/ASP_example

최근 기록된 소스 활동: 2026년 6월 9일 19:40

SkillsMP 카탈로그 업데이트: 2026년 11월 5일 19:57

수집된 skills: 1

GitHub 스타: 10
GitHub 포크: 4

AI 어시스턴트로 설치

이 프롬프트를 복사해 사용 중인 AI 어시스턴트에 입력하세요.

Follow https://skillsmp.com/skill-install/prompt.md to install Agent Skills from https://github.com/mongodb/ASP_example.

저장소 README

README 원본 파일: README.md

README 원본 보기

README 전체 펼치기

# Atlas Stream Processing Example Repo This repository serves as both a the human readable corpus of examples, but also a RAG optimized repository for code generation in AI development scenarios. This repository is the most up to date, has the most detailed examples, and context and is generated and vetting by the MongoDB internal PM and Engineering teams. ## Canonical Stream Processor Format **All stream processor definitions in this repository follow a standardized JSON format:** ```json { "name": "processor_name", "pipeline": [ { "$source": { ... } }, { "$stage": { ... } }, ... ] } ``` ### Why This Format? - ✅ **Portable**: Works consistently across MongoDB Shell, Admin API, Terraform, and all tools - ✅ **Version Control Friendly**: JSON files can be tracked, diffed, and reviewed - ✅ **Separation of Concerns**: Configuration (name) separate from logic (pipeline) - ✅ **Reusable**: Easy to share, import, and adapt examples - ✅ **AI-Friendly**: Clear structure for code generation and RAG ### Usage Examples **Ephemeral (testing/development):** ```javascript const def = JSON.parse(fs.readFileSync('processor.json', 'utf8')) sp.process(def.pipeline) ``` **Persistent (production):** ```javascript const def = JSON.parse(fs.readFileSync('processor.json', 'utf8')) sp.createStreamProcessor(def.name, def.pipeline) sp[def.name].start() ``` ### Best Practices - Store processor definitions as `.json` files - Use descriptive names that indicate purpose (e.g., `kafka_to_mongo_rollup`) - Use `connectionName` instead of hardcoded connection strings - Include sink stages (`$merge`, `$emit`) for persistent processors - Pipelines without sinks only work with `sp.process()` (ephemeral mode) ## Contributing We encourage collaboration, anyone can open a pull request on this repository. Because this repository is a source for AI generated code we ask some simple best practices be followed: * Keep example files short and name them descriptively (e.g., window_join_example.js, not sample2.js). * Add thorough comments and docstrings in the sample repo * **Use the canonical `{name, pipeline}` JSON format for all stream processor definitions** ## Structure The structure for this repository is: * [Quickstarts](/quickstarts) - Short, canonical examples to get started with Atlas Stream Processing. * [Code snippets](/code_snipplets) are example MQL solutions to specific problems. * [Example procesors](/example_processors) are end to end Atlas Stream Processing Examples. * [Terraform](/terraform) examples, explain Terraform usage with Atlas Stream Processing. * [DB examples](/db) are examples for the MongoDB database in relation to Atlas Stream Processing. * [Demo](/demo) is various self-contained demos.

저장소 README를 불러오는 중…

이 저장소의 skills

소프트웨어 개발자

직업 카테고리 1개 · 100% 분류됨

skill

직업 분류

설명

업데이트

kafka-to-asp

소프트웨어 개발자

Converts MongoDB Kafka managed connector configurations (MongoDbAtlasSource / MongoDbAtlasSink) to equivalent Atlas Stream Processing processors. One-time migration workflow: reads connector JSON, validates it, maps fields to ASP pipeline stages, and creates…

원문 언어: 영어

2026-06-09

수집된 skill 1개 중 1개를 표시합니다.