Assessment Aggregator
Last updated
Last updated
'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:
Source code:
