Assessment Aggregator

'assessment-aggregator' job is used to compute the course assessment content progress present as part of the Course. Job calculates the scores secured by the user during consumption against each Course Assessment Content.

Configuration variables:

Variable	Default Value	Purpose
kafka.input.topic	{{env}}.telemetry.assess	Kafka topic from which messages/events are read to be processed.
kafka.output.failed.topic	{{env}}.telemetry.assess.failed	Kafka topic to which message is written when an exception occurs while processing an event.
kafka.output.certissue.topic	{{env}}.issue.certificate.request	Kafka topic used to trigger certificate issue pre-processor job
kafka.groupId	{{env}}-assessment-aggregator-group	Kafka input topic group Id
lms-cassandra.keyspace	sunbird_courses	Cassandra keyspace name
lms-cassandra.table	assessment_aggregator	Cassandra table used to store attempt wise data for each assessment in a collection of a batch by a user. Answer for each question in the assessment is also recorded.
lms-cassandra.enrolmentstable	user_enrolments	Cassandra table used to store user enrolment data in a collection of a particular batch. This also holds the consumption progress, enrolment status and issued certificate details
lms-cassandra.activityytable	user_activity_agg	Cassandra table used to store user consumption aggregate details of a collection in a batch. Aggregates like the consumption completed content count
lms-cassandra.questionudttype	question	Cassandra table used to store each question information.
redis.database.relationCache.id	10	Redis index from which computed data like leafnodes and optionalnodes is read.
redis.database.contentCache.id	5	Redis index from which Content metadata is read from.
assessment.skip.missingRecords	false	Variable used to mention if the event processing is to be skipped in case of 'the totalQuestions Count value is not matching with the event size then job should skip those events and increase the metrics value'.
user.activity.agg.type	attempt_metrics
content.read.api	Endpoint URL of content read API	Endpoint URL of content read API part of content-service

Sample event:

{
  "assessmentTs": 1683606904796,
  "batchId": "013625297374085120185",
  "courseId": "do_2136252863013273601715",
  "userId": "95c1f00b-c033-4ea2-acf6-e368e2a56bdb",
  "attemptId": "9b6908cad37c83e53582354e1b971bb9",
  "contentId": "do_21362528320146636811198",
  "events": []
}  

Source code:

data-pipeline/lms-jobs/activity-aggregate-updater at release-5.3.0 · Sunbird-Lern/data-pipelineGitHub