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