BptDataFlow

The BptDataFlow component is an Apache NiFi-inspired visual data flow designer. Create data pipelines by connecting sources and targets (email, files, FTP/SFTP, databases, REST APIs) with configurable glob/regex filters. Supports drag-and-drop flow building, JSON export/import, and real-time execution monitoring. Available in Dark, Light, Blueprint, and Nord themes.

DataFlow Parameters

Height

Width

Read Only

Sandbox

Minimap

Data Flows

No flows defined

Connectors

File

FTP/SFTP

Database

API

Filter

Webhook

Kafka

EventHub

Az Function

Split Router

Merge Router

⮕ Data Flow Designer

Select a flow from the list or create a new one

Ready

Current Configuration

📋 [+]

<BptDataFlow
    Theme="DataFlowTheme.Light"
    Height="600px"
    Width="100%"
    UseSandboxData="false"
    ReadOnly="false"
    Services="@_services"
    />

@code {
@using Bpt.Components.Tools

// Program.cs setup (required for WebAssembly mode):
app.MapBptDataFlowHub();

}

Program.cs Setup

using Bpt.Components.Tools;

// In your Program.cs pipeline:
app.MapBptDataFlowHub();

Required for WebAssembly mode. Server mode works without hub registration but the hub is still recommended for WASM support.

Supported Connectors

Email (IMAP/SMTP)

Read from IMAP mailboxes
Filter by subject, sender, attachments
Write/forward via SMTP

File / FTP / SFTP

Local file system read/write
Glob/regex filename filtering
FTP and SFTP with key auth

Database / API

SQL Server, PostgreSQL, MySQL, SQLite
REST API with auth (key, bearer, basic, OAuth2)
Custom queries and table mapping

Filter / Router

Inline glob/regex pattern matching
Route items to named outputs (split/merge)
Error port for failed items

Webhook

Read-only inbound listener
HMAC secret validation
JSON payload ingestion

Kafka

Read-only Kafka consumer
Topic / consumer group config
Auto-offset reset policy

Azure EventHub

Read and write event streams
Consumer group support
Batch event processing

Azure Function

Poll via GET, trigger via POST
Function key authentication
Serverless data processing