Oracle 統合CDCコネクター
ベータ版
この機能はベータ版です。ワークスペース管理者は、 プレビュー ページからこの機能へのアクセスを制御できます。Databricksのプレビューを管理するを参照してください。
このページでは、Oracle 取り込みワークフローについて理解を深めることができます。これには、セットアップアプローチを決定する要因や、ユーザーの役割に応じたステップが含まれます。
Oracle統合CDCコネクタは、 統合CDCパイプライン を使用します。これは、LogMinerを使用してOracleから変更を抽出し、個別の取り込みゲートウェイなしで宛先のストリーミングテーブルに適用する単一のパイプラインです。コンポーネントモデルについては、コネクタコンポーネントを参照してください。
Oracle 統合 CDC 取り込みパイプラインを作成する前に、Oracle でソースデータベースを直接構成する必要があります。具体的には、アーカイブログモードの有効化、レプリケートするテーブルでの補足ログの有効化、および必要な権限を持つレプリケーションユーザーの作成を行います。最初にこれらのタスクを完了してください。Databricks への取り込み用に Oracle を構成するを参照してください。
機能の利用可能状況
AWS、Azure、GCP の Databricks には、同じ機能の可用性が適用されます。
機能 | 可用性 |
|---|---|
UI ベースのパイプライン オーサリング |
|
API ベースのパイプライン オーサリング |
|
宣言型オートメーションバンドル |
|
増分取り込み |
|
Unity Catalog ガバナンス |
|
Lakeflowジョブによるオーケストレーション |
|
SCDタイプ2 |
|
APIベースの列選択および選択解除 |
|
APIベースの行フィルタリング |
|
自動スキーマ進化:新規および削除済みカラム |
削除された列を同じ名前で再追加することはサポートされていません。 |
自動スキーマ進化: データ型の変更 |
型拡張のみ。非拡張(縮小)型の変更には、完全更新が必要です。 |
自動スキーマ進化:列の名前変更 |
|
自動スキーマ進化: テーブル名の変更 |
|
自動スキーマ進化: 新しいテーブル |
スキーマ全体を取り込む場合。パイプラインごとのテーブル数の制限については、こちらを参照してください。 |
自動フルリフレッシュ |
サポートされていないスキーマ変更から復旧するために、影響を受けるテーブルを自動的にフル更新します。自動フル更新ポリシーを参照してください。 |
パイプラインあたりの最大テーブル数 | 250 |
認証方法
このコネクタは、Oracleのユーザー名とパスワードを使用したBasic認証のみをサポートしています。Oracle接続の作成を参照してください。
3つのステップでOracleから取り込む
開始する前に、Databricks ユーザーペルソナ、データベースのバリエーション、認証方法、サポートされているインターフェース、取り込み頻度、および一般的なパターンを確認してください。
- 取り込み用にOracleを構成する (管理者) — archive log modeを有効にし、レプリケートするテーブルでsupplemental logを有効にして、必要な権限を持つレプリケーションユーザーを作成します。
- Unity Catalog 接続の作成 (管理者) — 管理者以外のユーザーがパイプラインを作成できるように、カタログ エクスプローラーで接続を作成します。
- インジェストパイプラインを作成する (管理者または管理者以外のユーザー) — サポートされているインターフェースを選択し、既存の接続からパイプラインを作成します。