一般的なお問い合わせと所在地情報
お問い合わせ一般的なワークフローの問題
これらはエッジケースではありません。複数のツールでGCP Dataflowジョブを実行しているチームにとって、通常の操作条件です。Control-Mが各ケースをどのように処理するかをご覧ください。
遅延データ到着
Control-Mは上流のファイル依存関係を追跡し、必要なデータが利用可能になるまでDataflowの実行を保持します。スケジューリングと依存関係のロジックが不完全な入力に対して処理ジョブが開始されるのを防ぎ、壊れやすい固定時間の引き渡しを排除します。
ジョブ失敗
Control-MはDataflowジョブの状態、結果、出力を監視し、失敗した実行を検出します。設定可能なControl-Mの回復ロジックは、下流のジョブが進行するのを防ぎ、壊れたパイプラインが連鎖するのを防ぐために適切な運用対応にルーティングします。
クロスツール依存関係
Control-MはDataflowの成功した完了を検出し、同じジョブフロー内で依存するBigQueryワークロードを解放します。クロスツールの依存関係は、切断されたスケジュールを明示的な実行順序に置き換えるため、下流の処理はその前提条件が実際に終了したときに開始されます。
SLAリスク
Control-MはDataflowジョブを広範なワークフローSLAに接続し、オペレーションに個々のクラウドジョブを超えた可視性を提供します。チームは、遅延したパイプラインがビジネスの締切を逃す前に、依存する処理と配信ステップ全体のSLAリスクを特定できます。
テンプレート実行
Control-MはClassicおよびFlexテンプレートに基づくDataflowジョブをサポートし、ジョブ内でプロジェクト、リージョン、テンプレートの場所、パラメーター、およびポーリング設定が定義されます。データエンジニアはネイティブな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の可視性 · エンドツーエンドの依存関係ビュー |
エンドツーエンドオーケストレーション
Control-MはGCP Dataflow、Cloud Storage、BigQuery、Pub/Sub、GCP Composer、クラウドサービス全体でワークフローを調整し、依存関係の追跡、SLAの可視性、すべての自動リカバリーを提供します。
|
GCP Dataflow |
Classic Templateの実行 · Flex Templateの実行 · パラメータ · ステータス/結果/出力のモニタリング |
|
クラウドストレージ |
ファイル到着依存 · 上流データの準備状況 · ワークフローの引き継ぎ |
|
BigQuery |
下流ジョブのオーケストレーション · 依存関係の調整 · 分析の引き継ぎ |
|
Pub/Sub |
ストリーミングパイプラインの調整 · Dataflowソース/シンクワークフロー依存 |
|
GCP Composer |
DAG調整 · 上流/下流依存 · クロスプラットフォームオーケストレーション |
|
Databricks |
ジョブ調整 · 変換依存 · 下流引き継ぎ |
|
REST APIs |
API駆動のワークフローステップ · クロスアプリケーション依存 · プロセス調整 |
airflow共存
一般的な異議: 「すでにAirflowを使用しています。」問題はAirflowが何をするかではなく、Airflowが実行される前後に何が起こるかです。そこがパイプラインが実際に失敗する場所です。
AirflowはそのDAGを管理します。Control-Mはそれを取り巻くすべてを管理します。
airflowが処理する
control-mが追加する
パイプラインを監視する
Dataflowは自分自身のジョブに対する可視性を提供しますが、プロダクションパイプラインはそこに止まりません。Control-MはDataflowとそれに依存するワークロード全体にわたる中央集権的な監視を追加し、チームがエンドツーエンドの文脈で実行を追跡できるようにします:
Dataflowジョブの状態と結果
ジョブ出力と失敗の詳細
上流および下流依存
クロスプラットフォームパイプライン実行
エンドツーエンドワークフローの状態
SLA保証
健康なDataflowジョブは、時間通りのビジネス成果を保証しません。Control-MはDataflowの実行を依存関係とSLA管理に結びつけ、全体のデータ配信が必要なときに完了するかどうかをチームが理解できるようにします:
エンドツーエンドSLA追跡
上流依存の可視性
下流カスケード防止
パイプライン完了の監視
SLAジョブの添付
Control-Mがチームに複雑なプロセスをより高い可視性、調整、および制御でオーケストレーションする手助けをする方法を学ぶ。