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

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

これらはエッジケースではありません。それらは複数のツールでGCP Dataplexジョブを実行しているチームの通常の運用条件です。Control-Mがそれぞれをどのように処理するかは次のとおりです。

データ品質

あなたのBigQueryロードが完了しました。Dataplexの品質スキャンは開始されませんでした。

Control-MはBigQueryジョブとDataplexスキャンを依存関係のあるワークフロー手順としてモデル化し、上流の条件が満たされてからのみ事前定義されたスキャンを開始します。見逃したハンドオフは、静かなデータ品質のギャップではなく、目に見えるワークフローステートになります。

失敗したスキャン

午前2時のデータ品質スキャンが失敗しました。下流のレポートが待機しています。

Control-MはDataplexジョブのステータス、結果、出力を監視し、定義された失敗処理を適用し、失敗した実行で依存する作業が進むのを防ぎます。オペレーションは文脈内で失敗したステップを確認し、チェーンを再構築することなくワークフローを回復できます。

SPARKの遅延

あなたのカスタムSparkタスクが長く実行されました。すべての下流依存関係がシフトしました。

Control-Mはエンドツーエンドワークフロー内でDataplexタスクを監視し、下流の納品 commitmentsへの貢献を追跡します。SLA監視は遅延の影響を早期に露呈させるので、チームは遅れたSparkタスクが遅れたビジネス結果になる前に介入できます。

プロファイルハンドオフ

プロファイルが完了しました。あなたの次のBigQueryプロセスはまだ待機しています。

Control-Mは事前定義されたデータプロファイリングスキャンの完了を追跡し、次のワークフロー依存関係を自動的に評価します。必要な状態に達すると、下流処理は別のポーリングスクリプト、cronスケジュール、または手動ハンドオフなしで進みます。

ステータスポーリング

Dataplexはまだ実行中です。あなたのスケジューラはすでに失敗を仮定しています。

Control-MはGCP Dataplexジョブのステータスポーリング頻度と失敗許容を構成可能です。一時的なステータスチェックの問題は、ジョブが終了する前に処理されることができ、周囲の生産ワークフローを集中管理の下に保ちながら、偽の失敗を減らします。

統合の事実

Control-M + GCP Dataplex

workload.types

データ品質タスク · カスタムSparkタスク · データプロファイリングスキャン · データ品質スキャン

trigger.type

高度なスケジュール · 上流ジョブの完了 · ファイル到着 · API/イベント条件 · クロスツール依存関係

cross_tool.deps

Google Cloud Storage · BigQuery · GCP Dataflow · GCP Data Fusion · Apache Airflow/Cloud Composer · 下流分析

cloud.platforms

Google Cloud Platform · ハイブリッド環境 · マルチクラウドワークフロー · Control-M SaaS · 自己ホスト型Control-M

error_handling

ステータスポーリング頻度 · 障害耐性 · 下流カスケード防止 · 依存関係に基づくリカバリ · SLA監視 · アラート

throughput

エージェントごとに同時に最大50のDataplexジョブ · 中央集中型スケジューリング · リソースプール · リソースのロック

observability

Dataplexジョブのステータス · ジョブ結果 · ジョブ出力 · SLA追跡 · エンドツーエンドの依存関係の可視性 · ワークフロー監視

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

1つの生産ワークフロー。スタック内のすべてのツール。

Control-MはGCP Dataplex、BigQuery、Cloud Storage、Cloud Composer、Dataflow、そしてクラウドサービスを1つのジョブフローで調整します—すべての依存関係の追跡、SLAの可視性、そして自動リカバリを備えて。

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

GCP Dataplex

データ品質タスク · カスタムSparkタスク · データプロファイリングスキャン · データ品質スキャン · ステータス監視

BigQuery

クエリ実行 · 変換依存関係 · 上流/下流のシーケンシング

Cloud Storage

ファイル到着 · 取り込み依存関係 · データハンドオフ

Cloud Composer / Airflow

DAGオーケストレーション · 完了依存関係 · クロスDAGワークフロー調整

GCP Dataflow

パイプライン実行 · ステータス依存関係 · 下流シーケンシング

GCP Data Fusion

パイプライン実行 · ワークフロー依存関係 · 中央集権的監視

下流分析

デリバリー依存関係 · SLA調整 · ワークフロー完了

airflow共存

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

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

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

airflowが処理します

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

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

control-mが追加します

あなたのDAGの周囲の調整レイヤー

  • DAGの周囲の調整レイヤー - 上流の条件:ファイルの到着、APIイベント、他のツールの完了に基づいてAirflowをトリガー
  • 各DAGのSLA貢献をフルエンドツーエンドワークフロー全体で追跡し、それ自身のルーチンだけでなく
  • Airflowが開始される前に上流の依存関係が失敗した場合の失敗復旧を管理
  • 既存のDAGは書き直したり移行したりする必要はありません

パイプラインを監視する

完全なデータパイプラインにわたってDataplexジョブを監視します。

DataplexはGoogle Cloudコンテキスト内での実行を示します。生産依存関係はしばしばそれを超えます。Control-Mは、Dataplexのステータス、結果、および出力を中央で監視し、完全なワークフローが成功するかどうかを決定する上流および下流のジョブとともに表示します:

  • Dataplexジョブ実行ステータス

  • ジョブ結果と出力

  • 上流および下流の依存関係

  • エンドツーエンドのワークフロー監視

  • クロスプラットフォームの失敗コンテキスト

SLA保証

ビジネスSLA内でDataplex実行を行う。

成功したDataplexスキャンは、完全なデータ製品が時間通りに到着したことを証明するものではありません。Control-Mは、DataplexジョブにSLA管理を付加し、より広いワークフロー内でそれらを追跡し、チームが上流または下流の依存関係が配信を危険にさらす前に遅延を特定できるようにします:

  • Dataplex SLAジョブの添付

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

  • 予測遅延の可視性

  • 依存関係を意識したワークフローステータス

  • 中央集権的な運用アラート

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

Control-Mがチームに大きな可視性、調整、制御で複雑なプロセスをオーケストレーションする方法を学ぶ。