Associate Data Practitioner 問題の一覧 › 3. データパイプラインのオーケストレーション
Cloud Storage バケットにファイルがアップロードされたら、自動的に Cloud Run functions を起動して前処理を行いたい。最も適切な仕組みはどれか。
- Cloud Composer の DAG を毎分実行する
- BigQuery のスケジュールされたクエリを使う
- Eventarc のトリガーで Cloud Storage のイベントを関数に配信する
- Cloud Scheduler で毎分ポーリングする
💡 答えと解説を見る
答え:C(Eventarc のトリガーで Cloud Storage のイベントを関数に配信する)
Eventarc は Cloud Storage のオブジェクト作成イベントなどをトリガーに Cloud Run functions を起動できる。ポーリング方式は遅延と無駄が生じ、BigQuery のスケジュールクエリはファイル到着検知に使えない。
Eventarc は Cloud Storage のオブジェクト作成イベントなどをトリガーに Cloud Run functions を起動できる。ポーリング方式は遅延と無駄が生じ、BigQuery のスケジュールクエリはファイル到着検知に使えない。
関連サービス
| スケジュールクエリ | SQL の定期実行。最も簡単なオーケストレーション |
| Cloud Composer | マネージド Airflow。DAG で複雑なパイプライン・依存・リトライを管理 |
| DAG | 有向非巡回グラフ。タスクと依存関係の定義(Airflow) |
| Cloud Scheduler | マネージド cron。HTTP/Pub/Sub/Workflows を定時起動 |
| Eventarc | イベント(GCS 到着等)を Cloud Run 等へルーティング |
※ 学習用に作成したオリジナル問題です。本番試験とは異なります。