StonFlux
Sign In
NEXT-GEN ETL PLATFORM

Data Integration,
Reimagined.

StonFlux는 차세대 ETL/ELT 플랫폼입니다. 레거시 DI 시스템의 복잡한 데이터 파이프라인을 현대적인 아키텍처로 마이그레이션하고, 실시간 모니터링과 비주얼 워크플로우 편집기로 데이터 통합을 혁신합니다.

Get Started Learn More
0
Supported DB Types
0+
Concurrent Pipelines
0%
Uptime SLA
0/s
Real-time Events

Platform at a Glance

StonFlux가 처리하는 데이터 파이프라인의 규모를 한눈에 확인하세요.

0+
등록 커넥션
Oracle, Tibero, PostgreSQL, MySQL, MSSQL
0+
ETL Jobs
자동 변환된 레거시 DI 포함
0+
Workplans
DAG 기반 실행 계획
0+
Schedules
Cron & Interval 자동 실행

Data Flow Overview

SOURCE SYSTEMS
Oracle SALESDB
128 tables
Tibero HRDATA
96 tables
PostgreSQL stonflux
45 tables
Oracle LFIS
32 tables
ETL PIPELINE
Extract100%
Transform85%
Load92%
processing
TARGET SYSTEMS
PostgreSQL stonflux
301 tables
etl_target schema
45 tables
Data Warehouse
78 tables
Analytics DB
25 tables
98.7%
Success Rate
12 monthsnow
2.4M
Rows / Day
12 monthsnow
0.3%
Error Rate
12 monthsnow

Key Screens

StonFlux의 주요 화면을 미리 살펴보세요.

DASHBOARD

Analytics Dashboard

ETL 실행 현황을 한눈에 파악합니다. Job, Workplan, Connection 수와 성공률, 실행 중인 파이프라인, 레거시 마이그레이션 진행률을 실시간으로 모니터링합니다.

  • 엔터티별 통계 카드
  • 최근 실행 이력 테이블
  • 마이그레이션 진행률 바
StonFlux - Dashboard
Jobs
142
Models
89
Success
98.7%
Running
3
Recent Executions
daily_sync_job
12,450 rowssuccess
oracle_migration
8,200 rowsrunning
report_etl
3,100 rowssuccess
StonFlux - Workplan Editor
Start
extract_users
Oracle → PG
load_orders
PG → DW
extract_products
Tibero → PG
build_reports
PG → Analytics
WORKPLAN EDITOR

Visual DAG Editor

ReactFlow 기반 시각적 워크플로우 에디터로 ETL 파이프라인을 설계합니다. 노드를 드래그 앤 드롭하고 간선으로 연결하여 실행 순서와 의존성을 직관적으로 구성합니다.

  • DAG 토폴로지 정렬 실행
  • 병렬/직렬 혼합 실행
  • 에러 정책 (Stop/Continue)
EXECUTION

Real-time Monitoring

WebSocket 기반 실시간 모니터링으로 ETL 실행 상태를 즉시 확인합니다. 추출/적재 row 수, 소요 시간, 에러 로그를 라이브로 추적합니다.

  • 실시간 진행률 업데이트
  • 단계별 실행 로그
  • 실행 취소 기능
StonFlux - Execution Detail
SUCCESSdaily_sync_workplan
2.34s
Extracted
12,450
Loaded
12,448
Failed
2
INFO[engine]Starting ETL pipeline
INFO[extract]Starting extraction
INFO[load]Loaded batch: 1,000 rows, insert=1000
INFO[load]Loaded final batch: 450 rows, insert=448, update=2
INFO[engine]Pipeline finished: success in 2.34s
StonFlux - Catalog Browser
EMPLOYEES@SALESDB (Oracle)
EMPLOYEES
COLUMNTYPENULLABLEDEFAULTCOMMENT
IDNUMBER(10)NOSEQ.NEXTVALPK
USER_NAMEVARCHAR2(100)NO-Name
EMAILVARCHAR2(200)YESNULLEmail
CREATED_ATTIMESTAMPNOSYSDATECreated
STATUSCHAR(1)NO'A'Status
CATALOG

Data Catalog Browser

등록된 커넥션의 스키마, 테이블, 컬럼 정보를 실시간으로 탐색합니다. DDL 조회, 인덱스/FK 확인, SQL 직접 실행까지 지원합니다.

  • 스키마/테이블/컬럼 탐색
  • DDL, 인덱스, FK 조회
  • SQL 쿼리 직접 실행

All Platform Menus

StonFlux의 모든 메뉴 화면을 라이트/다크 두 가지 테마로 확인하세요.

Light Theme
Dark Theme
DASHBOARD
StonFlux - Dashboard
LIGHT
StonFlux
Dashboard
Projects
Connections
Catalog
Data Models
Jobs
Workplans
Schedules
Sequences
Procedures
Legacy DI
Executions
Settings
admin
admin
Total Jobs
142
Data Models
89
Connections
24
Workplans
56
Success Rate
98.7%
Running Now
3
Recent Executions
daily_sync_job
12,450 rows2.3ssuccess
oracle_migration
8,200 rows...running
report_etl
3,100 rows1.1ssuccess
StonFlux - Dashboard
DARK
StonFlux
Dashboard
Projects
Connections
Catalog
Data Models
Jobs
Workplans
Schedules
Sequences
Procedures
Legacy DI
Executions
Settings
admin
admin
Total Jobs
142
Data Models
89
Connections
24
Workplans
56
Success Rate
98.7%
Running Now
3
Recent Executions
daily_sync_job
12,450 rows2.3ssuccess
oracle_migration
8,200 rows...running
report_etl
3,100 rows1.1ssuccess
ALL MENU SCREENS

Connections

Connections
SALESDB (Oracle)
HRDATA (Tibero)
stonflux (PostgreSQL)
report_db (MySQL)
Connections
SALESDB (Oracle)
HRDATA (Tibero)
stonflux (PostgreSQL)
report_db (MySQL)

Catalog

Catalog
EMPLOYEES@SALESDB
ID / NUMBER(10)
USER_NM / VARCHAR2(100)
EMAIL / VARCHAR2(200)
STATUS / CHAR(1)
Catalog
EMPLOYEES@SALESDB
ID / NUMBER(10)
USER_NM / VARCHAR2(100)
EMAIL / VARCHAR2(200)
STATUS / CHAR(1)

Data Models

Data Models
user_masterv312cols
order_detailv218cols
product_infov18cols
Data Models
user_masterv312cols
order_detailv218cols
product_infov18cols

Jobs

Jobs
daily_sync_users
Oracle → PG
extract_orders
Tibero → PG
load_products
PG → DW
Jobs
daily_sync_users
Oracle → PG
extract_orders
Tibero → PG
load_products
PG → DW

Workplans

Workplans
daily_pipeline
5 jobs · stop_on_error
weekly_report
3 jobs · continue
migration_batch
12 jobs · stop_on_error
Workplans
daily_pipeline
5 jobs · stop_on_error
weekly_report
3 jobs · continue
migration_batch
12 jobs · stop_on_error

Schedules

Schedules
daily_2am
0 2 * * *
next: 02:00
hourly_sync
0 * * * *
next: 15:00
weekly_mon
0 6 * * 1
next: Mon 06:00
Schedules
daily_2am
0 2 * * *
next: 02:00
hourly_sync
0 * * * *
next: 15:00
weekly_mon
0 6 * * 1
next: Mon 06:00

Sequences

Sequences
pre_check_seq3 steps
post_load_seq5 steps
cleanup_seq2 steps
Sequences
pre_check_seq3 steps
post_load_seq5 steps
cleanup_seq2 steps

Procedures

Procedures
upsert_userSQL
calc_balancePython
validate_dataSQL
Procedures
upsert_userSQL
calc_balancePython
validate_dataSQL

Executions

Executions
daily_pipelinesuccess
oracle_syncrunning
weekly_reportfailed
Executions
daily_pipelinesuccess
oracle_syncrunning
weekly_reportfailed

Why StonFlux?

기존 DI 시스템의 한계를 넘어, 확장 가능한 현대적 데이터 파이프라인을 구축하세요.

Visual Workflow Editor

ReactFlow 기반 DAG 편집기로 워크플랜을 시각적으로 설계합니다. 드래그 앤 드롭으로 Job 간 의존성을 정의하고 병렬 실행 흐름을 구성할 수 있습니다.

Multi-DB Connectivity

PostgreSQL, Oracle, Tibero, MySQL, MSSQL 등 다양한 데이터베이스를 지원합니다. 커넥션 풀링과 암호화된 자격증명으로 안전하게 연결합니다.

Real-time Monitoring

WebSocket 기반 실시간 실행 모니터링으로 ETL 파이프라인 상태를 즉시 확인합니다. 추출/적재 row 수를 라이브로 추적합니다.

Data Model Management

소스와 타겟 테이블의 스키마를 데이터 모델로 관리합니다. 버전 관리를 통해 변경 이력을 추적하고 롤백할 수 있습니다.

Enterprise Security

JWT + OAuth2 인증, RBAC 권한 관리, Google OAuth 소셜 로그인을 지원합니다. 관리자 승인 프로세스로 접근을 제어합니다.

Analytics Dashboard

ETL 실행 성공률, 처리량 추세, 에러 패턴을 대시보드에서 분석합니다. 레거시 DI 마이그레이션 진행률도 실시간으로 확인할 수 있습니다.

Flexible Scheduling

Cron 기반 스케줄, 인터벌 반복, 일회성 실행 등 다양한 스케줄링을 지원합니다. APScheduler 통합으로 안정적인 자동 실행을 보장합니다.

Legacy DI Migration

기존 DI 시스템(DataStage, Informatica 등)의 메타데이터를 파싱하여 StonFlux 엔터티로 자동 변환합니다. XML 기반 레거시 정의를 원클릭으로 마이그레이션합니다.

i18n & Theming

한국어/영어 다국어 지원과 다크/라이트 테마를 제공합니다. 사용자별 설정으로 최적화된 작업 환경을 구성합니다.

System Architecture

모던 풀스택 아키텍처로 설계된 확장 가능한 ETL 플랫폼

Frontend Layer
Next.js 14App Router, SSR
React 18Server Components
ReactFlowDAG Editor
TanStack QueryData Fetching
ZustandState Management
REST API + WebSocket
Backend Layer
FastAPIAsync Python
SQLAlchemy 2Async ORM
JWT + OAuth2Authentication
APSchedulerJob Scheduling
WebSocketReal-time Events
SQLAlchemy + asyncpg
Data Layer
PostgreSQLPrimary Database
OracleSource/Target
TiberoSource/Target
MySQLSource/Target
MSSQLSource/Target

ETL Pipeline Flow

STEP 01

Extract

Source DB Query

STEP 02

Transform

Field Mapping & Scripts

STEP 03

Load

Target DB Insert/Upsert

STEP 04

Monitor

Real-time WebSocket

STEP 05

Report

Execution Logs

Getting Started

StonFlux의 핵심 엔터티와 ETL 파이프라인 구성 방법을 알아보세요.

1. Connection

데이터베이스 연결 정보를 등록합니다. 소스(추출) DB와 타겟(적재) DB를 각각 설정하며, 연결 테스트로 접속을 확인합니다.

  • •Host, Port, Database 정보 입력
  • •비밀번호 암호화 저장
  • •연결 테스트 및 카탈로그 탐색

2. Data Model

테이블 스키마를 데이터 모델로 정의합니다. 소스/타겟 컬럼 매핑, 외래키 관계, 필드 참조를 관리합니다.

  • •테이블 컬럼 정의 (JSON)
  • •버전 관리 및 변경 이력
  • •카탈로그에서 자동 가져오기

3. Job

하나의 ETL 작업 단위입니다. 소스 쿼리, 필드 매핑, 변환 스크립트, 타겟 테이블을 설정합니다.

  • •소스 DB에서 데이터 추출 (SELECT)
  • •필드 변환 (cast, trim, upper 등)
  • •타겟 DB에 적재 (INSERT/UPSERT)

4. Workplan

여러 Job을 순서대로 또는 DAG로 구성하는 실행 계획입니다. 에러 정책(중지/계속)을 설정합니다.

  • •Job들의 실행 순서 정의
  • •DAG 기반 병렬/직렬 실행
  • •에러 시 중지 또는 계속 정책

5. Schedule

Workplan의 자동 실행 스케줄을 설정합니다. Cron 표현식, 인터벌, 일회성 실행을 지원합니다.

  • •Cron: 0 2 * * * (매일 새벽 2시)
  • •Interval: 3600초마다 반복
  • •시작/종료 시간 설정

6. Execution

ETL 파이프라인의 실행 결과를 추적합니다. 추출/적재 row 수, 소요 시간, 에러 로그를 확인합니다.

  • •실시간 진행 상태 모니터링
  • •parent/child 실행 트리
  • •실행 스냅샷으로 감사 추적

Typical Workflow

Connection 등록
Data Model 정의
Job 생성
Workplan 구성
Schedule 설정
Execution 모니터링

Ready to Transform Your Data?

지금 바로 StonFlux에 로그인하여 데이터 파이프라인을 구축하세요.

Sign In