ヘルスケア検索データストアを管理する

ヘルスケア データストアを作成して FHIR R4 データをインポートしたら、次のオペレーションを実行して管理できます。

バッチ インポートをキャンセルする

進行中のバッチ インポート オペレーションをキャンセルするには、次の操作を行います。

REST

  1. バッチ インポート オペレーションのオペレーション ID を確認します。このオペレーション ID は、データストアにデータをインポートしたときに返された ID と同じです。オペレーション ID がすでにある場合は、次のステップに進みます。

    1. Google Cloud コンソールで [Agent Builder] ページに移動し、ナビゲーション メニューで [データストア] をクリックします。

      [データストア] ページに移動

    2. インポートをキャンセルするデータストアをクリックします。

    3. データストアの詳細ページで、[詳細を表示] をクリックします。この操作は、インポート オペレーションが作成され、処理中になってからのみ使用できます。

    4. [アクティビティ ログの詳細] パネルで、オペレーション ID を取得します。

  2. 進行中のバッチ インポートをキャンセルします。

    curl -X POST \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/json" \
    -H "X-Goog-User-Project: PROJECT_ID" \
    "https://us-discoveryengine.googleapis.com/v1/projects/PROJECT_ID/locations/us/collections/default_collection/dataStores/DATA_STORE_ID/branches/0/operations/OPERATION_ID:cancel" \
    

    次のように置き換えます。

    • PROJECT_ID: Google Cloud プロジェクトの ID。
    • DATA_STORE_ID: 進行中の一括インポートをキャンセルするデータストアの ID。
    • IMPORT_OPERATION_ID: キャンセルする進行中の一括インポート オペレーションの ID。

    オペレーションが正常にキャンセルされると、空の JSON オブジェクトが返されます。

ストリーミングを一時停止または再開する

ストリーミング オペレーションを一時停止または再開するには、次の操作を行います。

Console

  1. Google Cloud コンソールで、[Agent Builder] ページに移動します。

    Agent Builder

  2. ナビゲーション メニューで [データストア] をクリックします。

    [データストア] ページには、プロジェクト内のデータストアのリストと詳細が表示されます。 Google Cloud

  3. ストリーミングを一時停止または再開するデータストアをクリックします。

  4. データコネクタの [データ] ページで、 [データ ストリーミングを一時停止] をクリックしてストリーミングを一時停止するか、 [データ ストリーミングを再開] をクリックしてデータ ストリーミングを再開します。

REST

  1. コレクション ID を確認します。コレクション ID がすでにある場合は、次のステップに進みます。

    1. Google Cloud コンソールで [Agent Builder] ページに移動し、ナビゲーション メニューで [データストア] をクリックします。

      [データストア] ページに移動

    2. ストリーミングを一時停止または再開するデータ コネクタの名前をクリックします。

    3. データ コネクタの [データ] ページで、コレクション ID を取得します。

  2. データコネクタ内でストリーミングを一時停止または再開する。

    curl -X PATCH \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/json" \
    -H "X-Goog-User-Project: PROJECT_ID" \
    "https://us-discoveryengine.googleapis.com/v1/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector?updateMask=auto_run_disabled" \
    -d ' {
      "name":"projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector",
      "autoRunDisabled": PAUSE_STREAM_TRUE|FALSE
    }'
    

    次のように置き換えます。

    • PROJECT_ID: Google Cloud プロジェクトの ID。
    • COLLECTION_ID: ストリーミングを一時停止または再開するデータ コネクタの ID。
    • PAUSE_STREAM_TRUE|FALSE: ブール値。true に設定するとストリーミングが一時停止され、false に設定すると一時停止したストリーミングが再開されます。

ストリーミング データストア内のすべてのドキュメントを同期する

サポートされている FHIR リソースタイプを持つすべてのドキュメントに対して、バックフィルを手動でトリガーできます。これにより、Vertex AI Search データストアを Cloud Healthcare API FHIR ストアと最新の状態に保つことができます。データの同期は、ストリーミング データストアでのみ可能です。

ストリーミング データストア内のすべてのドキュメントを同期するには、次の操作を行います。

Console

  1. Google Cloud コンソールで、[Agent Builder] ページに移動します。

    Agent Builder

  2. ナビゲーション メニューで [データストア] をクリックします。

    [データストア] ページには、プロジェクト内のデータストアのリストと詳細が表示されます。 Google Cloud

  3. 同期するデータ コネクタを選択します。

  4. データストアの詳細ページで、 [再インポート] をクリックします。

  5. [データを再インポート] ペインで をクリックし、データを同期する日付を選択して、[閉じる] をクリックします。

  6. [再インポートするリソース] セクションで、すべての FHIR リソースタイプを選択します。これにより、サポートされている FHIR リソースタイプですべてのドキュメントがバックフィルされます。

  7. [再インポート] をクリックします。

REST

  1. コレクション ID を確認します。コレクション ID がすでにある場合は、次のステップに進みます。

    1. Google Cloud コンソールで [Agent Builder] ページに移動し、ナビゲーション メニューで [データストア] をクリックします。

      [データストア] ページに移動

    2. ストリーミングを一時停止または再開するデータ コネクタの名前をクリックします。

    3. データ コネクタの [データ] ページで、コレクション ID を取得します。

  2. サポートされている FHIR リソースタイプを持つすべてのドキュメントの同期またはバックフィルをトリガーします。

    curl -X POST \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/json" \
    -H "X-Goog-User-Project: PROJECT_ID" \
    "https://us-discoveryengine.googleapis.com/v1/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector:startConnectorRun" \
    -d ' {
      "syncSinceTimestamp": {}
    }'
    

    次のように置き換えます。

    • PROJECT_ID: Google Cloud プロジェクトの ID。
    • COLLECTION_ID: ストリーミングを一時停止または再開するコレクションの ID。

    実行中の startConnectorRun メソッドを再度呼び出すと、エラーが発生することがあります。

ストリーミング データストア内の一部のドキュメントを同期する

サポートされている FHIR リソースタイプを使用して、選択したドキュメントをインポートできます。これは、特定の FHIR リソースタイプのドキュメントで Vertex AI Search データストアを更新する場合に便利です。データの同期は、ストリーミング データストアでのみ可能です。

ストリーミング データストア内の選択したドキュメントを同期するには、次の操作を行います。

Console

  1. Google Cloud コンソールで、[Agent Builder] ページに移動します。

    Agent Builder

  2. ナビゲーション メニューで [データストア] をクリックします。

    [データストア] ページには、プロジェクト内のデータストアのリストと詳細が表示されます。 Google Cloud

  3. 同期するデータ コネクタを選択します。

  4. データストアの詳細ページで、 [再インポート] をクリックします。

  5. [データを再インポートする] ペインで をクリックし、データを同期する日付を選択して、[閉じる] をクリックします。

  6. [再インポートするリソース] セクションで、インポートする FHIR リソースタイプをすべて選択します。これにより、選択した FHIR リソースタイプのすべてのドキュメントがインポートされます。

  7. [再インポート] をクリックします。

REST

  1. コレクション ID を確認します。コレクション ID がすでにある場合は、次のステップに進みます。

    1. Google Cloud コンソールで [Agent Builder] ページに移動し、ナビゲーション メニューで [データストア] をクリックします。

      [データストア] ページに移動

    2. ストリーミングを一時停止または再開するデータ コネクタの名前をクリックします。

    3. データ コネクタの [データ] ページで、コレクション ID を取得します。

  2. サポートされている FHIR リソースタイプを使用して、選択したドキュメントの同期またはバックフィルをトリガーします。

    curl -X POST \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/json" \
    -H "X-Goog-User-Project: PROJECT_ID" \
    "https://us-discoveryengine.googleapis.com/v1/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector:startConnectorRun" \
    -d ' {
      "syncSinceTimestamp": {},
      "healthcareFhirResourceTypes": "Patient",
      "healthcareFhirResourceTypes": "RESOURCE_TYPE"
    }'
    

    次のように置き換えます。

    • PROJECT_ID: Google Cloud プロジェクトの ID。
    • COLLECTION_ID: ストリーミングを一時停止または再開するコレクションの ID。
    • RESOURCE_TYPE: バックフィルする FHIR ドキュメントのリソースタイプ。

    実行中の startConnectorRun メソッドを再度呼び出すと、エラーが発生することがあります。

ストリーミング データストアで指定されたタイムスタンプ以降のドキュメントを同期する

指定したタイムスタンプ以降の、サポートされている FHIR リソースタイプを含むドキュメントを選択してインポートできます。データの同期は、ストリーミング データストアでのみ可能です。

特定のタイムスタンプ以降のドキュメントを同期するには、次の操作を行います。

Console

  1. Google Cloud コンソールで、[Agent Builder] ページに移動します。

    Agent Builder

  2. ナビゲーション メニューで [データストア] をクリックします。

    [データストア] ページには、プロジェクト内のデータストアのリストと詳細が表示されます。 Google Cloud

  3. 同期するデータ コネクタを選択します。

  4. データストアの詳細ページで、 [再インポート] をクリックします。

  5. [データを再インポートする] ペインで をクリックし、データを同期する日付を選択して、[閉じる] をクリックします。

  6. [再インポートするリソース] セクションで、インポートする FHIR リソースタイプをすべて選択します。これにより、選択した FHIR リソースタイプのすべてのドキュメントがインポートされます。

  7. [再インポート] をクリックします。

REST

  1. コレクション ID を確認します。コレクション ID がすでにある場合は、次のステップに進みます。

    1. Google Cloud コンソールで [Agent Builder] ページに移動し、ナビゲーション メニューで [データストア] をクリックします。

      [データストア] ページに移動

    2. ストリーミングを一時停止または再開するデータ コネクタの名前をクリックします。

    3. データ コネクタの [データ] ページで、コレクション ID を取得します。

  2. サポートされている FHIR リソースタイプを持つすべてのドキュメントの同期またはバックフィルをトリガーします。

    curl -X POST \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/json" \
    -H "X-Goog-User-Project: PROJECT_ID" \
    "https://us-discoveryengine.googleapis.com/v1/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector:startConnectorRun" \
    -d ' {
      "syncSinceTimestamp": {
        "seconds": TIMESTAMP_SECONDS,
        "nanos": TIMESTAMP_NANOS
      }
    }'
    

    次のように置き換えます。

    • PROJECT_ID: Google Cloud プロジェクトの ID。
    • COLLECTION_ID: ストリーミングを一時停止または再開するコレクションの ID。
    • TIMESTAMP_SECONDS: ドキュメントのインポート元のタイムスタンプからの秒数。タイムスタンプ形式に従います。
    • TIMESTAMP_NANOS: ドキュメントのインポート元のタイムスタンプからの秒数。タイムスタンプ形式に従います。

    実行中の startConnectorRun メソッドを再度呼び出すと、エラーが発生することがあります。

ストリーミングを削除する

ストリーミング オペレーションを削除するには、次の操作を行います。

Console

  1. Google Cloud コンソールで、[Agent Builder] ページに移動します。

    Agent Builder

  2. ナビゲーション メニューで [データストア] をクリックします。

    [データストア] ページには、プロジェクト内のデータストアのリストと詳細が表示されます。 Google Cloud

  3. データストアのリストで、削除するデータ コネクタの [その他のオプション] をクリックします。

  4. [削除] をクリックします。

  5. 表示されたダイアログで「yes」と入力し、[確認] をクリックして削除を確定します。

REST

  1. コレクション ID を確認します。コレクション ID がすでにある場合は、次のステップに進みます。

    1. Google Cloud コンソールで [Agent Builder] ページに移動し、ナビゲーション メニューで [データストア] をクリックします。

      [データストア] ページに移動

    2. ストリーミングを一時停止または再開するデータ コネクタの名前をクリックします。

    3. データ コネクタの [データ] ページで、コレクション ID を取得します。

  2. サポートされている FHIR リソースタイプを持つすべてのドキュメントの同期またはバックフィルをトリガーします。

    curl -X POST \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/json" \
    -H "X-Goog-User-Project: PROJECT_ID" \
    "https://us-discoveryengine.googleapis.com/v1/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector:startConnectorRun" \
    -d ' {
      "syncSinceTimestamp": {
        "seconds": TIMESTAMP_SECONDS,
        "nanos": TIMESTAMP_NANOS
      }
    }'
    

    次のように置き換えます。

    • PROJECT_ID: Google Cloud プロジェクトの ID。
    • COLLECTION_ID: ストリーミングを一時停止または再開するコレクションの ID。
    • TIMESTAMP_SECONDS: ドキュメントのインポート元のタイムスタンプからの秒数。タイムスタンプ形式に従います。
    • TIMESTAMP_NANOS: ドキュメントのインポート元のタイムスタンプからの秒数。タイムスタンプ形式に従います。

    実行中の startConnectorRun メソッドを再度呼び出すと、エラーが発生することがあります。