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

Anysphere (Cursor) からデータを取り込む

備考

ベータ版

この機能はベータ版です。ワークスペース管理者は、 プレビュー ページからこの機能へのアクセスを制御できます。Databricksのプレビューを管理するを参照してください。

このページでは、Lakeflow Connect を使用して Anysphere Audit Logs の管理対象データ取り込みパイプラインを作成する方法を示します。

要件​

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

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

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

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

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

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

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

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

  • Anysphere Audit Logs から取り込むには、まず Databricks からの認証を構成する必要があります。「Anysphere (Cursor) への認証の構成」を参照してください。

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

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

例​

これらの例を使用して、パイプラインを構成してください。

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

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

YAML
resources:
  pipelines:
    anysphere_audit_logs_pipeline:
      name: anysphere_audit_logs_pipeline
      catalog: 'main'
      target: 'anysphere_audit_logs_data'
      ingestion_definition:
        connection_name: anysphere_audit_logs_connection
        objects:
          - schema:
              source_schema: 'default'
              destination_catalog: 'main'
              destination_schema: 'anysphere_audit_logs_data'

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

個々の Anysphere Audit Logsテーブルを取り込みます。サポートされているテーブルの完全なリストについては、サポートされているソーステーブルを参照してください。

次のパイプライン定義ファイルは、個々のAnysphere Audit Logsテーブルを取り込みます：

YAML
resources:
  pipelines:
    anysphere_audit_logs_pipeline:
      name: anysphere_audit_logs_pipeline
      catalog: 'main'
      target: 'anysphere_audit_logs_data'
      ingestion_definition:
        connection_name: anysphere_audit_logs_connection
        objects:
          - table:
              source_schema: 'default'
              source_table: 'audit_logs'
              destination_catalog: 'main'
              destination_schema: 'anysphere_audit_logs_data'
              destination_table: 'audit_logs'

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

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

一般的なパターン​

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

次のステップ​

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

その他のリソース​

このページの見出し