Source → DWH data flow:
-
WMS service emits operational log events (e.g.
replenish_stock,start_replenishment_round) with raw JSON fields likefromLocation,toLocation,object,load_carrier_barcode, etc. -
picnic_wms__operational_log_parsed(dbt evt model) normalizes these raw events into a unified JSON structure via a largeCASE WHEN event_name = ...block. For each event type, it maps raw fields into standardized keys:
replenish_stock:source_hu_id←event_raw:"fromLocation",target_hu_id←coalesce(event_raw:"toLocation", event_raw:"object")