/flux-pipeline

FluxData & Databases

Builds a data pipeline from source to destination: extraction from APIs, databases, or files; transformation with type coercion, deduplication, and business logic; loading into the target store; with error handling, retry logic, dead letter queues, and scheduled or event-driven execution.

Install

This skill

Install Flux Pipeline

1. Add to marketplace

$ claude plugin marketplace add tonone-ai/tonone

2. Install this skill

$ claude plugin install flux-pipeline@tonone-ai

The agent

Install Flux

1. Add to marketplace

$ claude plugin marketplace add tonone-ai/tonone

2. Install Flux

$ claude plugin install flux@tonone-ai

See all Flux skills

Want all 31 agents across both teams?

Full installation guide

Invoke this skill

Command|$ /flux-pipeline

When to use

When moving data between systems on a schedule. When building a data warehouse feed or analytics pipeline. When an existing manual data export and import process needs to be automated and made reliable. When syncing data from an external vendor API into your own data store.

Deep dive

AI Data Pipeline ETL Builder

Most data pipelines are scripts that work until they don't. /flux-pipeline builds extract-transform-load with retries, dead letters, dedupe, and scheduled execution.

Read the article

More from Flux

All Flux skills

FluxData

/flux-schema

Designs a database schema with proper normalization, appropriate denormalization for high-frequency read paths, indexes for the expected query patterns, constraints that enforce data integrity at the database level, and migration files ready to run. Explains the reasoning behind every design decision.

When designing a new data model from scratch and w…

FluxData

/flux-migrate

Writes zero-downtime database migrations: reversible steps designed to run while the application is serving traffic, safe for concurrent reads and writes during the migration window, with an explicit rollback plan for every step. Handles column renames, backfills, and index creation on large tables safely.

Whenever making schema changes on a live productio…

FluxData

/flux-query

Optimizes slow database queries by reading execution plans, identifying missing indexes, rewriting inefficient joins and subqueries, and suggesting caching strategies where appropriate. Explains why each change helps so you can apply the same reasoning to future query problems.

When specific queries are slow in production or st…

Ready to use Flux Pipeline?

Get Started Back to Marketplace