メインコンテンツまでスキップ
に最終更新

Oracle Eloquaからデータを取り込む

備考

ベータ版

この機能はパブリックプレビューです。使用するには、ワークスペース管理者は、 プレビューページ から Lakeflow Connect for Oracle Eloqua を有効にする必要があります。Databricksプレビューの管理を参照してください。

Oracle Eloqua データを Unity Catalog テーブルに取り込む管理された Lakeflow Connect パイプラインを作成します。Databricks UI、宣言型オートメーションバンドル、またはDatabricksノートブックを使用します。

要件​

  • 取り込み パイプラインを作成するには、最初に次の要件を満たす必要があります。

    • ワークスペースでUnity Catalogが有効になっている必要があります。

    • ワークスペースでServerless コンピュートが有効になっている必要があります。Serverless コンピュートの要件を参照してください。

    • 新しい接続を作成するには、メタストアに対する CREATE CONNECTION 特権が必要です。Unity Catalog での権限の管理を参照してください。

      コネクタが UI ベースのパイプライン オーサリングをサポートしている場合、管理者はこのページのステップを完了することで、接続とパイプラインを同時に作成できます。 ただし、パイプラインを作成するユーザーが API ベースのパイプライン オーサリングを使用している場合、または管理者以外のユーザーである場合、管理者はまずカタログ エクスプローラーで接続を作成する必要があります。 「管理対象取り込みソースへの接続」を参照してください。

    • 既存の接続を使用するには、接続オブジェクトに対する USE CONNECTION 権限または ALL PRIVILEGES 権限が必要です。

    • ターゲットカタログに対する USE CATALOG 権限が必要です。

    • 既存のスキーマに対してUSE SCHEMAとCREATE TABLE権限、またはターゲットカタログに対してCREATE SCHEMA権限が必要です。

  • Oracle Eloquaから取り込むには、まずDatabricksから認証を構成し、接続を作成します。「Oracle Eloquaへの認証の構成」および「Oracle Eloqua接続の作成」を参照してください。

コネクター オプション​

Oracle Eloquaコネクタが受け入れるオプション、そのスコープ、およびそれらが適用されるテーブルについては、コネクタ オプションを参照してください。source_configurationsでパイプラインスコープのオプションを設定します。使用方法については例を参照してください。

取り込みパイプラインを作成する​

サポートされているソーステーブルの一覧については、 「サポートされているソーステーブル」を参照してください。

  1. Databricksワークスペースのサイドバーで、 データ取り込み をクリックします。
  2. データの追加 ページの Databricks コネクタ で、 Oracle Eloqua をクリックします。
  3. 取り込みウィザードの 接続 ページで、Oracle Eloqua 認証情報を格納する接続を選択します。メタストアに対する CREATE CONNECTION 特権がある場合は、 プラスアイコン。 接続の作成 をクリックして、Oracle Eloqua への認証の構成からの認証情報を使用して接続を作成します。
  4. 次へ をクリックします。
  5. インジェスト設定 ページで、パイプラインの名前を入力します。
  6. イベントLogsを書き込むカタログとスキーマを選択します。カタログに対する USE CATALOG 権限と CREATE SCHEMA 権限がある場合は、ドロップダウンメニューの プラスアイコン。 スキーマの作成 をクリックしてスキーマを作成します。
  7. パイプラインの作成および続行 をクリックします。
  8. ソース ページで、取り込むテーブルを選択します。
  9. 保存して続行 をクリックします。
  10. 宛先 ページで、データを読み込むカタログとスキーマを選択します。カタログに対する USE CATALOG 権限と CREATE SCHEMA 権限がある場合は、ドロップダウンメニューの プラスアイコン。 スキーマの作成 をクリックしてスキーマを作成します。
  11. 保存して続行 をクリックします。
  12. (オプション) スケジュールと通知 ページで、 プラスアイコン。 スケジュールの作成 をクリックします。宛先テーブルを更新する頻度を設定します。
  13. (オプション) プラスアイコン。 通知の追加 をクリックして、パイプライン操作の成功または失敗に対するEメール通知を設定してから、 パイプラインの保存と実行 をクリックします。

例​

Oracle Eloquaコネクタは、そのソーステーブルを default ソーススキーマで利用可能にします。テーブルの一覧については、サポートされているソーステーブルを参照してください。個々のテーブルまたはスキーマ全体を取り込みます。

特定のテーブルを取り込む​

このオプションを使用して、テーブルの特定のサブセットを取り込んだり、テーブルごとに宛先の名前をカスタマイズしたりします。

次のパイプライン定義ファイルは、個別の Oracle Eloqua テーブルを取り込みます。

YAML
resources:
  pipelines:
    oracle_eloqua_pipeline:
      name: oracle_eloqua_pipeline
      catalog: 'main'
      target: 'oracle_eloqua_data'
      ingestion_definition:
        connection_name: oracle_eloqua_connection
        objects:
          - table:
              source_schema: 'default'
              source_table: 'contact'
              destination_catalog: 'main'
              destination_schema: 'oracle_eloqua_data'
              destination_table: 'contact'
          - table:
              source_schema: 'default'
              source_table: 'campaign'
              destination_catalog: 'main'
              destination_schema: 'oracle_eloqua_data'
              destination_table: 'campaign'
          - table:
              source_schema: 'default'
              source_table: 'form_submission'
              destination_catalog: 'main'
              destination_schema: 'oracle_eloqua_data'
              destination_table: 'form_submission'

特定の日付から取り込む​

start_datetime オプションを使用して、増分テーブルが最初の同期でどれだけ遡って読み取るかを制御します。

次のパイプライン定義ファイルは、特定の起動日から Oracle Eloqua テーブルを取り込みます。

YAML
resources:
  pipelines:
    oracle_eloqua_pipeline:
      name: oracle_eloqua_pipeline
      catalog: 'main'
      target: 'oracle_eloqua_data'
      ingestion_definition:
        connection_name: oracle_eloqua_connection
        source_configurations:
          - api_source_connector_config:
              configs:
                start_datetime: '<start-datetime>'
        objects:
          - table:
              source_schema: 'default'
              source_table: 'contact'
              destination_catalog: 'main'
              destination_schema: 'oracle_eloqua_data'
              destination_table: 'contact'
          - table:
              source_schema: 'default'
              source_table: 'form_submission'
              destination_catalog: 'main'
              destination_schema: 'oracle_eloqua_data'
              destination_table: 'form_submission'

スキーマ全体を取り込む​

このオプションを使用すると、すべての Oracle Eloqua ソーステーブルを 1 つの宣言で 1 つの宛先スキーマに取り込むことができます。

次のパイプライン定義ファイルは、サポートされているすべての Oracle Eloqua テーブルを宛先スキーマに取り込みます。

YAML
resources:
  pipelines:
    oracle_eloqua_pipeline:
      name: oracle_eloqua_pipeline
      catalog: 'main'
      target: 'oracle_eloqua_data'
      ingestion_definition:
        connection_name: oracle_eloqua_connection
        objects:
          - schema:
              source_schema: 'default'
              destination_catalog: 'main'
              destination_schema: 'oracle_eloqua_data'

宣言型オートメーションバンドルのジョブ定義ファイル​

次に示すのは、宣言型オートメーションバンドルで使用するジョブ定義ファイルの例です。ジョブは毎日ランされます。

YAML
resources:
  jobs:
    oracle_eloqua_job:
      name: oracle_eloqua_job
      schedule:
        quartz_cron_expression: '0 0 0 * * ?'
        timezone_id: 'UTC'
      tasks:
        - task_key: oracle_eloqua_ingestion
          pipeline_task:
            pipeline_id: ${resources.pipelines.oracle_eloqua_pipeline.id}

一般的なパターン​

高度なパイプライン構成については、「管理された取り込みパイプラインの一般的なパターン」を参照してください。

次のステップ​

パイプラインの起動、スケジュール、アラートを設定します。一般的なパイプラインのメンテナンス タスクを参照してください。

その他のリソース​

このページの見出し