Engineered with formal verification principles, strict type validation, and native production readiness.
WPipe Steps provides a comprehensive library of modular components ("Steps") that can be easily integrated into your WPipe pipelines. Instead of reinventing the wheel for common tasks like API calls, database queries, or notifications, simply import and use a pre-built step.
## 📂 Professional Structure
| `wpipe_steps.connectivity` | **HttpRequestStep**: REST client with automatic retries.
**GraphQLQueryStep**: GraphQL executor.
**WebhookTriggerStep**: Webhook notifier.
**SftpTransferStep**: SFTP transfer (upload/download).
**RSSParserStep**: RSS/Atom feed parser.
**OAuth2AuthStep**: OAuth2 token manager. |
| `wpipe_steps.database` | **MySQLQueryStep**: MySQL SQL executor.
**Redis Steps**: Full Redis support via wredis (bitmaps, hash, sets, sorted sets, streams, pub/sub, queue, geo, hyperloglog, transactions, pipeline, cache decorators) - sync/async.
**MongoInsertStep**: MongoDB document inserter.
**SQLiteAuditStep**: Local SQLite audit logger.
**ClickHouseBulkStep**: ClickHouse massive data inserter.
**CassandraWriteStep**: Cassandra data writer. |
| `wpipe_steps.security` | **Fail2BanCheckStep**: IP ban status verifier.
**NmapScanStep**: Port scanning discovery.
**ShodanSearchStep**: Network intelligence search.
**HashGeneratorStep**: Hash generator.
**VaultSecretsStep**: Vault secrets retriever.
**WafFilterStep**: SQLi/XSS input filter. |
| `wpipe_steps.infrastructure` | **S3BucketUploadStep**: AWS S3 file uploader. |
Designed to eliminate low-level plumbing and cognitive friction, allowing engineers to build reliable solutions in minutes.
from wpipe import Pipeline
from wpipe_steps.connectivity import HttpRequestStep
# Create a pipeline
pipeline = Pipeline(pipeline_name="fetch_api")
# Use a pre-built step
pipeline.set_steps([
HttpRequestStep.as_step(
name="fetch_user",
url="https://api.example.com/user/1",
method="GET"
)
])
pipeline.run({})
wpipe-steps is an integral component within the Wisrovi Binary Universe, engineered by William Steve Rodriguez Villamizar to unify high-throughput distributed systems, formal verification, and autonomous agent orchestration.