npipeline 

High-performance, streaming data pipelines for .NET

Extensible storage abstraction layer for NPipeline - supports pluggable storage providers (file system, cloud storage, etc.)

Storage provider abstractions and implementations for NPipeline - interfaces, models, and base classes for storage operations

Testing utilities for NPipeline including in-memory nodes, test harness, and assertion helpers

CSV source and sink nodes for NPipeline using CsvHelper - read and write CSV files with configurable options

Microsoft.Extensions.DependencyInjection integration for NPipeline - enables automatic node registration and lifetime management

High-performance parallel execution strategies for NPipeline with configurable backpressure and queue policies

AwesomeAssertions extensions for NPipeline testing - adds assertion methods for pipeline execution results

FluentAssertions extensions for NPipeline testing - adds fluent assertion methods for pipeline execution results

NPipeline analyzers and code fixes for detecting and resolving common pipeline configuration issues

Observability extension for NPipeline - provides comprehensive metrics collection and monitoring capabilities

OpenTelemetry integration for NPipeline observability - provides seamless integration with OpenTelemetry SDKs for distributed tracing

High-performance pipeline composition extension for NPipeline - enables treating entire pipelines as nodes within larger pipelines

High-performance, dependency-free extension library providing ready-made data processing nodes for NPipeline. Includes cleansing, validation, filtering, type conversion, and enrichment nodes for strings,... More information

Lineage extension for NPipeline - provides comprehensive data lineage tracking and provenance capabilities

Excel source and sink nodes for NPipeline using ExcelDataReader - read and write Excel files (XLS, XLSX) with configurable options

SQL Server source and sink nodes for NPipeline using Microsoft.Data.SqlClient - read from and write to SQL Server databases with configurable options

SQL Server connector-specific analyzers for NPipeline, including checkpointing validation

JSON source and sink nodes for NPipeline using System.Text.Json - read and write JSON files with configurable options

AWS SQS source and sink nodes for NPipeline - integrate with Amazon Simple Queue Service for reliable message queuing