一般的なワークフローの問題

これがあなたの週のように聞こえますか?

これらはエッジケースではありません。複数のツールでGCP Dataflowジョブを実行しているチームにとって、通常の操作条件です。Control-Mが各ケースをどのように処理するかをご覧ください。

遅延データ到着

あなたのCloud Storageデータは遅れています。午前2時のDataflowジョブは開始できません。

Control-Mは上流のファイル依存関係を追跡し、必要なデータが利用可能になるまでDataflowの実行を保持します。スケジューリングと依存関係のロジックが不完全な入力に対して処理ジョブが開始されるのを防ぎ、壊れやすい固定時間の引き渡しを排除します。

ジョブ失敗

あなたのFlexテンプレートが起動します。Dataflowジョブは処理中に失敗します。

Control-MはDataflowジョブの状態、結果、出力を監視し、失敗した実行を検出します。設定可能なControl-Mの回復ロジックは、下流のジョブが進行するのを防ぎ、壊れたパイプラインが連鎖するのを防ぐために適切な運用対応にルーティングします。

クロスツール依存関係

Dataflowは成功裏に完了しました。BigQueryの処理は下流でまだ待機しています。

Control-MはDataflowの成功した完了を検出し、同じジョブフロー内で依存するBigQueryワークロードを解放します。クロスツールの依存関係は、切断されたスケジュールを明示的な実行順序に置き換えるため、下流の処理はその前提条件が実際に終了したときに開始されます。

SLAリスク

Dataflowはまだ処理中です。あなたの朝の分析の締切が近づいています。

Control-MはDataflowジョブを広範なワークフローSLAに接続し、オペレーションに個々のクラウドジョブを超えた可視性を提供します。チームは、遅延したパイプラインがビジネスの締切を逃す前に、依存する処理と配信ステップ全体のSLAリスクを特定できます。

テンプレート実行

ClassicおよびFlexテンプレートは異なる方法で実行されます。オペレーションはまだ1つのワークフローが必要です。

Control-MはClassicおよびFlexテンプレートに基づくDataflowジョブをサポートし、ジョブ内でプロジェクト、リージョン、テンプレートの場所、パラメーター、およびポーリング設定が定義されます。データエンジニアはネイティブなDataflow実行を維持し、オペレーションは一貫した企業オーケストレーションを取得します。

統合事実

Control-M + GCP Dataflow

workload.types

バッチパイプライン · リアルタイムストリーミングパイプライン · Classicテンプレート · Flexテンプレート · パラメータ化されたDataflowジョブ

trigger.type

時間スケジュール · 上流ジョブの完了 · ファイル到着 · Control-Mの依存関係 · API駆動の実行 · ビジネスカレンダー

cross_tool.deps

GCP BigQueryジョブ · GCP Composer DAG · Cloud Storageファイルの到着 · Databricksジョブ · REST APIコール · 下流分析ジョブ

cloud.platforms

Google Cloud Platform · GCP Dataflow · Cloud Storage · BigQuery · Pub/Sub

error_handling

ジョブステータスのモニタリング · 設定可能なControl-Mのリカバリー · 下流のカスケード防止 · 失敗出力の取得 · SLAのモニタリング · 依存関係の保持

throughput

バッチ処理 · リアルタイムデータストリーミング · エージェントごとに50の同時Dataflowジョブ · 設定可能なステータスポーリング

observability

Dataflowジョブのステータス · ジョブ結果 · ジョブ出力 · Control-Mモニタリング · SLAの可視性 · エンドツーエンドの依存関係ビュー

エンドツーエンドオーケストレーション

1つのプロダクションワークフロー。スタック内のすべてのツール。

Control-MはGCP Dataflow、Cloud Storage、BigQuery、Pub/Sub、GCP Composer、クラウドサービス全体でワークフローを調整し、依存関係の追跡、SLAの可視性、すべての自動リカバリーを提供します。

  • クロスツール依存関係:Cloud Storage → Dataflowジョブ → BigQuery → 分析の引き渡し
  • データ認識トリガー:ファイルの到着、APIイベント、上流ジョブの完了、Dataflowの完了

GCP Dataflow

Classic Templateの実行 · Flex Templateの実行 · パラメータ · ステータス/結果/出力のモニタリング

クラウドストレージ

ファイル到着依存 · 上流データの準備状況 · ワークフローの引き継ぎ

BigQuery

下流ジョブのオーケストレーション · 依存関係の調整 · 分析の引き継ぎ

Pub/Sub

ストリーミングパイプラインの調整 · Dataflowソース/シンクワークフロー依存

GCP Composer

DAG調整 · 上流/下流依存 · クロスプラットフォームオーケストレーション

Databricks

ジョブ調整 · 変換依存 · 下流引き継ぎ

REST APIs

API駆動のワークフローステップ · クロスアプリケーション依存 · プロセス調整

airflow共存

Control-MはあなたのAirflow DAGを置き換えることはありません。それはそれらの上にレイヤーを実行します。

一般的な異議: 「すでにAirflowを使用しています。」問題はAirflowが何をするかではなく、Airflowが実行される前後に何が起こるかです。そこがパイプラインが実際に失敗する場所です。

AirflowはそのDAGを管理します。Control-Mはそれを取り巻くすべてを管理します。

airflowが処理する

データパイプライン内のDAGレベルのオーケストレーション

  • データパイプライン内のDAGレベルのタスクオーケストレーション
  • Pythonオペレーター、センサー、タスク依存関係
  • パイプライン内で実行されるジョブの実行グラフ
  • 単一DAGコンテキスト内でのリトライを管理

control-mが追加する

あなたのDAGを取り巻く調整レイヤー

  • DAGを取り巻く調整レイヤー — 上流の条件に基づいてAirflowをトリガーします: ファイルの到着、APIイベント、他のツールの完了
  • 各DAGのSLA貢献度をフルエンドツーエンドワークフロー全体で追跡します。自身のルーチンだけではなく
  • Airflowが開始する前に上流の依存関係が失敗した際の障害回復を管理
  • 既存のDAGを再記述または移行する必要はありません

パイプラインを監視する

GCP Dataflowの実行をフルパイプラインにわたって監視する

Dataflowは自分自身のジョブに対する可視性を提供しますが、プロダクションパイプラインはそこに止まりません。Control-MはDataflowとそれに依存するワークロード全体にわたる中央集権的な監視を追加し、チームがエンドツーエンドの文脈で実行を追跡できるようにします:

  • Dataflowジョブの状態と結果

  • ジョブ出力と失敗の詳細

  • 上流および下流依存

  • クロスプラットフォームパイプライン実行

  • エンドツーエンドワークフローの状態

SLA保証

Dataflowパイプラインをビジネスの締切に合わせる

健康なDataflowジョブは、時間通りのビジネス成果を保証しません。Control-MはDataflowの実行を依存関係とSLA管理に結びつけ、全体のデータ配信が必要なときに完了するかどうかをチームが理解できるようにします:

  • エンドツーエンドSLA追跡

  • 上流依存の可視性

  • 下流カスケード防止

  • パイプライン完了の監視

  • SLAジョブの添付

複雑なワークフローに秩序をもたらす

Control-Mがチームに複雑なプロセスをより高い可視性、調整、および制御でオーケストレーションする手助けをする方法を学ぶ。