一般的なお問い合わせと所在地情報
お問い合わせ一般的なワークフローの問題
これらはエッジケースではありません。それらは複数のツールでGCP Dataplexジョブを実行しているチームの通常の運用条件です。Control-Mがそれぞれをどのように処理するかは次のとおりです。
データ品質
Control-MはBigQueryジョブとDataplexスキャンを依存関係のあるワークフロー手順としてモデル化し、上流の条件が満たされてからのみ事前定義されたスキャンを開始します。見逃したハンドオフは、静かなデータ品質のギャップではなく、目に見えるワークフローステートになります。
失敗したスキャン
Control-MはDataplexジョブのステータス、結果、出力を監視し、定義された失敗処理を適用し、失敗した実行で依存する作業が進むのを防ぎます。オペレーションは文脈内で失敗したステップを確認し、チェーンを再構築することなくワークフローを回復できます。
SPARKの遅延
Control-Mはエンドツーエンドワークフロー内でDataplexタスクを監視し、下流の納品 commitmentsへの貢献を追跡します。SLA監視は遅延の影響を早期に露呈させるので、チームは遅れたSparkタスクが遅れたビジネス結果になる前に介入できます。
プロファイルハンドオフ
Control-Mは事前定義されたデータプロファイリングスキャンの完了を追跡し、次のワークフロー依存関係を自動的に評価します。必要な状態に達すると、下流処理は別のポーリングスクリプト、cronスケジュール、または手動ハンドオフなしで進みます。
ステータスポーリング
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追跡 · エンドツーエンドの依存関係の可視性 · ワークフロー監視 |
エンドツーエンドのオーケストレーション
Control-MはGCP Dataplex、BigQuery、Cloud Storage、Cloud Composer、Dataflow、そしてクラウドサービスを1つのジョブフローで調整します—すべての依存関係の追跡、SLAの可視性、そして自動リカバリを備えて。
|
GCP Dataplex |
データ品質タスク · カスタムSparkタスク · データプロファイリングスキャン · データ品質スキャン · ステータス監視 |
|
BigQuery |
クエリ実行 · 変換依存関係 · 上流/下流のシーケンシング |
|
Cloud Storage |
ファイル到着 · 取り込み依存関係 · データハンドオフ |
|
Cloud Composer / Airflow |
DAGオーケストレーション · 完了依存関係 · クロスDAGワークフロー調整 |
|
GCP Dataflow |
パイプライン実行 · ステータス依存関係 · 下流シーケンシング |
|
GCP Data Fusion |
パイプライン実行 · ワークフロー依存関係 · 中央集権的監視 |
|
下流分析 |
デリバリー依存関係 · SLA調整 · ワークフロー完了 |
airflow共存
一般的な異議:"私たちはすでにAirflowを使用しています。" 問題はAirflowが何をするかではなく、Airflowが実行される前後に何が起こるかです。そこがパイプラインが実際に失敗するところです。
AirflowはそのDAGを管理します。Control-Mはそれを取り巻くすべてを管理します。
airflowが処理します
control-mが追加します
パイプラインを監視する
DataplexはGoogle Cloudコンテキスト内での実行を示します。生産依存関係はしばしばそれを超えます。Control-Mは、Dataplexのステータス、結果、および出力を中央で監視し、完全なワークフローが成功するかどうかを決定する上流および下流のジョブとともに表示します:
Dataplexジョブ実行ステータス
ジョブ結果と出力
上流および下流の依存関係
エンドツーエンドのワークフロー監視
クロスプラットフォームの失敗コンテキスト
SLA保証
成功したDataplexスキャンは、完全なデータ製品が時間通りに到着したことを証明するものではありません。Control-Mは、DataplexジョブにSLA管理を付加し、より広いワークフロー内でそれらを追跡し、チームが上流または下流の依存関係が配信を危険にさらす前に遅延を特定できるようにします:
Dataplex SLAジョブの添付
エンドツーエンドのSLA追跡
予測遅延の可視性
依存関係を意識したワークフローステータス
中央集権的な運用アラート
Control-Mがチームに大きな可視性、調整、制御で複雑なプロセスをオーケストレーションする方法を学ぶ。