PrefectHQ/prefect

Prefect is a workflow orchestration framework for building resilient data pipelines in Python.

解決する課題

Prefect は、Python スクリプトを本番環境対応のデータパイプラインに変換するプロセスを簡素化します。既存のコードを完全に書き直すことなく、スケジューリング、エラー回復、複雑な依存関係を処理する必要がある、回復力と動的なワークフローを構築する際の課題に対処します。

仕組み

ユーザーは Python 関数に @flow と @task デコレータを適用して、ワークフローの構造とロジックを定義します。これらのフローは、スケジュールされたタスク(cron 式を使用)としてデプロイしたり、特定のイベントによってトリガーしたりできます。アクティビティは、セルフホストの Prefect サーバーまたはマネージドクラウドダッシュボードを介して監視され、実行を追跡し、パイプラインの健全性を可視化します。

対象者

データプロセスを自動化し、変更に対応し、予期しない障害から回復できる信頼性の高いパイプラインを構築する必要があるデータチームとエンジニア向けに設計されています。

主な特長

  • 回復力のある自動化: リトライ、キャッシュ、複雑な分岐ロジックの組み込みサポート。
  • 柔軟な実行: セルフホストのサーバーインスタンスとマネージドクラウドバージョンの両方をサポート。
  • 動的トリガー: ワークフローは固定スケジュールまたはリアルタイムイベントに応じて実行できます。
  • 低摩擦: 開発者は最小限のコード変更で標準の Python スクリプトをオーケストレーションされたワークフローに昇格できます。

関連

  • プロジェクト
  • プロジェクト
  • プロジェクト
  • プロジェクト
  • プロジェクト