wshobson/workflow-orchestration-patterns

workflow-orchestration-patterns은(는) 무엇을 하나요?

Temporal을 사용하여 분산 시스템을 위한 내구성 있는 워크플로우를 설계합니다. 워크플로우와 액티비티의 분리, 사가 패턴, 상태 관리, 결정론적 제약 조건을 다룹니다. 장기 실행 프로세스, 분산 트랜잭션 또는 마이크로서비스 오케스트레이션을 구축할 때 사용하세요.

개요

이 스킬은 Temporal 워크플로우 오케스트레이션의 핵심 패턴을 소개합니다. Temporal은 분산 시스템에서 워크플로우 실행을 안정적으로 관리하고, 오류 상황에서도 자동으로 복구할 수 있는 플랫폼입니다.

포함된 패턴

1. 워크플로우와 액티비티 분리

• 워크플로우(Workflow): 비즈니스 로직, 오케스트레이션, 상태 전이를 담당합니다. 결정론적이어야 합니다.
• 액티비티(Activity): 실제 작업(API 호출, 파일 처리, 데이터베이스 쓰기 등)을 수행합니다. 멱등성을 고려해야 합니다.

2. 사가(Saga) 패턴

• 분산 트랜잭션에서 실패 시 보상 작업을 실행합니다.
• 각 단계에 대해 보상 액티비티를 정의하고, 실패 시 롤백합니다.
• Temporal의 시그널(Signal)과 쿼리(Query)를 활용한 유연한 취소 처리.

3. 상태 관리

• 워크플로우 상태를 객체로 관리하고, 지속성(persistence)을 위해 Temporal의 내장 기능을 사용합니다.
• 로컬 상태 vs. 외부 저장소 선택 기준.

4. 결정론적 제약 조건

• 워크플로우 코드는 결정론적이어야 합니다 (동일한 입력에 대해 항상 동일한 실행 경로).
• 피해야 할 것: 랜덤 값, 현재 시간, 네트워크 호출 (액티비티에서만 수행).

사용 방법

1. temporalite 또는 Temporal Cloud를 사용하여 Temporal 서버를 실행합니다.
2. 워크플로우와 액티비티 인터페이스를 정의합니다.
3. 각 패턴에 맞게 구현합니다.
4. 워커(Worker)를 등록하고 워크플로우를 실행합니다.

예제

// 워크플로우 정의
func MyWorkflow(ctx workflow.Context, input string) (string, error) {
    ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
        StartToCloseTimeout: time.Minute,
    })
    var result string
    err := workflow.ExecuteActivity(ctx, MyActivity, input).Get(ctx, &result)
    return result, err
}

참고 자료

• Temporal 공식 문서
• Temporal Go SDK
• 사가 패턴 설명

라이선스

이 스킬은 학습 및 참고 목적으로 제공됩니다.