6.1 WADO-Consumer Service Implementation: Building Scalable Cloud DICOM-WEB Services
WADO-Consumer Module Documentation Overview storage_consumer.rs is the core consumption module in the WADO system, responsible for consuming DICOM storage messages from the Kafka message queue, performing batch processing, persistent storage, and republishing to other topics. Main Functions Message Consumption and Processing Flow Subscribe to DicomStoreMeta messages from Kafka topics Batch collect messages and process according to time and quantity thresholds Classify processed messages into state metadata and image metadata Persist to databases Republish to corresponding Kafka topics Core Components start_process Function System entry point, responsible for initializing the entire consumption process: ...