Trasmissione e sincronizzazione di risorse FHIR con BigQuery

Questo tutorial illustra gli scenari in cui è possibile utilizzare i flussi di dati BigQuery per mantenere sincronizzato un archivio FHIR con un set di dati BigQuery quasi in tempo reale.

Obiettivi

Il tutorial illustra i seguenti passaggi:

Configura le autorizzazioni BigQuery.
Creare un archivio FHIR e aggiungere risorse Patient.
Configurare il flusso di dati BigQuery nell'archivio FHIR.
Verifica la configurazione di flussi di dati in BigQuery.
Esporta le risorse FHIR esistenti in BigQuery.
Trasmetti il flusso di risorse da più archivi FHIR allo stesso set di dati BigQuery.

Prima di iniziare

Accedi al tuo account Google Cloud. Se non conosci Google Cloud, crea un account per valutare le prestazioni dei nostri prodotti in scenari reali. I nuovi clienti ricevono anche 300 $di crediti gratuiti per l'esecuzione, il test e il deployment dei carichi di lavoro.

Nella pagina del selettore di progetti della console Google Cloud, seleziona o crea un progetto Google Cloud.

Vai al selettore progetti

Assicurati che la fatturazione sia attivata per il tuo progetto Google Cloud.

Nella pagina del selettore di progetti della console Google Cloud, seleziona o crea un progetto Google Cloud.

Vai al selettore progetti

Assicurati che la fatturazione sia attivata per il tuo progetto Google Cloud.

Attiva Cloud Healthcare API.
Abilita l'API

Installa Google Cloud CLI.
Per initialize gcloud CLI, esegui questo comando:
```
gcloud init
```

Passaggio 1: configura le autorizzazioni BigQuery

Per trasmettere le modifiche alle risorse FHIR in BigQuery, devi concedere autorizzazioni aggiuntive all'account di servizio dell'agente di servizio Cloud Healthcare. Per ulteriori informazioni, consulta Autorizzazioni BigQuery per gli archivi FHIR.

Passaggio 2: configura e verifica il flusso di dati BigQuery

Per attivare il flusso di dati in BigQuery, segui queste istruzioni:

crea un archivio FHIR e aggiungi risorse Patient

Per creare un archivio FHIR e aggiungere due risorse Patient, segui questi passaggi:

Crea l'archivio FHIR:
REST

Prima di utilizzare i dati della richiesta, effettua le seguenti sostituzioni:
- PROJECT_ID: l'ID del tuo progetto Google Cloud
- LOCATION: la posizione del set di dati
- DATASET_ID: set di dati padre dell'archivio FHIR
- FHIR_STORE_ID: un identificatore per l'archivio FHIR. L'ID archivio FHIR deve avere i seguenti valori:
  
  Un ID univoco nel relativo set di dati
  
  Una stringa Unicode di 1-256 caratteri composta dai seguenti elementi:
  
  Numeri
  
  Lettere
  
  Trattini bassi
  
  Trattini
  
  Punti
- FHIR_STORE_VERSION: la versione FHIR dell'archivio FHIR. Le opzioni disponibili sono DSTU2, STU3 o R4.
Corpo JSON richiesta:
{ "version": "FHIR_STORE_VERSION" }
Per inviare la richiesta, scegli una delle seguenti opzioni:
arricciare

Nota: il seguente comando presuppone che tu abbia eseguito l'accesso all'interfaccia a riga di comando di gcloud con il tuo account utente eseguendo gcloud init o gcloud auth login oppure utilizzando Cloud Shell, che ti permette di accedere automaticamente all'interfaccia a riga di comando di gcloud. Puoi controllare l'account attualmente attivo eseguendo gcloud auth list.

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

cat > request.json << 'EOF' { "version": "FHIR_STORE_VERSION" } EOF

Quindi esegui questo comando per inviare la richiesta REST:

curl -X POST \
-H "Authorization: Bearer $(gcloud auth print-access-token)" \
-H "Content-Type: application/json; charset=utf-8" \
-d @request.json \
"https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores?fhirStoreId=FHIR_STORE_ID"

PowerShell

Nota: il seguente comando presuppone che tu abbia eseguito l'accesso all'interfaccia a riga di comando di gcloud con il tuo account utente eseguendo gcloud init o gcloud auth login oppure utilizzando Cloud Shell, che ti permette di accedere automaticamente all'interfaccia a riga di comando di gcloud. Puoi controllare l'account attualmente attivo eseguendo gcloud auth list.

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

@' { "version": "FHIR_STORE_VERSION" } '@ | Out-File -FilePath request.json -Encoding utf8

Quindi esegui questo comando per inviare la richiesta REST:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
-Method POST `
-Headers $headers `
-ContentType: "application/json; charset=utf-8" `
-InFile request.json `
-Uri "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores?fhirStoreId=FHIR_STORE_ID" | Select-Object -Expand Content

Esplora API

Copia il corpo della richiesta e apri la pagina di riferimento del metodo. Il riquadro Explorer API si apre sul lato destro della pagina. Puoi interagire con questo strumento per inviare richieste. Incolla il corpo della richiesta in questo strumento, compila gli altri campi obbligatori e fai clic su Esegui.
Dovresti ricevere una risposta JSON simile alla seguente:
Risposta

{ "name": "projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID", "version": "FHIR_STORE_VERSION" }

Crea la prima risorsa Patient nell'archivio FHIR:

REST

Prima di utilizzare i dati della richiesta, effettua le seguenti sostituzioni:

PROJECT_ID: l'ID del tuo progetto Google Cloud
LOCATION: la posizione del set di dati
DATASET_ID: set di dati padre dell'archivio FHIR
FHIR_STORE_ID: l'ID archivio FHIR

Corpo JSON richiesta:

{
  "name": [
    {
      "use": "official",
      "family": "Smith",
      "given": [
        "Darcy"
      ]
    }
  ],
  "gender": "female",
  "birthDate": "1970-01-01",
  "resourceType": "Patient"
}

Per inviare la richiesta, scegli una delle seguenti opzioni:

arricciare

Nota: il seguente comando presuppone che tu abbia eseguito l'accesso all'interfaccia a riga di comando di gcloud con il tuo account utente eseguendo gcloud init o gcloud auth login oppure utilizzando Cloud Shell, che ti permette di accedere automaticamente all'interfaccia a riga di comando di gcloud. Puoi controllare l'account attualmente attivo eseguendo gcloud auth list.

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

cat > request.json << 'EOF'
{
  "name": [
    {
      "use": "official",
      "family": "Smith",
      "given": [
        "Darcy"
      ]
    }
  ],
  "gender": "female",
  "birthDate": "1970-01-01",
  "resourceType": "Patient"
}
EOF

Quindi esegui questo comando per inviare la richiesta REST:

curl -X POST \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/fhir+json" \
    -d @request.json \
    "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient"

PowerShell

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

@'
{
  "name": [
    {
      "use": "official",
      "family": "Smith",
      "given": [
        "Darcy"
      ]
    }
  ],
  "gender": "female",
  "birthDate": "1970-01-01",
  "resourceType": "Patient"
}
'@  | Out-File -FilePath request.json -Encoding utf8

Quindi esegui questo comando per inviare la richiesta REST:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -ContentType: "application/fhir+json" `
    -InFile request.json `
    -Uri "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient" | Select-Object -Expand Content

Dovresti ricevere una risposta JSON simile alla seguente:

Risposta

{
  "birthDate": "1970-01-01",
  "gender": "female",
  "id": "PATIENT_ID",
  "meta": {
    "lastUpdated": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ",
    "versionId": "VERSION_ID"
  },
  "name": [
    {
      "family": "Smith",
      "given": [
        "Darcy"
      ],
      "use": "official"
    }
  ],
  "resourceType": "Patient"
}

Crea la seconda risorsa Patient nell'archivio FHIR:

REST

Prima di utilizzare i dati della richiesta, effettua le seguenti sostituzioni:

PROJECT_ID: l'ID del tuo progetto Google Cloud
LOCATION: la posizione del set di dati padre
DATASET_ID: set di dati padre dell'archivio FHIR
FHIR_STORE_ID: l'ID archivio FHIR

Corpo JSON richiesta:

{
  "name": [
    {
      "use": "official",
      "family": "Zhang",
      "given": [
        "Michael"
      ]
    }
  ],
  "gender": "male",
  "birthDate": "1980-01-01",
  "resourceType": "Patient"
}

Per inviare la richiesta, scegli una delle seguenti opzioni:

arricciare

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

cat > request.json << 'EOF'
{
  "name": [
    {
      "use": "official",
      "family": "Zhang",
      "given": [
        "Michael"
      ]
    }
  ],
  "gender": "male",
  "birthDate": "1980-01-01",
  "resourceType": "Patient"
}
EOF

Quindi esegui questo comando per inviare la richiesta REST:

curl -X POST \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/fhir+json" \
    -d @request.json \
    "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient"

PowerShell

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

@'
{
  "name": [
    {
      "use": "official",
      "family": "Zhang",
      "given": [
        "Michael"
      ]
    }
  ],
  "gender": "male",
  "birthDate": "1980-01-01",
  "resourceType": "Patient"
}
'@  | Out-File -FilePath request.json -Encoding utf8

Quindi esegui questo comando per inviare la richiesta REST:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -ContentType: "application/fhir+json" `
    -InFile request.json `
    -Uri "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient" | Select-Object -Expand Content

Dovresti ricevere una risposta JSON simile alla seguente:

Risposta

{
  "birthDate": "1980-01-01",
  "gender": "male",
  "id": "PATIENT_ID",
  "meta": {
    "lastUpdated": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ",
    "versionId": "VERSION_ID"
  },
  "name": [
    {
      "family": "Zhang",
      "given": [
        "Michael"
      ],
      "use": "official"
    }
  ],
  "resourceType": "Patient"
}

Cerca le risorse Patient nell'archivio FHIR e verifica che l'archivio contenga le due risorse Patient:

REST

Prima di utilizzare i dati della richiesta, effettua le seguenti sostituzioni:

PROJECT_ID: l'ID del tuo progetto Google Cloud
LOCATION: la posizione del set di dati padre
DATASET_ID: set di dati padre dell'archivio FHIR
FHIR_STORE_ID: l'ID archivio FHIR

Per inviare la richiesta, scegli una delle seguenti opzioni:

arricciare

Esegui questo comando:

curl -X GET \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient"

PowerShell

Esegui questo comando:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method GET `
    -Headers $headers `
    -Uri "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient" | Select-Object -Expand Content

Dovresti ricevere una risposta JSON simile alla seguente:

Risposta

{
  "entry": [
    {
      "fullUrl": "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient/d5d0d3a7-29a1-4bb6-b388-35e8ce218fc5",
      "resource": {
        "birthDate": "1980-01-01",
        "gender": "male",
        "id": "PATIENT_ID",
        "meta": {
          "lastUpdated": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ",
          "versionId": "VERSION_ID"
        },
        "name": [
          {
            "family": "Zhang",
            "given": [
              "Michael"
            ],
            "use": "official"
          }
        ],
        "resourceType": "Patient"
      },
      "search": {
        "mode": "match"
      }
    },
    {
      "fullUrl": "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient/f2aa0885-390d-437d-ac73-8d41516a2c05",
      "resource": {
        "birthDate": "1970-01-01",
        "gender": "female",
        "id": "PATIENT_ID",
        "meta": {
          "lastUpdated": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ",
          "versionId": "VERSION_ID"
        },
        "name": [
          {
            "family": "Smith",
            "given": [
              "Darcy"
            ],
            "use": "official"
          }
        ],
        "resourceType": "Patient"
      },
      "search": {
        "mode": "match"
      }
    }
  ],
  "link": [
    {
      "relation": "search",
      "url": "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient/?"
    },
    {
      "relation": "first",
      "url": "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient/?"
    },
    {
      "relation": "self",
      "url": "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient/?"
    }
  ],
  "resourceType": "Bundle",
  "total": 2,
  "type": "searchset"
}

Configura il flusso di dati BigQuery nell'archivio FHIR

Aggiorna l'archivio FHIR per configurare il flusso di BigQuery. Dopo aver configurato il flusso di dati, l'API Cloud Healthcare trasmette in streaming qualsiasi modifica alle risorse nel set di dati BigQuery.

Aggiorna l'archivio FHIR esistente per aggiungere la posizione del set di dati BigQuery:
REST

Prima di utilizzare i dati della richiesta, effettua le seguenti sostituzioni:
- PROJECT_ID: l'ID del tuo progetto Google Cloud
- LOCATION: la posizione del set di dati padre
- DATASET_ID: set di dati padre dell'archivio FHIR
- FHIR_STORE_ID: il tuo ID archivio FHIR
- BIGQUERY_PROJECT_ID: il progetto Google Cloud contenente il set di dati BigQuery per il flusso di modifiche alle risorse FHIR
- BIGQUERY_DATASET_ID: il set di dati BigQuery in cui invii in streaming le modifiche alle risorse FHIR
Corpo JSON richiesta:
{ "streamConfigs": [ { "bigqueryDestination": { "datasetUri": "bq://BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID", "schemaConfig": { "schemaType": "ANALYTICS_V2" } } } ] }
Per inviare la richiesta, scegli una delle seguenti opzioni:
arricciare

Nota: il seguente comando presuppone che tu abbia eseguito l'accesso all'interfaccia a riga di comando di gcloud con il tuo account utente eseguendo gcloud init o gcloud auth login oppure utilizzando Cloud Shell, che ti permette di accedere automaticamente all'interfaccia a riga di comando di gcloud. Puoi controllare l'account attualmente attivo eseguendo gcloud auth list.

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

cat > request.json << 'EOF' { "streamConfigs": [ { "bigqueryDestination": { "datasetUri": "bq://BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID", "schemaConfig": { "schemaType": "ANALYTICS_V2" } } } ] } EOF

Quindi esegui questo comando per inviare la richiesta REST:

curl -X PATCH \
-H "Authorization: Bearer $(gcloud auth print-access-token)" \
-H "Content-Type: application/json; charset=utf-8" \
-d @request.json \
"https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID?updateMask=streamConfigs"

PowerShell

Nota: il seguente comando presuppone che tu abbia eseguito l'accesso all'interfaccia a riga di comando di gcloud con il tuo account utente eseguendo gcloud init o gcloud auth login oppure utilizzando Cloud Shell, che ti permette di accedere automaticamente all'interfaccia a riga di comando di gcloud. Puoi controllare l'account attualmente attivo eseguendo gcloud auth list.

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

@' { "streamConfigs": [ { "bigqueryDestination": { "datasetUri": "bq://BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID", "schemaConfig": { "schemaType": "ANALYTICS_V2" } } } ] } '@ | Out-File -FilePath request.json -Encoding utf8

Quindi esegui questo comando per inviare la richiesta REST:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
-Method PATCH `
-Headers $headers `
-ContentType: "application/json; charset=utf-8" `
-InFile request.json `
-Uri "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID?updateMask=streamConfigs" | Select-Object -Expand Content

Esplora API

Copia il corpo della richiesta e apri la pagina di riferimento del metodo. Il riquadro Explorer API si apre sul lato destro della pagina. Puoi interagire con questo strumento per inviare richieste. Incolla il corpo della richiesta in questo strumento, compila gli altri campi obbligatori e fai clic su Esegui.
Dovresti ricevere una risposta JSON simile alla seguente:
Risposta

{ "name": "projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID", "version": "FHIR_STORE_VERSION", "streamConfigs": [ { "bigqueryDestination": { "datasetUri": "bq://BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID", "schemaConfig": { "schemaType": "ANALYTICS_V2" } } } ] }

Verifica la configurazione di flussi di dati in BigQuery

Verifica che il flusso di dati sia configurato correttamente svolgendo i seguenti passaggi:

Crea una terza risorsa Patient nell'archivio FHIR:

REST

Prima di utilizzare i dati della richiesta, effettua le seguenti sostituzioni:

PROJECT_ID: l'ID del tuo progetto Google Cloud
LOCATION: la posizione del set di dati padre
DATASET_ID: set di dati padre dell'archivio FHIR
FHIR_STORE_ID: l'ID archivio FHIR

Corpo JSON richiesta:

{
  "name": [
    {
      "use": "official",
      "family": "Lee",
      "given": [
        "Alex"
      ]
    }
  ],
  "gender": "male",
  "birthDate": "1990-01-01",
  "resourceType": "Patient"
}

Per inviare la richiesta, scegli una delle seguenti opzioni:

arricciare

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

cat > request.json << 'EOF'
{
  "name": [
    {
      "use": "official",
      "family": "Lee",
      "given": [
        "Alex"
      ]
    }
  ],
  "gender": "male",
  "birthDate": "1990-01-01",
  "resourceType": "Patient"
}
EOF

Quindi esegui questo comando per inviare la richiesta REST:

curl -X POST \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/fhir+json" \
    -d @request.json \
    "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient"

PowerShell

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

@'
{
  "name": [
    {
      "use": "official",
      "family": "Lee",
      "given": [
        "Alex"
      ]
    }
  ],
  "gender": "male",
  "birthDate": "1990-01-01",
  "resourceType": "Patient"
}
'@  | Out-File -FilePath request.json -Encoding utf8

Quindi esegui questo comando per inviare la richiesta REST:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -ContentType: "application/fhir+json" `
    -InFile request.json `
    -Uri "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/FHIR_STORE_ID/fhir/Patient" | Select-Object -Expand Content

Dovresti ricevere una risposta JSON simile alla seguente:

Risposta

{
  "birthDate": "1990-01-01",
  "gender": "male",
  "id": "PATIENT_ID",
  "meta": {
    "lastUpdated": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ",
    "versionId": "VERSION_ID"
  },
  "name": [
    {
      "family": "Lee",
      "given": [
        "Alex"
      ],
      "use": "official"
    }
  ],
  "resourceType": "Patient"
}

Esegui una query sulla tabella BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID.Patient eseguendo bq query. BigQuery organizza le tabelle in base al tipo di risorsa FHIR. La terza risorsa Patient che hai creato si trova nella tabella Patient.
```
bq query \
   --project_id=BIGQUERY_PROJECT_ID \
   --use_legacy_sql=false \
   'SELECT COUNT(*) FROM `BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID.Patient`'
```
La query restituisce il risultato seguente. Il risultato mostra che è presente un record di risorse Patient nella tabella BigQuery, perché hai aggiunto la risorsa Patient dopo aver configurato il flusso di dati nell'archivio FHIR.
```
+-----+
| f0_ |
+-----+
|   1 |
+-----+
```

Passaggio 3: esporta le risorse FHIR esistenti in BigQuery

Se disponi di un archivio FHIR esistente contenente dati che vuoi sincronizzare con un set di dati BigQuery, devi completare i seguenti passaggi per assicurarti che i dati esistenti siano in BigQuery:

Configura il flusso di dati in BigQuery.
Esporta i dati esistenti nel set di dati BigQuery.

Per esportare le due risorse Patient esistenti nell'archivio FHIR prima di configurare il flusso di dati nel set di dati BigQuery, completa i seguenti passaggi:

Per esportare le risorse dell'archivio FHIR in BigQuery, esegui il comando gcloud healthcare fhir-stores export bq. Il comando utilizza il flag --write-disposition=write-append, che aggiunge dati alla tabella BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID.Patient esistente.
```
gcloud healthcare fhir-stores export bq FHIR_STORE_ID \
   --dataset=DATASET_ID \
   --location=LOCATION \
   --bq-dataset=bq://BIGQUERY_PROJECT_ID.BIGQUERY_DATASET \
   --schema-type=analytics_v2 \
   --write-disposition=write-append
```
Esegui una query sulla tabella BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID.Patient per verificare il numero di risorse Patient nel set di dati BigQuery:
```
bq query \
   --project_id=BIGQUERY_PROJECT_ID \
   --use_legacy_sql=false \
   'SELECT COUNT(*) FROM `BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID.Patient`'
```
La query restituisce il seguente risultato, che mostra la presenza di quattro record di risorse Patient nella tabella BigQuery:
```
+-----+
| f0_ |
+-----+
|   4 |
+-----+
```
Il numero effettivo di risorse Paziente nella tabella BigQuery è 3, ma la query restituisce 4. Quando una risorsa contiene duplicati di operazioni diverse, potrebbero verificarsi incoerenze. In questo caso, la prima risorsa Patient è stata aggiunta alla tabella BigQuery queste due volte:
- Quando la creazione della risorsa Paziente è stata trasmessa in streaming
- Quando le risorse nell'archivio FHIR sono state esportate in BigQuery.
La tabella BigQuery contiene anche una cronologia delle mutazioni della prima risorsa Paziente. Ad esempio, se elimini la risorsa Paziente utilizzando fhir.delete, la tabella BigQuery avrà una colonna meta.tag.code con il valore DELETE.
Esegui una query sulla vista per ottenere lo snapshot più recente dei dati nell'archivio FHIR. L'API Cloud Healthcare crea la vista solo guardando la versione più recente di ogni risorsa. L'esecuzione di query sulle viste è il modo più preciso per mantenere sincronizzati un archivio FHIR e la tabella BigQuery corrispondente.

Per eseguire una query sulla vista, esegui questo comando:
```
bq query \
   --project_id=BIGQUERY_PROJECT_ID \
   --use_legacy_sql=false \
   'SELECT COUNT(*) FROM `BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID.PatientView`'
```
La query restituisce il seguente risultato, che mostra correttamente che sono presenti tre risorse Patient nella tabella BigQuery:
```
+-----+
| f0_ |
+-----+
|   3 |
+-----+
```

Passaggio 4: trasmetti il flusso di risorse da più archivi FHIR allo stesso set di dati BigQuery

In alcuni casi, potresti voler trasmettere il flusso di risorse FHIR da più archivi FHIR allo stesso set di dati BigQuery per eseguire analisi sulle risorse FHIR aggregate degli archivi FHIR.

Nei passaggi seguenti, creerai un secondo archivio FHIR nello stesso set di dati dell'API Cloud Healthcare del primo archivio FHIR, ma puoi utilizzare gli archivi FHIR di diversi set di dati durante l'aggregazione delle risorse FHIR.

Crea un secondo archivio FHIR con i flussi di dati BigQuery abilitati e utilizza lo stesso set di dati BigQuery che hai utilizzato nella sezione Configurare i flussi di dati BigQuery nell'archivio FHIR.
REST

Prima di utilizzare i dati della richiesta, effettua le seguenti sostituzioni:
- PROJECT_ID: l'ID del tuo progetto Google Cloud
- LOCATION: la posizione del set di dati padre
- DATASET_ID: set di dati padre dell'archivio FHIR
- SECOND_FHIR_STORE_ID: un identificatore per il secondo archivio FHIR. L'ID dell'archivio FHIR deve essere univoco nel set di dati. L'ID archivio FHIR può essere qualsiasi stringa Unicode da 1 a 256 caratteri composta da numeri, lettere, trattini bassi, trattini e punti.
- FHIR_STORE_VERSION: la versione dell'archivio FHIR: DSTU2, STU3 o R4
- BIGQUERY_PROJECT_ID: il progetto Google Cloud contenente il set di dati BigQuery per il flusso di modifiche alle risorse FHIR
- BIGQUERY_DATASET_ID: il set di dati BigQuery in cui invii in streaming le modifiche alle risorse FHIR
Corpo JSON richiesta:
{ "version": "FHIR_STORE_VERSION" "streamConfigs": [ { "bigqueryDestination": { "datasetUri": "bq://BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID", "schemaConfig": { "schemaType": "ANALYTICS" } } } ] }
Per inviare la richiesta, scegli una delle seguenti opzioni:
arricciare

Nota: il seguente comando presuppone che tu abbia eseguito l'accesso all'interfaccia a riga di comando di gcloud con il tuo account utente eseguendo gcloud init o gcloud auth login oppure utilizzando Cloud Shell, che ti permette di accedere automaticamente all'interfaccia a riga di comando di gcloud. Puoi controllare l'account attualmente attivo eseguendo gcloud auth list.

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

cat > request.json << 'EOF' { "version": "FHIR_STORE_VERSION" "streamConfigs": [ { "bigqueryDestination": { "datasetUri": "bq://BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID", "schemaConfig": { "schemaType": "ANALYTICS" } } } ] } EOF

Quindi esegui questo comando per inviare la richiesta REST:

curl -X POST \
-H "Authorization: Bearer $(gcloud auth print-access-token)" \
-H "Content-Type: application/json; charset=utf-8" \
-d @request.json \
"https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores?fhirStoreId=SECOND_FHIR_STORE_ID"

PowerShell

Nota: il seguente comando presuppone che tu abbia eseguito l'accesso all'interfaccia a riga di comando di gcloud con il tuo account utente eseguendo gcloud init o gcloud auth login oppure utilizzando Cloud Shell, che ti permette di accedere automaticamente all'interfaccia a riga di comando di gcloud. Puoi controllare l'account attualmente attivo eseguendo gcloud auth list.

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

@' { "version": "FHIR_STORE_VERSION" "streamConfigs": [ { "bigqueryDestination": { "datasetUri": "bq://BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID", "schemaConfig": { "schemaType": "ANALYTICS" } } } ] } '@ | Out-File -FilePath request.json -Encoding utf8

Quindi esegui questo comando per inviare la richiesta REST:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
-Method POST `
-Headers $headers `
-ContentType: "application/json; charset=utf-8" `
-InFile request.json `
-Uri "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores?fhirStoreId=SECOND_FHIR_STORE_ID" | Select-Object -Expand Content

Esplora API

Copia il corpo della richiesta e apri la pagina di riferimento del metodo. Il riquadro Explorer API si apre sul lato destro della pagina. Puoi interagire con questo strumento per inviare richieste. Incolla il corpo della richiesta in questo strumento, compila gli altri campi obbligatori e fai clic su Esegui.
Dovresti ricevere una risposta JSON simile alla seguente:
Risposta

{ "name": "projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/SECOND_FHIR_STORE_ID", "version": "VERSION", "streamConfigs": [ { "bigqueryDestination": { "datasetUri": "bq://BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID", "schemaConfig": { "schemaType": "ANALYTICS" } } } ] }

Crea una risorsa Patient nel secondo archivio FHIR:

REST

Prima di utilizzare i dati della richiesta, effettua le seguenti sostituzioni:

PROJECT_ID: l'ID del tuo progetto Google Cloud
LOCATION: la posizione del set di dati padre
DATASET_ID: set di dati padre dell'archivio FHIR
SECOND_FHIR_STORE_ID: il secondo ID archivio FHIR

Corpo JSON richiesta:

{
  "name": [
    {
      "use": "official",
      "family": "Lee",
      "given": [
        "Alex"
      ]
    }
  ],
  "gender": "male",
  "birthDate": "1990-01-01",
  "resourceType": "Patient"
}

Per inviare la richiesta, scegli una delle seguenti opzioni:

arricciare

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

cat > request.json << 'EOF'
{
  "name": [
    {
      "use": "official",
      "family": "Lee",
      "given": [
        "Alex"
      ]
    }
  ],
  "gender": "male",
  "birthDate": "1990-01-01",
  "resourceType": "Patient"
}
EOF

Quindi esegui questo comando per inviare la richiesta REST:

curl -X POST \
    -H "Authorization: Bearer $(gcloud auth print-access-token)" \
    -H "Content-Type: application/fhir+json" \
    -d @request.json \
    "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/SECOND_FHIR_STORE_ID/fhir/Patient"

PowerShell

Salva il corpo della richiesta in un file denominato request.json. Esegui questo comando nel terminale per creare o sovrascrivere questo file nella directory attuale:

@'
{
  "name": [
    {
      "use": "official",
      "family": "Lee",
      "given": [
        "Alex"
      ]
    }
  ],
  "gender": "male",
  "birthDate": "1990-01-01",
  "resourceType": "Patient"
}
'@  | Out-File -FilePath request.json -Encoding utf8

Quindi esegui questo comando per inviare la richiesta REST:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -ContentType: "application/fhir+json" `
    -InFile request.json `
    -Uri "https://healthcare.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/datasets/DATASET_ID/fhirStores/SECOND_FHIR_STORE_ID/fhir/Patient" | Select-Object -Expand Content

Dovresti ricevere una risposta JSON simile alla seguente:

Risposta

{
  "birthDate": "1990-01-01",
  "gender": "male",
  "id": "PATIENT_ID",
  "meta": {
    "lastUpdated": "YYYY-MM-DDTHH:MM:SS+ZZ:ZZ",
    "versionId": "VERSION_ID"
  },
  "name": [
    {
      "family": "Cruz",
      "given": [
        "Taylor"
      ],
      "use": "official"
    }
  ],
  "resourceType": "Patient"
}

Esegui una query sulla tabella BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID.Patient per verificare il numero di risorse Paziente nella tabella BigQuery:
```
bq query \
   --project_id=BIGQUERY_PROJECT_ID \
   --use_legacy_sql=false \
   'SELECT COUNT(*) FROM `BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID.Patient`'
```
Durante il trasferimento di flussi di dati sulla nuova risorsa Patient, BigQuery ha utilizzato la tabella Patient esistente nel set di dati BigQuery. La query restituisce il risultato seguente, che mostra la presenza di 5 record di risorse Patient nella tabella BigQuery. Vedi Esportare le risorse FHIR esistenti in BigQuery per una spiegazione del motivo per cui la tabella contiene 5 risorse invece di 4.
```
+-----+
| f0_ |
+-----+
|   5 |
+-----+
```
Esegui questo comando per eseguire una query sulla vista:
```
bq query \
   --project_id=BIGQUERY_PROJECT_ID \
   --use_legacy_sql=false \
   'SELECT COUNT(*) FROM `BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID.PatientView`'
```
La query restituisce il risultato seguente, che mostra che sono presenti 4 risorse Patient nel primo e nel secondo archivio FHIR combinati e nella tabella BigQuery:
```
+-----+
| f0_ |
+-----+
|   4 |
+-----+
```

Esegui la pulizia

Se hai creato un nuovo progetto per questo tutorial, segui i passaggi descritti in Eliminare il progetto. Per eliminare solo l'API Cloud Healthcare e le risorse BigQuery, completa i passaggi descritti in Eliminare il set di dati dell'API Cloud Healthcare ed Eliminare il set di dati BigQuery.

Elimina il progetto

Attenzione: l'eliminazione di un progetto ha i seguenti effetti:

L'intero contenuto del progetto viene eliminato. Se hai utilizzato un progetto esistente per le attività in questo documento, quando lo elimini elimini anche qualsiasi altro lavoro svolto nel progetto.
Gli ID progetto personalizzati non sono più disponibili. Quando hai creato questo progetto, potresti aver creato un ID progetto personalizzato che vuoi utilizzare in futuro. Per conservare gli URL che utilizzano l'ID progetto, ad esempio un URL appspot.com, elimina le risorse selezionate all'interno del progetto anziché eliminare l'intero progetto.

Se intendi esplorare più architetture, tutorial o guide rapide, puoi riutilizzare i progetti ed evitare così di superare i limiti di quota.

Nella console Google Cloud, vai alla pagina Gestisci risorse.
Vai a Gestisci risorse
Nell'elenco dei progetti, seleziona il progetto che vuoi eliminare, quindi fai clic su Elimina.
Nella finestra di dialogo, digita l'ID del progetto e fai clic su Chiudi per eliminare il progetto.

Elimina il set di dati dell'API Cloud Healthcare

Se non hai più bisogno del set di dati dell'API Cloud Healthcare creato in questo tutorial, puoi eliminarlo. L'eliminazione di un set di dati elimina definitivamente il set di dati e tutti gli archivi FHIR al suo interno.

Per eliminare un set di dati, utilizza il comando gcloud healthcare datasets delete:
```
gcloud healthcare datasets delete DATASET_ID \
--location=LOCATION \
--project=PROJECT_ID
```
Sostituisci quanto segue:
- DATASET_ID: il set di dati dell'API Cloud Healthcare
- LOCATION: la posizione del set di dati
- PROJECT_ID: l'ID del tuo progetto Google Cloud
Per confermare, digita Y.

L'output è il seguente:

Deleted dataset [DATASET_ID].

Elimina il set di dati BigQuery

Se non hai più bisogno del set di dati BigQuery creato in questo tutorial, puoi eliminarlo. L'eliminazione di un set di dati elimina definitivamente il set di dati e le eventuali tabelle che contiene.

Rimuovi BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID set di dati eseguendo il comando bq rm:
```
bq rm --recursive=true BIGQUERY_PROJECT_ID.BIGQUERY_DATASET_ID
```
Il flag --recursive elimina tutte le tabelle nel set di dati, inclusa la tabella Patient.
Per confermare, digita Y.

Passaggi successivi

Se si verificano errori durante il trasferimento di flussi a BigQuery, gli errori vengono registrati in Cloud Logging. Per ulteriori informazioni, consulta Visualizzazione dei log degli errori in Cloud Logging.
Vedi una panoramica sull'esportazione delle risorse FHIR in BigQuery.
Per creare, visualizzare, elencare o eliminare gli archivi FHIR, vedi Creazione e gestione degli archivi FHIR.

Trasmissione e sincronizzazione di risorse FHIR con BigQuery

Obiettivi

Prima di iniziare

Passaggio 1: configura le autorizzazioni BigQuery

Passaggio 2: configura e verifica il flusso di dati BigQuery

crea un archivio FHIR e aggiungi risorse Patient

REST

arricciare

PowerShell

Esplora API

Risposta

REST

arricciare

PowerShell

Risposta

REST

arricciare

PowerShell

Risposta

REST

arricciare

PowerShell

Risposta

Configura il flusso di dati BigQuery nell'archivio FHIR

REST

arricciare

PowerShell

Esplora API

Risposta

Verifica la configurazione di flussi di dati in BigQuery

REST

arricciare

PowerShell

Risposta

Passaggio 3: esporta le risorse FHIR esistenti in BigQuery

Passaggio 4: trasmetti il flusso di risorse da più archivi FHIR allo stesso set di dati BigQuery

REST

arricciare

PowerShell

Esplora API

Risposta

REST

arricciare

PowerShell

Risposta

Esegui la pulizia

Elimina il progetto

Elimina il set di dati dell'API Cloud Healthcare

Elimina il set di dati BigQuery

Passaggi successivi