Aria_moltbot aria-datapipeline

📊 Data pipeline management and ETL operations for Data Architect

install

source · Clone the upstream repo

git clone https://github.com/Najia-afk/Aria_moltbot

Claude Code · Install into ~/.claude/skills/

T=$(mktemp -d) && git clone --depth=1 https://github.com/Najia-afk/Aria_moltbot "$T" && mkdir -p ~/.claude/skills && cp -r "$T/aria_skills/data_pipeline" ~/.claude/skills/najia-afk-aria-moltbot-aria-datapipeline && rm -rf "$T"

manifest: aria_skills/data_pipeline/SKILL.md

source content

aria-datapipeline

Data pipeline management and ETL. Define pipelines, validate data, infer schemas, transform data, and run quality checks.

Usage

exec python3 /app/skills/run_skill.py data_pipeline <function> '<json_args>'

Functions

define_pipeline

Define a new data pipeline.

exec python3 /app/skills/run_skill.py data_pipeline define_pipeline '{"name": "etl_daily", "steps": [{"type": "extract"}]}'

validate_data

Validate data against a schema.

exec python3 /app/skills/run_skill.py data_pipeline validate_data '{"data": [...], "schema": {...}}'

infer_schema

Infer schema from data samples.

exec python3 /app/skills/run_skill.py data_pipeline infer_schema '{"data": [...]}'

transform_data

Apply transformations to data.

exec python3 /app/skills/run_skill.py data_pipeline transform_data '{"data": [...], "transforms": [...]}'

data_quality_check

Run data quality checks.

exec python3 /app/skills/run_skill.py data_pipeline data_quality_check '{"data": [...]}'