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

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

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

進行中のバッチ インポート オペレーションをキャンセルする手順は次のとおりです。

REST

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

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

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

    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 オブジェクトが返されます。

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

ストリーミング オペレーションを一時停止または再開する手順は次のとおりです。

コンソール

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

    AI Applications

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

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

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

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

REST

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

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

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

    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|FALSEtrue に設定するとストリーミングが一時停止され、false に設定すると一時停止したストリーミングが再開されるブール値。

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

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

ストリーミング データストア内のすべてのドキュメントを同期する手順は次のとおりです。

コンソール

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

    AI Applications

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

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

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

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

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

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

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

REST

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

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

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

    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/v1alpha/projects/PROJECT_ID/locations/us/collections/COLLECTION_ID/dataConnector:startConnectorRun" \
    -d ' {
      "syncSinceTimestamp": {}
    }'
    

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

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

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

ストリーミング データストア内の選択したドキュメントを同期する

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

ストリーミング データストア内の選択したドキュメントを同期する手順は次のとおりです。

コンソール

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

    AI Applications

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

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

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

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

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

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

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

REST

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

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

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

    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/v1alpha/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 リソースタイプを使用して、指定したタイムスタンプ以降の選択したドキュメントをインポートできます。データの同期は、ストリーミング データストアでのみ可能です。

指定したタイムスタンプ以降のドキュメントを同期する手順は次のとおりです。

コンソール

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

    AI Applications

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

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

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

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

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

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

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

REST

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

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

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

    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/v1alpha/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 形式に従います。
    • TIMESTAMP_NANOS: ドキュメントのインポートを開始するタイムスタンプの値(秒単位)。Timestamp 形式に従います。

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

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

ストリーミング オペレーションを削除する手順は次のとおりです。

コンソール

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

    AI Applications

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

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

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

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

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

REST

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

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

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

    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/v1alpha/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 形式に従います。
    • TIMESTAMP_NANOS: ドキュメントのインポートを開始するタイムスタンプの値(秒単位)。Timestamp 形式に従います。

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