The Pipeline

We lay the pipes. Your data flows.

Med Pipers is the ETL engine for U.S. healthcare data — one secure, HIPAA-compliant pipeline connecting EHRs, labs, pharmacies, payers, and public-health registries. Below is exactly how it works.

The pipeline ↔ Bidirectional · real-time
SOURCES DESTINATIONS MED PIPERS · ETL ENGINE 1. Ingest Transport FTP · SFTP · MLLP · API · Kafka · S3 · Webhook 2. Parse Formats HL7 v2/v3 · CCDA · FHIR · X12 · JSON · NCPDP 3. Normalize Codes ICD-10 · SNOMED · LOINC · CPT · RxNorm · NDC 4. Transform Logic Python · JavaScript · SQL · XPath · Mapping DSL EHRs Hospitals & Clinics Labs & Radiology Pharmacies Payers & Clearinghouses HIEs & TEFCA / QHIN State Registries CDC / CMS
Every arrow is a bidirectional pipe. Sources become destinations and back. HIPAA · SOC 2 · end-to-end encrypted
The anatomy · inside the engine Seven chambers · hover any endpoint for message types
SOURCES DESTINATIONS MED PIPERS · ETL ENGINE 1 Ingest Transport Accept data — batch or stream, push or pull. FTP · SFTP · MLLP · REST · SOAP · Webhook Kafka · S3 · DB reader/writer · VPN tunnel 2 Store Buffer Land raw payload — encrypted at rest, replayable. Raw buffer · Object store · Message queue Audit log · Dead-letter queue · Versioning 3 Parse Formats Turn bytes into structured records — natively. HL7 v2 · v3/CCDA · FHIR · SMART on FHIR X12 270/271 · 835 · 837 · NCPDP · JSON/XML 4 Declassify PHI · Security Detect PHI, apply consent, strip or tokenize. PHI detection · Safe Harbor de-ID · Tokenize Consent gating · Schema validation · Audit 5 Normalize Codes Map every value to one clean semantic layer. ICD-9 · ICD-10 · ICD-11 · SNOMED CT · LOINC CPT · HCPCS · RxNorm · NDC · CVX · MVX 6 Transform Any → Any Reshape into whatever the destination needs. In: Python · JS · SQL · XPath · Mapping DSL Out: HL7 · FHIR · CCDA · X12 · JSON · API 7 Disperse Egress Deliver to any endpoint — with retries, ACKs, receipts. Push · Poll · Stream · Fan-out · Filter · Route EHRs & PMS EPIC · CERNER · ATHENA EHRs & PMS EPIC · CERNER · ATHENA Message types ADT · SIU · MDM · ORM · ORU DFT · MFN · FHIR · CCDA Hospitals & Clinics HL7 v2 · MLLP · CCDA Hospitals & Clinics HL7 v2 · MLLP · CCDA Message types ADT^A01/A04/A08 · DFT · BAR ORM · ORU · Discharge Labs & Radiology ORU · ORM · DICOM SR Labs & Radiology ORU · ORM · DICOM SR Message types ORU^R01 · ORM^O01 OML · OMI · DICOM SR · WADO Pharmacies NCPDP · SCRIPT Pharmacies NCPDP · SCRIPT Message types NewRx · Renewal · Change CancelRx · RDE^O11 · RDS^O13 Facilities FHIR · API · Webhook Facilities FHIR · API · Webhook Message types Patient · Encounter · CarePlan Observation · SMART · Bulk HIEs & ELR IHE ITI · XDR · XCA HIEs & ELR IHE ITI · XDR · XCA Message types ITI-41/42/43 · XCPD · XDS.b ELR · VXU^V04 · IPS Payers X12 270/271 · 835 · 837 Payers X12 EDI · Real-time API Message types 270/271 · 837P/I · 835 276/277 · 278 · 820 Clearinghouses SFTP · EDI · API Clearinghouses SFTP · EDI · API Message types 837 · 835 · 999 · TA1 batches Availity · Waystar · CH HIEs · TEFCA / QHIN IHE · FHIR · IPS HIEs · TEFCA / QHIN IHE · FHIR · IPS Message types XCA · XCPD · XDS.b · Bulk FHIR IPS · QHIN broker · Direct State Registries IIS · Cancer · Syndromic State Registries IIS · Cancer · Syndromic Message types VXU^V04 · ELR (public health) Syndromic ADT · NAACCR CDC / CMS NHSN · QRDA · HEDIS CDC / CMS NHSN · QRDA · HEDIS Message types NHSN CDA · QRDA Cat I / III HEDIS · MIPS / Quality Analytics · Warehouses Snowflake · S3 · Kafka Analytics · Warehouses Snowflake · S3 · Kafka Message types Parquet · Avro · NDJSON CDC streams · FHIR Bulk
Every source feeds the left manifold into Ingest. Every destination fans out from the right manifold from Disperse. Bidirectional — flow reverses on the way back. Encrypted in transit & at rest · Tokenized · SOC 2
Inside the pipeline

Seven chambers. One platform.

Composable stages that turn any healthcare data into any other healthcare data — safely. Every chamber is auditable, replayable, and independently scalable.

01

Ingest

Transport

However your data wants to arrive, we accept it — batch or stream, push or pull, on prem or in the cloud.

FTP SFTP MLLP REST API SOAP Webhook Database Reader Database Writer Kafka S3 VPN Tunnel
02

Store

Buffer

Raw payloads land in an encrypted, replayable buffer — so nothing is ever lost, and every hop can be re-run.

Raw Buffer Object Store Message Queue Dead-letter Queue Audit Log Versioning Encrypted at Rest Replay
03

Parse

Formats

Every major U.S. healthcare interchange format, natively — no third-party parsers, no lossy round-trips.

JSON / XML HL7 v2 HL7 v3 / CCDA FHIR SMART on FHIR X12 X12 270/271 X12 835 X12 837 NCPDP ORDA HEDIS CQL / QDM ITI Profiles SQL
04

Declassify

PHI · Security

Detect protected health information, apply the right consent, then strip, tokenize, or pass it through — auditable on every record.

PHI Detection Safe Harbor De-ID Expert Determination Tokenization Pseudonymization Consent Gating Schema Validation Field-level Encryption Audit Trail
05

Normalize

Codes

One clean semantic layer, mapped across every major clinical, financial, and pharmacy vocabulary.

ICD-9 ICD-10 ICD-11 SNOMED CT LOINC CPT HCPCS RxNorm NDC CVX MVX
06

Transform

Any → Any

Write mappings in the language you already know — then emit into whatever format the destination needs. Any format in, any format out.

Written in
Python JavaScript SQL XPath Mapping DSL Rules Engine Enrichment
Outputs to
JSON / XML HL7 v2 HL7 v3 / CCDA FHIR SMART on FHIR X12 X12 270/271 X12 835 X12 837 NCPDP ORDA HEDIS CQL / QDM ITI Profiles SQL REST API SOAP Webhook
07

Disperse

Egress

Fan out to any destination — with retries, acknowledgements, delivery receipts, and end-to-end lineage.

Push Poll Stream Fan-out Filter Route Retries ACK / NACK Delivery Receipts Lineage
Systems in the network

Every endpoint that matters.

The whole U.S. healthcare stack, connected in both directions.

Providers

Hospitals Clinics Facilities PMS EHRs

Diagnostics

Labs Radiology ELR

Pharmacy

Pharmacies NCPDP networks

Payers

Payers Clearinghouses

Interoperability

HIEs TEFCA / QHIN

Public health

State Registries CDC CMS

Stop patching. Start piping.

Book a 20-minute call — we'll map your data flow, free.