How-to run the NextGen FHIR Ingestion Pipeline

Setup Guide

To get started with running the nextgen_fhir_pipeline.py make sure that you have cloned the etl-ingest-pipelines repo and gone through the README.

Run the pipeline

1. Setup Environment Variables. See EHR Integration Configs here.

export client_id=<your_client_id_here>
export client_secret=<your_client_secret_here>
export site=nextgen-sandbox

1. You're now ready to run the pipeline! To get started, run this command:

python pipelines/product/nextgen_fhir_pipeline.py

1. You should see similar logs as below:

2024-07-05 22:44:59.825 | INFO     | __main__:nextgen_bulk_fhir_source:22 - Getting patients from API
2024-07-05 22:44:59.827 | DEBUG    | pipelines.product.nextgen.api.auth:token:109 - Token is expired, retrieving new token
2024-07-05 22:45:02.708 | DEBUG    | pipelines.product.nextgen.api.auth:token:107 - Token is valid, using existing token