Copy SOURCEFILE = conf/sources/mobileSimulatedStream.yaml
REFERENCEDATA = conf/sources/mobileReferenceData.yaml
ENGINEFILE = conf/usecases/analytics/mobileEventBasicAnalyticsFunctions.yaml
PUBLISHFILE = conf/publishers/enrichedEventsInfluxdb.yaml
Reference data stores can be used to prime the geofences. Change the required yaml file to test this feature in the app.env file.
Copy ENGINEFILE = conf/usecases/analytics/mobileReferenceData.yaml
Copy processing unit :
pipeline :
- tokenizer enricher :
tokenizers :
imei : com.fractalworks.streams.examples.telco.enricher.IMEIDecoder
latlng : com.fractalworks.streams.examples.telco.enricher.LatitudeLongitudeDecoder
- obfuscation :
name : piiMasking
enabled : true
cloneEvent : false
fields :
imsi :
encryption :
decrypt : false
key location : ./keytmp
aes bit length : 128
rsa bit length : 2048
rotate keys : true
- enricher :
enrich :
deviceType :
key : device
using : deviceStore
bundles :
key : dataBundle
using : dataBundleStore
stores :
dataBundleStore :
storeName : bundles
primaryKey : bundleid
primaryKeyType : java.lang.Integer
queryByKey : true
deviceStore :
storeName : mobiledevices
primaryKey : tac
primaryKeyType : java.lang.String
select :
expression : "imsi, device.manufacturer, device.model, bytesUp, bytesDown, 'byteRatio' bytesUp / bytesDown, celltower, droppedCall, latitude, longitude"
group by :
- imsi
- celltower
Copy select :
expression : "imsi,
device.manufacturer,
device.model,
bytesUp,
bytesDown,
'byteRatio' bytesUp / bytesDown,
celltower,
droppedCall,
latitude,
longitude"