본문으로 건너뛰기

Pipeline

Dagster/Flink 기반 파이프라인 템플릿 관리, 실행, 모니터링 API입니다. 파이프라인 정의, 실행, 취소 및 다양한 오케스트레이터 상태 모니터링을 제공합니다.

엔드포인트​

GET /api/v1/pipelines/templates​

설명: 파이프라인 템플릿 목록을 반환합니다.

GET /api/v1/pipelines/templates/{template_id}​

설명: 특정 템플릿의 상세 정보를 반환합니다.

POST /api/v1/pipelines/templates​

설명: 새 파이프라인 템플릿을 생성합니다. (HTTP 201)

PUT /api/v1/pipelines/templates/{template_id}​

설명: 파이프라인 템플릿을 수정합니다.

DELETE /api/v1/pipelines/templates/{template_id}​

설명: 파이프라인 템플릿을 삭제합니다. 관련 실행 이력(pipeline_runs)도 같은 트랜잭션에서 함께 삭제됩니다(#918).

POST /api/v1/pipelines/templates/{template_id}/run​

설명: 템플릿을 기반으로 파이프라인을 실행합니다. (HTTP 201)

GET /api/v1/pipelines/runs​

설명: 파이프라인 실행 이력을 반환합니다.

GET /api/v1/pipelines/runs/{run_id}​

설명: 특정 실행의 상세 정보를 반환합니다.

POST /api/v1/pipelines/runs/{run_id}/cancel​

설명: 실행 중인 파이프라인을 취소합니다.

GET /api/v1/pipelines/monitor/summary​

설명: 전체 파이프라인 모니터링 요약을 반환합니다.

GET /api/v1/pipelines/monitor/dagster​

설명: Dagster 오케스트레이터 상태를 반환합니다.

설명: Flink 스트리밍 엔진 상태를 반환합니다.

GET /api/v1/pipelines/monitor/ingestion​

설명: 수집 파이프라인 모니터링 요약을 반환합니다.

인증​

JWT Bearer 토큰이 필요합니다.

에러 코드​

코드설명
400잘못된 템플릿 또는 파라미터
404템플릿 또는 실행을 찾을 수 없음
500Dagster/Flink 연동 실패