Openflow Connector for SharePoint を設定する¶

前提条件¶

1. Openflow Connector for SharePoint について を確認してください。

2. Ensure that you have Openflowの設定 - BYOC or Set up Openflow - Snowflake Deployments.

3. If using Openflow - Snowflake Deployments, ensure that you've reviewed configuring required domains and have granted access to the required domains for the SharePoint connector.

認証情報を取得する¶

SharePoint 管理者として、以下のアクションを実行します。

1. Ensure that you have a Microsoft Graph application with the appropriate Microsoft Graph permissions based on your use case:

   For ACL connectors:

   1. Sites.Selected: 指定したサイトのみにアクセスを制限します。

   2. Files. SelectedOperations .Selected: 指定されたサイトのファイルのみにアクセスを制限します。

   3. GroupMember .Read.All: SharePoint グループ権限の解決に使用します。

   4. User. ReadBasic .All:Microsoft365ユーザーのメールの解決に使用します。

   For no-ACL connectors:

   1. Sites.Selected: 指定したサイトのみにアクセスを制限します。

   2. Files. SelectedOperations .Selected: 指定されたサイトのファイルのみにアクセスを制限します。

   注釈

   No-ACL connectors do not fetch user permissions or group information, so they do not require the GroupMember.Read.All and User.ReadBasic.All permissions.

2. Configure SharePoint to enable OAuth authentication as described in Get access without a user. The connector uses the following Microsoft Graph APIs to fetch data from SharePoint:

   1. driveItemコンテンツをダウンロードする

   2. driveItemメタデータを取得する

   3. driveItem: delta

   4. driveItem権限を一覧表示する

   5. group: delta

   6. グループメンバーを一覧表示する

   7. ユーザーを取得する

3. Snowflakeに取り込みたいファイルやフォルダーがあるMicrosoft 365 SharePoint サイトのサイト URL、およびAzureまたはOffice 365アカウント管理者からの認証情報を取得します。

Snowflakeアカウントを設定する¶

Snowflakeアカウント管理者として、以下のタスクを手動で、または下記に含まれるスクリプトを使用して実行します。

1. 新しいロールを作成するか、既存のロールを使用して データベース権限 を付与します。

2. タイプを SERVICE として、新しいSnowflakeサービスユーザーを作成します。

3. Snowflakeサービスユーザーに、前の手順で作成したロールを付与します。

4. ステップ2のSnowflake SERVICE ユーザーを key-pair auth で構成します。

5. Snowflakeではこの手順を強く推奨します。Openflowがサポートするシークレットマネージャ（AWS、Azure、Hashicorpなど）を構成し、公開キーと秘密キーを秘密ストアに格納します。

   注釈

   何らかの理由でシークレットマネージャを使用したくない場合は、組織のセキュリティポリシーに従って、キーペア認証に使用する公開キーと秘密キーファイルを保護する責任があります。

   1. シークレットマネージャを構成したら、その認証方法を決定します。AWS 上では、Openflowに関連付けられた EC2 インスタンスロールが推奨されます。こうすることで、他の秘密を永続化する必要がなくなるからです。

   2. Openflowで、右上のハンバーガーメニューから、このシークレットマネージャーに関連付けられたパラメータープロバイダーを構成します。Controller Settings » Parameter Provider に移動してから、パラメーター値を取得します。

   3. この時点で、すべての認証情報を関連するパラメーターパスで参照することができるため、機密性の高い値をOpenflow内で永続化する必要はありません。

6. 他のSnowflakeユーザーが、コネクタによって取り込まれた生の取り込みドキュメントやとテーブルへのアクセスを必要とする場合は（Snowflakeでのカスタム処理のためなど）、それらのユーザーにステップ1で作成したロールを付与します。

7. コネクタが使用するウェアハウスを指定します。まずは最小のウェアハウスサイズから始め、複製するテーブルの数や転送するデータ量に応じて異なるサイズを試してみてください。テーブル数が大きい場合は、通常、ウェアハウスのサイズを大きくするよりも、 マルチクラスターウェアハウス を使用した方がスケーリングが向上します。

Use case 1: Ingest files only¶

Use a connector to:

• Ingest and continuously update Sharepoint files for custom processing within Snowflake

• Optionally ingest file permissions (ACL connectors) to persist access controls downstream

Use case 2: Ingest files and perform processing with Cortex¶

事前定義されたフロー定義を使用して、次を行います。

• Create AI assistants for documents within your organization's SharePoint site

• Enable your AI assistants to adhere to access controls specified in your organization's SharePoint site

ユースケース3: コネクタ定義をカスタマイズする¶

コネクタ定義をカスタマイズして、次を実行します。

• Document AI で、取り込んだファイルを処理します。

• 取り込んだファイルにカスタム処理を実行します。

Sharepointサイトグループの有効化¶

Cortex Search serviceをクエリする¶

Cortex Search サービスを利用して、チャットや検索アプリケーションを構築し、 SharePoint のドキュメントとチャットしたり、クエリしたりすることができます。

コネクタをインストールして構成し、Sharepointからコンテンツの取り込みを開始すると、Cortex Searchサービスをクエリできます。Cortex Searchの使用に関する詳細については、 Cortex Search Serviceをクエリする をご参照ください。

応答をフィルターする

Cortex Searchサービスからの応答を特定のユーザーが SharePoint でアクセスできるドキュメントに制限するには、Cortex Searchのクエリ時に、そのユーザーのユーザー ID またはメールアドレスを含むフィルターを指定することができます。例えば、 filter.@contains.user_ids または filter.@contains.user_emails のようにします。コネクタによって作成されるCortex Searchサービスの名前は、スキーマ Cortex の search_service です。

SQL ワークシート内で以下の SQL コードを実行し、 SharePoint サイトから取り込んだファイルでCortex Searchサービスをクエリします。

以下を置き換えます。

• application_instance_name: データベースとコネクタアプリケーションインスタンスの名前。

• user_emailID: 応答をフィルターしたいユーザーのメール ID。

• your_question: 応答を得たい質問。

• number_of_results: 応答で返す結果の最大数。最大値は1000で、デフォルト値は10です。

SELECT PARSE_JSON(
  SNOWFLAKE.CORTEX.SEARCH_PREVIEW(
    '<application_instance_name>.cortex.search_service',
      '{
        "query": "<your_question>",
         "columns": ["chunk", "web_url"],
         "filter": {"@contains": {"user_emails": "<user_emailID>"} },
         "limit": <number_of_results>
       }'
   )
)['results'] AS results

columns に入力できる値の完全なリストを以下に示します。

For all connectors:

For ACL connectors only:

例: AI アシスタントに人事（HR）情報をクエリする

Cortex Searchを使用して、オンボーディング、行動規範、チームプロセス、組織ポリシーなど、 HR の最新バージョンの情報とチャットする従業員向けの AI アシスタントをクエリできます。応答フィルターを使用すると、 SharePoint で構成したアクセス制御を順守しながら、 HR チームメンバーに従業員契約のクエリを許可することもできます。

SELECT PARSE_JSON(
     SNOWFLAKE.CORTEX.SEARCH_PREVIEW(
          '<application_instance_name>.cortex.search_service',
          '{
             "query": "What is my vacation carry over policy?",
             "columns": ["chunk", "web_url"],
             "filter": {"@contains": {"user_emails": "<user_emailID>"} },
             "limit": 1
          }'
     )
 )['results'] AS results

import snowflake.snowpark as snowpark
from snowflake.snowpark import Session
from snowflake.core import Root

def main(session: snowpark.Session):

   root = Root(session)

   # fetch service
   my_service = (root
     .databases["<application_instance_name>"]
     .schemas["cortex"]
     .cortex_search_services["search_service"]
   )

   # query service
   resp = my_service.search(
     query="What is my vacation carry over policy?",
     columns = ["chunk", "web_url"],
     filter = {"@contains": {"user_emails": "<user_emailID>"} },
     limit=1
   )
   return (resp.to_json())

curl --location "https://<account_url>/api/v2/databases/<application_instance_name>/schemas/cortex/cortex-search-services/search_service" \
     --header 'Content-Type: application/json' \
     --header 'Accept: application/json' \
     --header "Authorization: Bearer <CORTEX_SEARCH_JWT>" \
     --data '{
         "query": "What is my vacation carry over policy?",
         "columns": ["chunk", "web_url"],
         "limit": 1
     }'

{
  "results" : [ {
  "web_url" : "https://<domain>.sharepoint.com/sites/<site_name>/<path_to_file>",
  "chunk" : "Answer to the question asked."
  } ]
}

ステージ内のファイルの検索¶

ステージに格納されているファイルには、読み取れない名前が付けられている場合があります。特定のファイルを見つけるには、メタデータテーブルを信頼できる情報源として使用します。これらのテーブルには、ファイル名と対応するファイル間のマッピングが含まれています IDs ステージでの。

Cortexが有効なセットアップの場合は、以下のクエリを使ってファイルを検索します。

SELECT DISTINCT METADATA:id FROM DOCS_CHUNKS WHERE METADATA:fullName LIKE '%<file_name>%';

Cortex以外のセットアップの場合は、以下のクエリを使います。

SELECT FILE_ID FROM DOC_METADATA WHERE FILE_NAME = '<file_name>';

<file_name> 探しているファイルの名前または部分的な名前を持つ。

ステージ内のファイルは で始まる ID これらのクエリから返された。