重新整理醫療照護資料

REST

1. 執行增量匯入。

   curl -X POST \
   -H "Authorization: Bearer $(gcloud auth print-access-token)" \
   -H "Content-Type: application/json; charset=utf-8" \
   -H "X-Goog-User-Project: PROJECT_ID" \
   "https://us-discoveryengine.googleapis.com/v1alpha/projects/PROJECT_ID/locations/us/dataStores/DATA_STORE_ID/branches/0/documents:import" \
   -d '{
      "reconciliation_mode": "INCREMENTAL",
      "fhir_store_source": {"fhir_store": "projects/PROJECT_ID/locations/CLOUD_HEALTHCARE_DATASET_LOCATION/datasets/CLOUD_HEALTHCARE_DATASET_ID/fhirStores/FHIR_STORE_ID"}
   }'
   

   更改下列內容：

   • PROJECT_ID：您的 Google Cloud 專案 ID。
   • DATA_STORE_ID：Vertex AI Search 資料儲存庫的 ID。
   • CLOUD_HEALTHCARE_DATASET_ID：包含來源 FHIR 儲存庫的 Cloud Healthcare API 資料集 ID。
   • CLOUD_HEALTHCARE_DATASET_LOCATION：包含來源 FHIR 儲存庫的 Cloud Healthcare API 資料集位置。
   • ：Cloud Healthcare API FHIR R4 存放區的 ID。FHIR_STORE_ID

   回應

   您應該會收到類似如下的 JSON 回應。回應會包含長時間執行作業的 ID。如果方法呼叫可能需要大量時間才能完成，就會傳回長時間執行的作業。請記下 IMPORT_OPERATION_ID 的值。您需要這個值來驗證匯入狀態。

     {
       "name": "projects/PROJECT_ID/locations/us/collections/default_collection/dataStores/DATA_STORE_ID/branches/0/operations/IMPORT_OPERATION_ID",
       "metadata": {
         "@type": "type.googleapis.com/google.cloud.discoveryengine.v1alpha.ImportDocumentsMetadata"
       }
     }
   

2. 確認 FHIR 資料匯入作業是否完成。

   curl -X GET \
   -H "Authorization: Bearer $(gcloud auth print-access-token)" \
   "https://us-discoveryengine.googleapis.com/v1alpha/projects/PROJECT_ID/locations/us/collections/default_collection/dataStores/DATA_STORE_ID/branches/0/operations/IMPORT_OPERATION_ID"
   

   更改下列內容：

   • PROJECT_ID：您的 Google Cloud 專案 ID。
   • DATA_STORE_ID：Vertex AI Search 資料儲存庫的 ID。
   • IMPORT_OPERATION_ID：呼叫 import 方法時傳回的長時間執行作業 ID。

   回應

   您應該會收到類似如下的 JSON 回應：匯入作業是長時間執行的作業。作業執行期間，回應會包含下列欄位：

   • successCount：表示目前成功匯入的 FHIR 資源數量。
   • failureCount：表示目前匯入失敗的 FHIR 資源數量。只有在有 FHIR 資源無法匯入時，才會顯示這個欄位。

   作業完成後，回應會包含下列欄位：

   • successCount：表示成功匯入的 FHIR 資源數量。
   • failureCount：表示匯入失敗的 FHIR 資源數量。只有在有 FHIR 資源無法匯入時，才會顯示這個欄位。
   • totalCount：表示來源 FHIR 儲存庫中的 FHIR 資源數量。只有在有 FHIR 資源無法匯入時，才會顯示這個欄位。
   • done：值為 true，表示匯入作業已完成
   • errorSamples：提供無法匯入的資源相關資訊。只有在有 FHIR 資源無法匯入時，才會顯示這個欄位。
   • errorConfig：提供包含錯誤摘要記錄檔的 Cloud Storage 位置路徑。

   {
    "name": "projects/PROJECT_ID/locations/us/collections/default_collection/dataStores/DATA_STORE_ID/branches/0/operations/IMPORT_OPERATION_ID",
    "metadata": {
      "@type": "type.googleapis.com/google.cloud.discoveryengine.v1alpha.ImportDocumentsMetadata",
      "createTime": "START_TIMESTAMP",
      "updateTime": "END_TIMESTAMP",
      "successCount": "SUCCESS_COUNT",
      "failureCount": "FAILURE_COUNT",
      "totalCount": "TOTAL_COUNT",
    },
    "done": true,
    "response": {
      "@type": "type.googleapis.com/google.cloud.discoveryengine.v1alpha.ImportDocumentsResponse",
     "errorSamples": [ERROR_SAMPLE],
     "errorConfig": {
        "gcsPrefix": "LOG_FILE_LOCATION"
      }
    }
   }
   

Python

詳情請參閱 AI Applications Python API 參考說明文件。

如要向 AI Applications 進行驗證，請設定應用程式預設憑證。 詳情請參閱「為本機開發環境設定驗證」。

from google.api_core.client_options import ClientOptions
from google.cloud import discoveryengine

# TODO(developer): Uncomment these variables before running the sample.
# project_id = "YOUR_PROJECT_ID"
# location = "YOUR_LOCATION" # Values: "us"
# data_store_id = "YOUR_DATA_STORE_ID"
# healthcare_project_id = "YOUR_HEALTHCARE_PROJECT_ID"
# healthcare_location = "YOUR_HEALTHCARE_LOCATION"
# healthcare_dataset_id = "YOUR_HEALTHCARE_DATASET_ID"
# healthcare_fihr_store_id = "YOUR_HEALTHCARE_FHIR_STORE_ID"

#  For more information, refer to:
# https://cloud.google.com/generative-ai-app-builder/docs/locations#specify_a_multi-region_for_your_data_store
client_options = (
    ClientOptions(api_endpoint=f"{location}-discoveryengine.googleapis.com")
    if location != "global"
    else None
)

# Create a client
client = discoveryengine.DocumentServiceClient(client_options=client_options)

# The full resource name of the search engine branch.
# e.g. projects/{project}/locations/{location}/dataStores/{data_store_id}/branches/{branch}
parent = client.branch_path(
    project=project_id,
    location=location,
    data_store=data_store_id,
    branch="default_branch",
)

request = discoveryengine.ImportDocumentsRequest(
    parent=parent,
    fhir_store_source=discoveryengine.FhirStoreSource(
        fhir_store=client.fhir_store_path(
            healthcare_project_id,
            healthcare_location,
            healthcare_dataset_id,
            healthcare_fihr_store_id,
        ),
    ),
    # Options: `FULL`, `INCREMENTAL`
    reconciliation_mode=discoveryengine.ImportDocumentsRequest.ReconciliationMode.INCREMENTAL,
)

# Make the request
operation = client.import_documents(request=request)

print(f"Waiting for operation to complete: {operation.operation.name}")
response = operation.result()

# After the operation is complete,
# get information from operation metadata
metadata = discoveryengine.ImportDocumentsMetadata(operation.metadata)

# Handle the response
print(response)
print(metadata)