Clinical notes pipeline

Clinical notes pipeline Clinical notes pipeline Notes land in Cloud Storage, are de-identified, analysed for health entities, indexed in BigQuery and served through an API Sources Google Cloud Ingest Process Store and serve export 2. Cloud Healthcare API → Cloud Storage (export)2 de-identified 4. Sensitive Data Protection → Healthcare Natural Language API (de-identified)4 5. Healthcare Natural Language API → Dataflow5 query 7. BigQuery → Notes API (query)7 HL7 / FHIR 1. EHR system → Cloud Healthcare API (HL7 / FHIR)1 inspect 3. Cloud Storage → Sensitive Data Protection (inspect)3 load 6. Dataflow → BigQuery (load)6 EHR system (Server Farm) EHR system HL7 / FHIR export Cloud Healthcare API (Cloud Healthcare API) Cloud Healthcare API FHIR / HL7v2 stores Cloud Storage (Cloud Storage) Cloud Storage raw notes Sensitive Data Protection (Data Loss Prevention API) Sensitive Data Protection de-identify Healthcare Natural Language API (Healthcare NLP API) Healthcare Natural Language API entity extraction Dataflow (Dataflow) Dataflow batch pipeline BigQuery (BigQuery) BigQuery curated notes Notes API (Cloud Run) Notes API Cloud Run

Flow

  1. 1EHR system → Cloud Healthcare API (HL7 / FHIR)
  2. 2Cloud Healthcare API → Cloud Storage (export)
  3. 3Cloud Storage → Sensitive Data Protection (inspect)
  4. 4Sensitive Data Protection → Healthcare Natural Language API (de-identified)
  5. 5Healthcare Natural Language API → Dataflow
  6. 6Dataflow → BigQuery (load)
  7. 7BigQuery → Notes API (query)