Azure DevOpsからデータをインジェストする
ベータ版
この機能はベータ版です。使用するには、ワークスペース管理者が [プレビュー] ページで Azure DevOps 向け Lakeflow Connect を有効にする必要があります。Databricksのプレビューを管理を参照してください。
このページでは、Lakeflow Connect を使用して管理対象の Azure DevOps インジェスト パイプラインを作成する方法について説明します。
要件
-
取り込み パイプラインを作成するには、まず次の要件を満たす必要があります:
-
ワークスペースでUnity Catalogが有効になっている必要があります。
-
ワークスペースでServerless コンピュートが有効になっている必要があります。Serverless コンピュートの要件を参照してください。
-
新しい接続を作成するには、メタストアに対する
CREATE CONNECTION特権が必要です。Unity Catalog での特権の管理を参照してください。コネクタが UI ベースのパイプライン オーサリングをサポートしている場合、管理者はこのページのステップを完了することで、接続とパイプラインを同時に作成できます。 ただし、パイプラインを作成するユーザーが API ベースのパイプライン オーサリングを使用している場合、または管理者以外のユーザーである場合、管理者はまずカタログ エクスプローラーで接続を作成する必要があります。 「管理対象取り込みソースへの接続」を参照してください。
-
既存の接続を使用するには、接続オブジェクトに対する
USE CONNECTION権限またはALL PRIVILEGES権限が必要です。 -
ターゲットカタログに対する
USE CATALOG権限が必要です。 -
既存のスキーマに対する
USE SCHEMAおよびCREATE TABLE権限、またはターゲットカタログに対するCREATE SCHEMA権限が必要です。
-
-
Azure DevOps から取り込むには、まず Databricks からの認証を構成し、接続を作成します。「Azure DevOps への認証を構成する」および「Azure DevOps 接続を作成する」を参照してください。
コネクターのオプション
source_configurationsでパイプラインスコープのオプションを設定します。使用方法については例を参照してください。
オプション | スコープ | 必須 | 適用対象 | 説明 |
|---|---|---|---|---|
| パイプライン | No |
| 最初の同期に取り込む最も早いcommit日時( |
取り込みパイプラインを作成する
サポートされているソーステーブルの一覧については、 サポートされているソーステーブルを参照してください。
- Databricks UI
- Declarative Automation Bundles
- Databricks notebook
- Databricksワークスペースのサイドバーで、 データ取り込み をクリックします。
- データの追加 ページの Databricks コネクタ で、 Azure DevOps をクリックします。
- 取り込みウィザードの 接続 ページで、Azure DevOps 認証情報を格納する接続を選択します。メタストアに対する
CREATE CONNECTION特権を持っている場合は、接続の作成 をクリックして、Azure DevOpsへの認証の構成から認証情報を使用して接続を作成します。
- 次へ をクリックします。
- インジェストの設定 ページで、パイプラインの名前を入力します。
- データの書き込み先となるカタログとスキーマを選択します。カタログに対する
USE CATALOG権限とCREATE SCHEMA権限がある場合は、ドロップダウンメニューでスキーマを作成 をクリックして、スキーマを作成します。
- パイプラインの作成および続行 をクリックします。
- ソース ページで、取り込むテーブルを選択します。
- 保存して続行 をクリックします。
- 宛先 ページで、データをロードするカタログとスキーマを選択します。カタログに対する
USE CATALOG権限とCREATE SCHEMA権限がある場合は、ドロップダウンメニューのスキーマの作成 をクリックしてスキーマを作成します。
- 保存して続行 をクリックします。
- (オプション) スケジュールと通知 ページで、
スケジュールの作成 をクリックします。宛先テーブルを更新する頻度を設定します。
- (オプション)
通知の追加 をクリックして、パイプライン操作の成功または失敗に対するEメール通知を設定し、 保存してパイプラインをラン をクリックします。
宣言型オートメーションバンドルを使用して、Azure DevOps パイプラインをコードとして管理します。バンドルには、ジョブとタスクの YAML 定義を含めることができ、Databricks CLI を使用して管理され、異なるターゲット ワークスペース(開発、ステージング、本番運用など)で共有およびランを実行できます。「宣言型オートメーションバンドルとは?」をご覧ください。
-
Databricks CLIを使用してバンドルを作成するには:
Bashdatabricks bundle init -
バンドルに新しいリソースファイルを2つ追加します:
- パイプライン定義ファイル(例:
resources/azure_devops_pipeline.yml)。パイプライン.ingestion_definitionを参照してください。と 例。 - データ取り込みの頻度を制御するジョブ定義ファイル(例:
resources/azure_devops_job.yml)。
- パイプライン定義ファイル(例:
-
Databricks CLIを使用してパイプラインをデプロイする:
Bashdatabricks bundle deploy
- 次のノートブックをDatabricksワークスペースにインポートします。
-
セル1とセル2はそのままにします。変更しないでください。
-
パイプライン構成の詳細でセル3を変更します。パイプライン.ingestion_definition を参照してくださいと 例。
-
必要に応じて、高度なパイプライン設定を構成します。マネージド取り込みパイプラインの一般的なパターン を参照してください。
-
「 すべて実行 」をクリックします。
例
Azure DevOpsコネクタは、defaultソーススキーマで17個のソーステーブルを利用可能にします。次の例は、特定のテーブルを取り込みます。
特定のテーブルを取り込む
テーブルの特定のサブセットを取り込む場合、またはテーブルごとに宛先の名前付けをカスタマイズする場合に、このオプションを使用します。
- Declarative Automation Bundles
- Databricks notebook
次のパイプライン定義ファイルは、個別の Azure DevOps テーブルを取り込みます。
resources:
pipelines:
azure_devops_pipeline:
name: azure_devops_pipeline
catalog: 'main'
target: 'azure_devops_data'
ingestion_definition:
connection_name: azure_devops_connection
source_configurations:
- api_source_connector_config:
configs:
start_datetime: '<start-datetime>'
objects:
- table:
source_schema: 'default'
source_table: 'projects'
destination_catalog: 'main'
destination_schema: 'azure_devops_data'
destination_table: 'projects'
- table:
source_schema: 'default'
source_table: 'work_items'
destination_catalog: 'main'
destination_schema: 'azure_devops_data'
destination_table: 'work_items'
- table:
source_schema: 'default'
source_table: 'pull_requests'
destination_catalog: 'main'
destination_schema: 'azure_devops_data'
destination_table: 'pull_requests'
- table:
source_schema: 'default'
source_table: 'commits'
destination_catalog: 'main'
destination_schema: 'azure_devops_data'
destination_table: 'commits'
次のパイプライン仕様では、個々の Azure DevOps テーブルが取り込まれます。
pipeline_name = "azure_devops_pipeline"
connection_name = "<azure-devops-connection>"
pipeline_spec = {
"name": pipeline_name,
"ingestion_definition": {
"connection_name": connection_name,
"source_configurations": [
{
"api_source_connector_config": {
"configs": {
"start_datetime": "<start-datetime>"
}
}
}
],
"objects": [
{
"table": {
"source_schema": "default",
"source_table": "projects",
"destination_catalog": "main",
"destination_schema": "azure_devops_data",
"destination_table": "projects"
}
},
{
"table": {
"source_schema": "default",
"source_table": "work_items",
"destination_catalog": "main",
"destination_schema": "azure_devops_data",
"destination_table": "work_items"
}
},
{
"table": {
"source_schema": "default",
"source_table": "pull_requests",
"destination_catalog": "main",
"destination_schema": "azure_devops_data",
"destination_table": "pull_requests"
}
},
{
"table": {
"source_schema": "default",
"source_table": "commits",
"destination_catalog": "main",
"destination_schema": "azure_devops_data",
"destination_table": "commits"
}
}
]
}
}
json_payload = json.dumps(pipeline_spec, indent=2)
create_pipeline(json_payload)
宣言型オートメーションバンドルのジョブ定義ファイル
以下は、宣言型オートメーションバンドルで使用するジョブ定義ファイルの例です。ジョブは毎日実行されます。
- Declarative Automation Bundles
resources:
jobs:
azure_devops_job:
name: azure_devops_job
schedule:
quartz_cron_expression: '0 0 0 * * ?'
timezone_id: 'UTC'
tasks:
- task_key: azure_devops_ingestion
pipeline_task:
pipeline_id: ${resources.pipelines.azure_devops_pipeline.id}
一般的なパターン
高度なパイプライン構成については、マネージド取り込みパイプラインの一般的なパターンを参照してください。
次のステップ
パイプラインの起動、スケジュール、アラートの設定を行います。一般的なパイプラインのメンテナンス タスクを参照してください。