콘텐츠로 이동

Upstream Source

This page is part of Truthound Orchestration 3.x.

Source repository: seadonggyun4/truthound-orchestration Upstream docs path: docs/prefect/flows.md Edit upstream page: Edit in orchestration

Prefect 플로우

오케스트레이션 실행에서 Truthound, Prefect, Flows을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.

플로우 설정

오케스트레이션 실행에서 관련 설정과 실행 흐름을(를) 다루는 항목입니다:

  • 오케스트레이션 실행에서 FlowConfig, FlowConfig을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 QualityFlowConfig, QualityFlowConfig을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 PipelineFlowConfig, PipelineFlowConfig을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.

Basic Quality 검증 플로우

from prefect import flow, task
from truthound_prefect.tasks import data_quality_check_task

@task
def load_data():
    return ...

@flow(name="basic_quality_flow")
async def basic_quality_flow():
    data = load_data()
    result = await data_quality_check_task(
        data,
        rules=[{"column": "id", "type": "not_null"}],
    )
    return result

플로우 With 프로파일링

from prefect import flow
from truthound_prefect.tasks import data_quality_check_task, data_quality_profile_task

@flow(name="full_quality_flow")
async def full_quality_flow():
    data = ...
    check_future = data_quality_check_task.submit(data, rules=[{"column": "id", "type": "not_null"}])
    profile_future = data_quality_profile_task.submit(data)
    return {"check": check_future.result(), "profile": profile_future.result()}

플로우 Decorators And Factories

오케스트레이션 실행에서 관련 설정과 실행 흐름을(를) 다루는 항목입니다:

  • 오케스트레이션 실행에서 quality_checked_flow을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 profiled_flow을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 validated_flow을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 create_quality_flow을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 create_validation_flow을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 create_pipeline_flow을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 관련 설정과 실행 흐름을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 관련 설정과 실행 흐름을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 관련 설정과 실행 흐름을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.

Deployment Guidance

오케스트레이션 실행에서 Keep을(를) 다루는 항목입니다:

  • 플로우 define 오케스트레이션
  • blocks define reusable 설정
  • 오케스트레이션 실행에서 Prefect을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.

오케스트레이션 실행에서 See, Deployment, Patterns을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.

  • 태스크
  • 오케스트레이션 실행에서 SLA, Hooks을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.
  • 오케스트레이션 실행에서 Deployment, Patterns을(를) 기준으로 데이터 품질 검증, 워크플로우 자동화, 결과 해석 방법을 설명합니다.