Import and export FHIR resources using Cloud Storage

import(
"context"
"fmt"
"io"
"time"
healthcare"google.golang.org/api/healthcare/v1"
)
// importsFHIRResource imports an FHIR resource.
funcimportFHIRResource(wio.Writer,projectID,location,datasetID,fhirStoreID,gcsURIstring)error{
ctx:=context.Background()
healthcareService,err:=healthcare.NewService(ctx)
iferr!=nil{
returnfmt.Errorf("healthcare.NewService: %w",err)
}
storesService:=healthcareService.Projects.Locations.Datasets.FhirStores
name:=fmt.Sprintf("projects/%s/locations/%s/datasets/%s/fhirStores/%s",projectID,location,datasetID,fhirStoreID)
req:=&healthcare.ImportResourcesRequest{
ContentStructure:"RESOURCE",
GcsSource:&healthcare.GoogleCloudHealthcareV1FhirGcsSource{
Uri:gcsURI,
},
}
op,err:=storesService.Import(name,req).Do()
iferr!=nil{
returnfmt.Errorf("Import: %w",err)
}
operationsService:=healthcareService.Projects.Locations.Datasets.Operations
ticker:=time.NewTicker(1*time.Second)
deferticker.Stop()
for{
select{
case<-ctx.Done():
returnctx.Err()
case<-ticker.C:
newOp,err:=operationsService.Get(op.Name).Do()
iferr!=nil{
returnfmt.Errorf("operationsService.Get(%q): %v",op.Name,err)
}
ifnewOp.Done{
ifnewOp.Error!=nil{
returnfmt.Errorf("import operation %q completed with error: %s",op.Name,newOp.Error.Details)
}
returnnil
}
}
}
}

importcom.google.api.client.http.HttpRequestInitializer ;
importcom.google.api.client.http.javanet.NetHttpTransport ;
importcom.google.api.client.json.JsonFactory ;
importcom.google.api.client.json.gson.GsonFactory ;
importcom.google.api.services.healthcare.v1.CloudHealthcare;
importcom.google.api.services.healthcare.v1.CloudHealthcare.Projects.Locations.Datasets.FhirStores;
importcom.google.api.services.healthcare.v1.CloudHealthcareScopes;
importcom.google.api.services.healthcare.v1.model.GoogleCloudHealthcareV1FhirGcsSource;
importcom.google.api.services.healthcare.v1.model.ImportResourcesRequest;
importcom.google.api.services.healthcare.v1.model.Operation;
importcom.google.auth.http.HttpCredentialsAdapter ;
importcom.google.auth.oauth2.GoogleCredentials ;
importjava.io.IOException;
importjava.util.Collections;
publicclass FhirStoreImport{
privatestaticfinalStringFHIR_NAME="projects/%s/locations/%s/datasets/%s/fhirStores/%s";
privatestaticfinalJsonFactoryJSON_FACTORY=newGsonFactory();
privatestaticfinalNetHttpTransportHTTP_TRANSPORT=newNetHttpTransport();
publicstaticvoidfhirStoreImport(StringfhirStoreName,StringgcsUri)throwsIOException{
// String fhirStoreName =
// String.format(
// FHIR_NAME, "your-project-id", "your-region-id", "your-dataset-id", "your-fhir-id");
// String gcsUri = "gs://your-bucket-id/path/to/destination/dir"
// Initialize the client, which will be used to interact with the service.
CloudHealthcareclient=createClient();
// Configure where the store should be imported from.
GoogleCloudHealthcareV1FhirGcsSourcegcsSource=
newGoogleCloudHealthcareV1FhirGcsSource().setUri(gcsUri);
ImportResourcesRequestimportRequest=newImportResourcesRequest().setGcsSource(gcsSource);
// Create request and configure any parameters.
FhirStores.CloudHealthcareImportrequest=
client
.projects()
.locations()
.datasets()
.fhirStores()
.healthcareImport(fhirStoreName,importRequest);
// Execute the request, wait for the operation to complete, and process the results.
try{
Operationoperation=request.execute();
while(operation.getDone()==null||!operation.getDone()){
// Update the status of the operation with another request.
Thread.sleep(500);// Pause for 500ms between requests.
operation=
client
.projects()
.locations()
.datasets()
.operations()
.get(operation.getName())
.execute();
}
System.out.println("FHIR store import complete: "+operation.getResponse());
}catch(Exceptionex){
System.out.printf("Error during request execution: %s",ex.toString());
ex.printStackTrace(System.out);
}
}
privatestaticCloudHealthcarecreateClient()throwsIOException{
// Use Application Default Credentials (ADC) to authenticate the requests
// For more information see https://cloud.google.com/docs/authentication/production
GoogleCredentialscredential=
GoogleCredentials.getApplicationDefault()
.createScoped(Collections.singleton(CloudHealthcareScopes.CLOUD_PLATFORM));
// Create a HttpRequestInitializer, which will provide a baseline configuration to all requests.
HttpRequestInitializerrequestInitializer=
request->{
newHttpCredentialsAdapter(credential).initialize(request);
request.setConnectTimeout(60000);// 1 minute connect timeout
request.setReadTimeout(60000);// 1 minute read timeout
};
// Build the client for interacting with the service.
returnnewCloudHealthcare.Builder(HTTP_TRANSPORT,JSON_FACTORY,requestInitializer)
.setApplicationName("your-application-name")
.build();
}
}

constgoogle=require('@googleapis/healthcare');
consthealthcare=google.healthcare({
version:'v1',
auth:newgoogle.auth.GoogleAuth({
scopes:['https://www.googleapis.com/auth/cloud-platform'],
}),
});
constsleep=ms=>{
returnnewPromise(resolve=>setTimeout(resolve,ms));
};
constimportFhirResources=async()=>{
// TODO(developer): uncomment these lines before running the sample
// const cloudRegion = 'us-central1';
// const projectId = 'adjective-noun-123';
// const datasetId = 'my-dataset';
// const fhirStoreId = 'my-fhir-store';
// const gcsUri = 'my-bucket/my-directory/*.json'
constname=`projects/${projectId}/locations/${cloudRegion}/datasets/${datasetId}/fhirStores/${fhirStoreId}`;
constrequest={
name,
resource:{
contentStructure:'RESOURCE',
gcsSource:{
uri:`gs://${gcsUri}`,
},
},
};
constoperation=
awaithealthcare.projects.locations.datasets.fhirStores.import(request);
constoperationName=operation.data.name;
constoperationRequest={name:operationName};
// Wait twenty seconds for the LRO to finish.
awaitsleep(20000);
// Check the LRO's status
constoperationStatus=
awaithealthcare.projects.locations.datasets.operations.get(
operationRequest
);
constsuccess=operationStatus.data.metadata.counter.success;
if(typeofsuccess!=='undefined'){
console.log(
`Import FHIR resources succeeded. ${success} resources imported.`
);
}else{
console.log(
'Imported FHIR resources failed. Details available in Cloud Logging at the following URL:\n',
operationStatus.data.metadata.logsUrl
);
}
};
importFhirResources();

defimport_fhir_resources(project_id, location, dataset_id, fhir_store_id, gcs_uri):
"""Import resources into the FHIR store by copying them from the
 specified source.
 See https://github.com/GoogleCloudPlatform/python-docs-samples/tree/main/healthcare/api-client/v1/fhir
 before running the sample."""
 # Imports the Google API Discovery Service.
 fromgoogleapiclientimport discovery
 api_version = "v1"
 service_name = "healthcare"
 # Instantiates an authorized API client by discovering the Healthcare API
 # and using GOOGLE_APPLICATION_CREDENTIALS environment variable.
 client = discovery.build(service_name, api_version)
 # TODO(developer): Uncomment these lines and replace with your values.
 # project_id = 'my-project' # replace with your GCP project ID
 # location = 'us-central1' # replace with the parent dataset's location
 # dataset_id = 'my-dataset' # replace with the parent dataset's ID
 # fhir_store_id = 'my-fhir-store' # replace with the FHIR store ID
 # gcs_uri = 'my-bucket' # replace with a Cloud Storage bucket
 fhir_store_parent = "projects/{}/locations/{}/datasets/{}".format(
 project_id, location, dataset_id
 )
 fhir_store_name = f"{fhir_store_parent}/fhirStores/{fhir_store_id}"
 body = {
 "contentStructure": "CONTENT_STRUCTURE_UNSPECIFIED",
 "gcsSource": {"uri": f"gs://{gcs_uri}"},
 }
 # Escape "import()" method keyword because "import"
 # is a reserved keyword in Python
 request = (
 client.projects()
 .locations()
 .datasets()
 .fhirStores()
 .import_(name=fhir_store_name, body=body)
 )
 response = request.execute()
 print(f"Imported FHIR resources: {gcs_uri}")
 return response

import(
"context"
"fmt"
"io"
"time"
healthcare"google.golang.org/api/healthcare/v1"
)
// exportFHIRResource exports the resources in the FHIR store.
funcexportFHIRResource(wio.Writer,projectID,location,datasetID,fhirStoreID,gcsURIPrefixstring)error{
ctx:=context.Background()
healthcareService,err:=healthcare.NewService(ctx)
iferr!=nil{
returnfmt.Errorf("healthcare.NewService: %w",err)
}
storesService:=healthcareService.Projects.Locations.Datasets.FhirStores
name:=fmt.Sprintf("projects/%s/locations/%s/datasets/%s/fhirStores/%s",projectID,location,datasetID,fhirStoreID)
req:=&healthcare.ExportResourcesRequest{
GcsDestination:&healthcare.GoogleCloudHealthcareV1FhirGcsDestination{
UriPrefix:gcsURIPrefix,
},
}
op,err:=storesService.Export(name,req).Do()
iferr!=nil{
returnfmt.Errorf("Export: %w",err)
}
operationsService:=healthcareService.Projects.Locations.Datasets.Operations
ticker:=time.NewTicker(1*time.Second)
deferticker.Stop()
for{
select{
case<-ctx.Done():
returnctx.Err()
case<-ticker.C:
newOp,err:=operationsService.Get(op.Name).Do()
iferr!=nil{
returnfmt.Errorf("operationsService.Get(%q): %v",op.Name,err)
}
ifnewOp.Done{
ifnewOp.Error!=nil{
returnfmt.Errorf("export operation %q completed with error: %v",op.Name,newOp.Error)
}
returnnil
}
}
}
}

importcom.google.api.client.http.HttpRequestInitializer ;
importcom.google.api.client.http.javanet.NetHttpTransport ;
importcom.google.api.client.json.JsonFactory ;
importcom.google.api.client.json.gson.GsonFactory ;
importcom.google.api.services.healthcare.v1.CloudHealthcare;
importcom.google.api.services.healthcare.v1.CloudHealthcare.Projects.Locations.Datasets.FhirStores;
importcom.google.api.services.healthcare.v1.CloudHealthcareScopes;
importcom.google.api.services.healthcare.v1.model.ExportResourcesRequest;
importcom.google.api.services.healthcare.v1.model.GoogleCloudHealthcareV1FhirGcsDestination;
importcom.google.api.services.healthcare.v1.model.Operation;
importcom.google.auth.http.HttpCredentialsAdapter ;
importcom.google.auth.oauth2.GoogleCredentials ;
importjava.io.IOException;
importjava.util.Collections;
publicclass FhirStoreExport{
privatestaticfinalStringFHIR_NAME="projects/%s/locations/%s/datasets/%s/fhirStores/%s";
privatestaticfinalJsonFactoryJSON_FACTORY=newGsonFactory();
privatestaticfinalNetHttpTransportHTTP_TRANSPORT=newNetHttpTransport();
publicstaticvoidfhirStoreExport(StringfhirStoreName,StringgcsUri)throwsIOException{
// String fhirStoreName =
// String.format(
// FHIR_NAME, "your-project-id", "your-region-id", "your-dataset-id", "your-fhir-id");
// String gcsUri = "gs://your-bucket-id/path/to/destination/dir"
// Initialize the client, which will be used to interact with the service.
CloudHealthcareclient=createClient();
// Configure where the store will be exported too.
GoogleCloudHealthcareV1FhirGcsDestinationgcsDestination=
newGoogleCloudHealthcareV1FhirGcsDestination().setUriPrefix(gcsUri);
ExportResourcesRequestexportRequest=
newExportResourcesRequest().setGcsDestination(gcsDestination);
// Create request and configure any parameters.
FhirStores.Exportrequest=
client.projects().locations().datasets().fhirStores().export(fhirStoreName,exportRequest);
// Execute the request, wait for the operation to complete, and process the results.
try{
Operationoperation=request.execute();
while(operation.getDone()==null||!operation.getDone()){
// Update the status of the operation with another request.
Thread.sleep(500);// Pause for 500ms between requests.
operation=
client
.projects()
.locations()
.datasets()
.operations()
.get(operation.getName())
.execute();
}
System.out.println("Fhir store export complete."+operation.getResponse());
}catch(Exceptionex){
System.out.printf("Error during request execution: %s",ex.toString());
ex.printStackTrace(System.out);
}
}
privatestaticCloudHealthcarecreateClient()throwsIOException{
// Use Application Default Credentials (ADC) to authenticate the requests
// For more information see https://cloud.google.com/docs/authentication/production
GoogleCredentialscredential=
GoogleCredentials.getApplicationDefault()
.createScoped(Collections.singleton(CloudHealthcareScopes.CLOUD_PLATFORM));
// Create a HttpRequestInitializer, which will provide a baseline configuration to all requests.
HttpRequestInitializerrequestInitializer=
request->{
newHttpCredentialsAdapter(credential).initialize(request);
request.setConnectTimeout(60000);// 1 minute connect timeout
request.setReadTimeout(60000);// 1 minute read timeout
};
// Build the client for interacting with the service.
returnnewCloudHealthcare.Builder(HTTP_TRANSPORT,JSON_FACTORY,requestInitializer)
.setApplicationName("your-application-name")
.build();
}
}

constgoogle=require('@googleapis/healthcare');
consthealthcare=google.healthcare({
version:'v1',
auth:newgoogle.auth.GoogleAuth({
scopes:['https://www.googleapis.com/auth/cloud-platform'],
}),
});
constsleep=ms=>{
returnnewPromise(resolve=>setTimeout(resolve,ms));
};
constexportFhirResourcesGcs=async()=>{
// TODO(developer): uncomment these lines before running the sample
// const cloudRegion = 'us-central1';
// const projectId = 'adjective-noun-123';
// const datasetId = 'my-dataset';
// const fhirStoreId = 'my-fhir-store';
// const gcsUri = 'my-bucket/my-directory'
constname=`projects/${projectId}/locations/${cloudRegion}/datasets/${datasetId}/fhirStores/${fhirStoreId}`;
constrequest={
name,
resource:{
gcsDestination:{
// The destination location in Cloud Storage for the FHIR resources
uriPrefix:`gs://${gcsUri}`,
},
},
};
constoperation=
awaithealthcare.projects.locations.datasets.fhirStores.export(request);
constoperationName=operation.data.name;
// Wait ten seconds for the LRO to finish
awaitsleep(10000);
// Check the LRO's status
constoperationStatus=
awaithealthcare.projects.locations.datasets.operations.get({
name:operationName,
});
if(typeofoperationStatus.data.metadata.counter!=='undefined'){
console.log('Exported FHIR resources successfully');
}else{
console.log('Export failed');
}
};
exportFhirResourcesGcs();

defexport_fhir_store_gcs(project_id, location, dataset_id, fhir_store_id, gcs_uri):
"""Export resources to a Google Cloud Storage bucket by copying
 them from the FHIR store.
 See https://github.com/GoogleCloudPlatform/python-docs-samples/tree/main/healthcare/api-client/v1/fhir
 before running the sample."""
 # Imports the Google API Discovery Service.
 fromgoogleapiclientimport discovery
 api_version = "v1"
 service_name = "healthcare"
 # Instantiates an authorized API client by discovering the Healthcare API
 # and using GOOGLE_APPLICATION_CREDENTIALS environment variable.
 client = discovery.build(service_name, api_version)
 # TODO(developer): Uncomment these lines and replace with your values.
 # project_id = 'my-project' # replace with your GCP project ID
 # location = 'us-central1' # replace with the parent dataset's location
 # dataset_id = 'my-dataset' # replace with the parent dataset's ID
 # fhir_store_id = 'my-fhir-store' # replace with the FHIR store ID
 # gcs_uri = 'my-bucket' # replace with a Cloud Storage bucket
 fhir_store_parent = "projects/{}/locations/{}/datasets/{}".format(
 project_id, location, dataset_id
 )
 fhir_store_name = f"{fhir_store_parent}/fhirStores/{fhir_store_id}"
 body = {"gcsDestination": {"uriPrefix": f"gs://{gcs_uri}/fhir_export"}}
 request = (
 client.projects()
 .locations()
 .datasets()
 .fhirStores()
 .export(name=fhir_store_name, body=body)
 )
 response = request.execute()
 print(f"Exported FHIR resources to bucket: gs://{gcs_uri}")
 return response