Data Pipeline
Skill Profile
(Select at least one profile to enable specific modules)
Overview
This skill provides comprehensive guidance and best practices for implementation. It enables teams to achieve reliable, maintainable, and scalable solutions.
When to use / When NOT to use
- ✅ Use when: Implementing this capability in your project
- ✅ Use when: Need to follow established patterns and conventions
- ❌ Avoid when: The requirements don't match this skill's scope
- ❌ Avoid when: Simpler alternatives would suffice
Why This Matters
- Reduces Technical Debt: Following established patterns prevents costly rework
- Increases System Stability: Proper implementation reduces bugs and downtime
- Improves Team Velocity: Clear guidance helps teams work more efficiently
- Reduces Maintenance Costs: Well-structured code is easier to maintain
- Ensures Investment Confidence: Following standards gives confidence in technical decisions
Core Concepts & Rules
1. Core Principles
- Follow established patterns and conventions
- Maintain consistency across codebase
- Document decisions and trade-offs
2. Implementation Guidelines
- Start with the simplest viable solution
- Iterate based on feedback and requirements
- Test thoroughly before deployment
Inputs / Outputs / Contracts
- Inputs:
- Requirements and specifications
- Existing codebase and architecture
- Team context and constraints
- Entry Conditions:
- Project repository initialized
- Development environment set up
- Required dependencies installed
- Outputs:
- Implementation code and documentation
- Test cases and test results
- Deployment artifacts
- Artifacts Required (Deliverables):
- Source code changes
- Updated documentation
- Test coverage reports
- Acceptance Evidence:
- All tests passing
- Code review approved
- Documentation updated
- Success Criteria:
- Meets all functional requirements
- Follows established patterns
- Test coverage ≥ 80%
Skill Composition
- Depends on: None
- Compatible with: None
- Conflicts with: None
- Related Skills: None
Overview
Comprehensive guide to building data pipelines, including ETL/ELT patterns, batch and streaming pipelines, and pipeline orchestration
Quick Start / Implementation Example
- Review requirements and constraints
- Set up development environment
- Implement core functionality following patterns
- Write tests for critical paths
- Run tests and fix issues
- Document any deviations or decisions
# Example implementation following best practices
def example_function():
# Your implementation here
pass
Assumptions / Constraints / Non-goals
- Assumptions:
- Development environment is properly configured
- Required dependencies are available
- Team has basic understanding of domain
- Constraints:
- Must follow existing codebase conventions
- Time and resource limitations
- Compatibility requirements
- Non-goals:
- This skill does not cover edge cases outside scope
- Not a replacement for formal training
Compatibility & Prerequisites
- Supported Versions:
- Python 3.8+
- Node.js 16+
- Modern browsers (Chrome, Firefox, Safari, Edge)
- Required AI Tools:
- Code editor (VS Code recommended)
- Testing framework appropriate for language
- Version control (Git)
- Dependencies:
- Language-specific package manager
- Build tools
- Testing libraries
- Environment Setup:
.env.example keys: API_KEY, DATABASE_URL (no values)
Test Scenario Matrix (QA Strategy)
| Type |
Focus Area |
Required Scenarios / Mocks |
| Unit |
Core Logic |
Must cover primary logic and at least 3 edge/error cases. Target minimum 80% coverage |
| Integration |
DB / API |
All external API calls or database connections must be mocked during unit tests |
| E2E |
User Journey |
Critical user flows to test |
| Performance |
Latency / Load |
Benchmark requirements |
| Security |
Vuln / Auth |
SAST/DAST or dependency audit |
| Frontend |
UX / A11y |
Accessibility checklist (WCAG), Performance Budget (Lighthouse score) |
Technical Guardrails & Security Threat Model
1. Security & Privacy (Threat Model)
- Top Threats: Injection attacks, authentication bypass, data exposure
2. Performance & Resources
3. Architecture & Scalability
4. Observability & Reliability
Agent Directives & Error Recovery
(ข้อกำหนดสำหรับ AI Agent ในการคิดและแก้ปัญหาเมื่อเกิดข้อผิดพลาด)
- Thinking Process: Analyze root cause before fixing. Do not brute-force.
- Fallback Strategy: Stop after 3 failed test attempts. Output root cause and ask for human intervention/clarification.
- Self-Review: Check against Guardrails & Anti-patterns before finalizing.
- Output Constraints: Output ONLY the modified code block. Do not explain unless asked.
Definition of Done (DoD) Checklist
Anti-patterns / Pitfalls
- ⛔ Don't: Log PII, catch-all exception, N+1 queries
- ⚠️ Watch out for: Common symptoms and quick fixes
- 💡 Instead: Use proper error handling, pagination, and logging
Reference Links & Examples
- Internal documentation and examples
- Official documentation and best practices
- Community resources and discussions
Versioning & Changelog
- Version: 1.0.0
- Changelog:
- 2026-02-22: Initial version with complete template structure
Converted and distributed by TomeVault — claim your Tome and manage your conversions.
1---2name: amnadtaowsoam-cerebraskills-data-pipeline3description: Data Pipeline4---56# Data Pipeline78## Skill Profile9*(Select at least one profile to enable specific modules)*10- [ ] **DevOps**11- [x] **Backend**12- [ ] **Frontend**13- [ ] **AI-RAG**14- [ ] **Security Critical**1516## Overview17This skill provides comprehensive guidance and best practices for implementation. It enables teams to achieve reliable, maintainable, and scalable solutions.1819### When to use / When NOT to use20* ✅ **Use when**: Implementing this capability in your project21* ✅ **Use when**: Need to follow established patterns and conventions22* ❌ **Avoid when**: The requirements don't match this skill's scope23* ❌ **Avoid when**: Simpler alternatives would suffice242526## Why This Matters27- **Reduces Technical Debt**: Following established patterns prevents costly rework28- **Increases System Stability**: Proper implementation reduces bugs and downtime29- **Improves Team Velocity**: Clear guidance helps teams work more efficiently30- **Reduces Maintenance Costs**: Well-structured code is easier to maintain31- **Ensures Investment Confidence**: Following standards gives confidence in technical decisions323334## Core Concepts & Rules3536### 1. Core Principles37- Follow established patterns and conventions38- Maintain consistency across codebase39- Document decisions and trade-offs4041### 2. Implementation Guidelines42- Start with the simplest viable solution43- Iterate based on feedback and requirements44- Test thoroughly before deployment454647## Inputs / Outputs / Contracts4849* **Inputs**:50 - Requirements and specifications51 - Existing codebase and architecture52 - Team context and constraints53* **Entry Conditions**:54 - Project repository initialized55 - Development environment set up56 - Required dependencies installed57* **Outputs**:58 - Implementation code and documentation59 - Test cases and test results60 - Deployment artifacts61* **Artifacts Required (Deliverables)**:62 - Source code changes63 - Updated documentation64 - Test coverage reports65* **Acceptance Evidence**:66 - All tests passing67 - Code review approved68 - Documentation updated69* **Success Criteria**:70 - Meets all functional requirements71 - Follows established patterns72 - Test coverage ≥ 80%737475## Skill Composition76* **Depends on**: None77* **Compatible with**: None78* **Conflicts with**: None79* **Related Skills**: None8081# Overview82Comprehensive guide to building data pipelines, including ETL/ELT patterns, batch and streaming pipelines, and pipeline orchestration8384## Quick Start / Implementation Example85861. Review requirements and constraints872. Set up development environment883. Implement core functionality following patterns894. Write tests for critical paths905. Run tests and fix issues916. Document any deviations or decisions9293```python94# Example implementation following best practices95def example_function():96 # Your implementation here97 pass98```99100101## Assumptions / Constraints / Non-goals102103* **Assumptions**:104 - Development environment is properly configured105 - Required dependencies are available106 - Team has basic understanding of domain107* **Constraints**:108 - Must follow existing codebase conventions109 - Time and resource limitations110 - Compatibility requirements111* **Non-goals**:112 - This skill does not cover edge cases outside scope113 - Not a replacement for formal training114115116## Compatibility & Prerequisites117118* **Supported Versions**:119 - Python 3.8+120 - Node.js 16+121 - Modern browsers (Chrome, Firefox, Safari, Edge)122* **Required AI Tools**:123 - Code editor (VS Code recommended)124 - Testing framework appropriate for language125 - Version control (Git)126* **Dependencies**:127 - Language-specific package manager128 - Build tools129 - Testing libraries130* **Environment Setup**:131 - `.env.example` keys: `API_KEY`, `DATABASE_URL` (no values)132133134## Test Scenario Matrix (QA Strategy)135136| Type | Focus Area | Required Scenarios / Mocks |137| :--- | :--- | :--- |138| **Unit** | Core Logic | Must cover primary logic and at least 3 edge/error cases. Target minimum 80% coverage |139| **Integration** | DB / API | All external API calls or database connections must be mocked during unit tests |140| **E2E** | User Journey | Critical user flows to test |141| **Performance** | Latency / Load | Benchmark requirements |142| **Security** | Vuln / Auth | SAST/DAST or dependency audit |143| **Frontend** | UX / A11y | Accessibility checklist (WCAG), Performance Budget (Lighthouse score) |144145146## Technical Guardrails & Security Threat Model147148### 1. Security & Privacy (Threat Model)149* **Top Threats**: Injection attacks, authentication bypass, data exposure150- [ ] **Data Handling**: Sanitize all user inputs to prevent Injection attacks. Never log raw PII151- [ ] **Secrets Management**: No hardcoded API keys. Use Env Vars/Secrets Manager152- [ ] **Authorization**: Validate user permissions before state changes153154### 2. Performance & Resources155- [ ] **Execution Efficiency**: Consider time complexity for algorithms156- [ ] **Memory Management**: Use streams/pagination for large data157- [ ] **Resource Cleanup**: Close DB connections/file handlers in finally blocks158159### 3. Architecture & Scalability160- [ ] **Design Pattern**: Follow SOLID principles, use Dependency Injection161- [ ] **Modularity**: Decouple logic from UI/Frameworks162163### 4. Observability & Reliability164- [ ] **Logging Standards**: Structured JSON, include trace IDs `request_id`165- [ ] **Metrics**: Track `error_rate`, `latency`, `queue_depth`166- [ ] **Error Handling**: Standardized error codes, no bare except167- [ ] **Observability Artifacts**:168 - **Log Fields**: timestamp, level, message, request_id169 - **Metrics**: request_count, error_count, response_time170 - **Dashboards/Alerts**: High Error Rate > 5%171172173## Agent Directives & Error Recovery174*(ข้อกำหนดสำหรับ AI Agent ในการคิดและแก้ปัญหาเมื่อเกิดข้อผิดพลาด)*175176- **Thinking Process**: Analyze root cause before fixing. Do not brute-force.177- **Fallback Strategy**: Stop after 3 failed test attempts. Output root cause and ask for human intervention/clarification.178- **Self-Review**: Check against Guardrails & Anti-patterns before finalizing.179- **Output Constraints**: Output ONLY the modified code block. Do not explain unless asked.180181182## Definition of Done (DoD) Checklist183184- [ ] Tests passed + coverage met185- [ ] Lint/Typecheck passed186- [ ] Logging/Metrics/Trace implemented187- [ ] Security checks passed188- [ ] Documentation/Changelog updated189- [ ] Accessibility/Performance requirements met (if frontend)190191192## Anti-patterns / Pitfalls193194* ⛔ **Don't**: Log PII, catch-all exception, N+1 queries195* ⚠️ **Watch out for**: Common symptoms and quick fixes196* 💡 **Instead**: Use proper error handling, pagination, and logging197198199## Reference Links & Examples200201* Internal documentation and examples202* Official documentation and best practices203* Community resources and discussions204205206## Versioning & Changelog207208* **Version**: 1.0.0209* **Changelog**:210 - 2026-02-22: Initial version with complete template structure211212---213> Converted and distributed by [TomeVault](https://tomevault.io/claim/amnadtaowsoam) — claim your Tome and manage your conversions.214<!-- tomevault:4.0:skill_md:2026-04-13 -->