...
Previous Design:
New Design:
Workflow:
The Redis Updater samza job updates the User, Content and Dialcode cache currently. The redis updater will be split in two different samza jobs, i.e. User Cache Updater and Content Cache Updater.
- User Cache Updater
- This job would process the AUDIT event and filters it based on edata_state.
- If edata_state has the value 'Update', it looks for locationids from the user db.
- Based on the locationids, it searches for state and district information from the location db and updates the Redis Cache along with the existing metadata.
- Content Cache Updater
- This job would process the learning graph events and filters it based on object type.
- The events containing object type as 'DialCode' update the Dialcode Cache:
a) If the 'nodeUniqueId' already exists in cache, the new properties get appended with the existing metadata and updated in Cache.
b) If not found, a new entry is created with the properties in Redis Cache.
- Events without object type 'DialCode' update the Content Cache:
a) It checks for the content model fields in the message envelope and updates the cache with the new value from the transactionData.
b) It creates a new entry if the 'nodeUniqueId' is not found in cache, else appends the existing values with the new data.