Introduction
This wiki details the architecture of enabling reporting framework to operate at scale. It discusses the high level design problems to be solved and introduces the proposed architecture for the same.
Key Design Problems
TBA
Reporting Architecture
Druid Architecture
Druid Data Model
Raw Telemetry
Dimension in Druid | Field in Telemetry | Description | Data Type | |
---|---|---|---|---|
1 | ets | ets | Event timestamp | Long |
2 | eid | eid | Event Id | String |
3 | syncts | syncts | Sync Timestamp | Long |
4 | actor_id | actor.id | Actor Id of the event | String |
5 | actor_type | actor.type | Type of the actor | String |
6 | context_channel | context.channel | Channel Id | String |
7 | context_pdata_id | context.pdata.id | Producer Id | String |
8 | context_pdata_pid | context.pdata.pid | Producer Process Id | String |
9 | context_pdata_ver | context.pdata.ver | Producer version number | String |
10 | context_env | context.env | Context Environment | String |
11 | context_sid | context.sid | Session Id | String |
12 | context_did | context.did | Device Id | String |
13 | context_cdata_type | context.cdata.type | Correlation Data Type | Array[String] |
14 | context_cdata_id | context.cdata.id | Correlation Data Id | Array[String] |
15 | object_id | object.id | Content Id | String |
16 | object_type | object.type | Content Type | String |
17 | object_version | object.ver | Content Version | String |
18 | tags | tags | Tags | Array[String] |
19 | edata_type | edata.type | Event type | String |
20 | edata_subtype | edata.subtype | Event subtype | String |
21 | edata_mode | edata.mode | START event Mode of start | String |
22 | edata_pageid | edata.pageid | Unique pageid | String |
23 | edata_uri | edata.uri | IMPRESSION event Relative URI of the content | String |
24 | edata_id | edata.id | Event data Id | String |
25 | edata_duration | edata.duration | Duration of the event | Double |
26 | edata_index | edata.index | ASSESS event Index of the question within a content | Integer |
27 | edata_pass | edata.pass | ASSESS event Field to identify pass or fail for assessments | String |
28 | edata_score | edata.score | ASSESS event Assessment score | Double |
29 | edata_resvalues | edata.resvalues | ASSESS event Assessment results | Array[Object] |
30 | edata_item_id | edata.item.id | ASSESS event Assessment item id | String |
31 | edata_item_title | edata.item.title | ASSESS event Assessment item title | String |
32 | edata_item_maxscore | edata.item.maxscore | ASSESS event Assessment item max score | Double |
33 | edata_target_id | edata.target.id | ASSESS event Assessment item target id | String |
34 | edata_target_type | edata.target.type | ASSESS event Assessment item target type | String |
35 | edata_rating | edata.rating | FEEDBACK event Ratings | Integer |
36 | edata_comments | edata.comments | FEEDBACK event Comments | String |
37 | edata_dir | edata.dir | SHARE event direction | String |
38 | edata_items_id | edata.items.id | SHARE event shared item ids | Array[String] |
39 | edata_items_type | edata.items.type | SHARE item types | Array[String] |
40 | edata_items_origin_id | edata.items.origin.id | SHARE event source id | Array[String] |
41 | edata_items_origin_type | edata.items.origin.type | SHARE event source type | Array[String] |
42 | edata_items_to_id | edata.items.to.id | SHARE event destination id | Array[String] |
43 | edata_items_to_type | edata.items.to.type | SHARE event destination type | Array[String] |
44 | edata_state | edata.state | AUDIT event current state | String |
45 | edata_prevstate | edata.prevstate | AUDIT event previous state | String |
46 | edata_size | edata.size | SEARCH event result size | Integer |
47 | edata_filters_dialcodes | edata.filters.dialcodes | SEARCH event List of dialcodes | Array[String] |
48 | edata_topn_identifier | edata.topn.identifier | SEARCH event topn results | Array[String] |
49 | edata_visits_objid | edata.visits.objid | IMPRESSION event unique id for object visited | Array[String] |
50 | edata_visits_objtype | edata.visits.objtype | IMPRESSION event type of object visited | Array[String] |
51 | edata_visits_objver | edata.visits.objver | IMPRESSION event version of object visited | Array[String] |
52 | edata_visits_index | edata.visits.index | IMPRESSION event index of object within list | Array[Integer] |
53 | device_loc_state | devicedata.state | State location information for the device | String |
54 | device_loc_state_code | devicedata.statecode | State ISO code information for the device | String |
55 | device_loc_city | devicedata.city | City location information for the device | String |
56 | device_loc_country_code | devicedata.countrycode | Country ISO code information for the device | String |
57 | device_loc_country | devicedata.country | Country location information for the device | String |
58 | device_os | devicedata.os | Device OS name | String |
59 | device_make | devicedata.make | Device make and model | String |
60 | device_id | devicedata.id | Physical device id if available from OS | String |
61 | device_mem | devicedata.mem | Total memory in mb | Integer |
62 | device_idisk | devicedata.idisk | Total interanl disk | Integer |
63 | device_edisk | devicedata.edisk | Total external disk | Integer |
64 | device_scrn | devicedata.scrn | Screen size in inches | Integer |
65 | device_camera | devicedata.camera | Primary & secondary camera spec | String |
66 | device_cpu | devicedata.cpu | Processor name | String |
67 | device_sims | devicedata.sims | Number of sim cards | Integer |
68 | device_uaspec_agent | devicedata.uaspec.agent | User agent of the browser | String |
69 | device_uaspec_ver | devicedata.uaspec.ver | User agent version of the browser | String |
70 | device_uaspec_system | devicedata.uaspec.system | User agent system identification of the browser | String |
71 | device_uaspec_platform | devicedata.uaspec.platform | User agent client platform of the browser | String |
72 | device_uaspec_raw | devicedata.uaspec.raw | Raw user agent of the browser | String |
73 | device_first_access | devicedata.firstaccess | First access of the device | Long (Epoch) |
74 | content_name | contentdata.name | Name of the content | String |
75 | content_object_type | contentdata.objecttype | Type of the content | String |
76 | content_type | contentdata.contenttype | Type of the resource | String |
77 | content_media_type | contentdata.mediatype | Type of the media of the resource | String |
78 | content_language | contentdata.language | List of languages in the content | Array[String] |
79 | content_medium | contentdata.medium | Language medium of the board | String |
80 | content_mimetype | contentdata.mimetype | Mimetype of the resource in the content | String |
81 | content_framework | contentdata.framework | String | |
82 | content_board | contentdata.board | Board of affiliation | String |
83 | content_status | contentdata.status | Status of the content - Draft, Published etc. | String |
84 | content_version | contentdata.pkgversion | Version of the content | Double |
85 | content_last_submitted_on | contentdata.lastsubmittedon | Last submitted date of the content | Long (Epoch) |
86 | content_last_published_on | contentdata.lastpublishedon | Last submitted date of the content | Long (Epoch) |
87 | content_last_updated_on | contentdata.lastupdatedon | Last updated date of the content | Long (Epoch) |
88 | user_grade_list | userdata.gradelist | List of grades taught | Array[String] |
89 | user_language_list | userdata.languagelist | List of languages known | Array[String] |
90 | user_subject_list | userdata.subjectlist | List of subjects taught | Array[String] |
91 | user_type | userdata.type | Type of user | String |
92 | user_loc_state | userdata.state | State info of the user | String |
93 | user_loc_district | userdata.district | District info of the user | String |
94 | user_loc_block | userdata.block | Block info of the user | String |
95 | dialcode_channel | dialcodedata.channel | Channel for which dialcode is generated | String |
96 | dialcode_batchcode | dialcodedata.batchcode | Batch for which dialcode belongs to | String |
97 | dialcode_publisher | dialcodedata.publisher | Publisher of the dialcode | String |
98 | dialcode_generated_on | dialcodedata.generatedon | Dialcode generated on | Long (Epoch) |
99 | dialcode_published_on | dialcodedata.publishedon | Dialcode published on | Long (Epoch) |
100 | dialcode_status | dialcodedata.status | Status of the dialcode | String |
101 | dialcode_object_type | dialcodedata.objecttype | Object type - DialCode as a value | String |
Summary Events
Dimension in Druid | Field in Summary event | Description | Data Type | |
---|---|---|---|---|
1 | ets | ets | Event timestamp | Long |
2 | eid | eid | Event Id | String |
3 | ver | ver | Version | String |
4 | syncts | syncts | Sync timestamp | Long |
5 | uid | uid | User Id | String |
6 | context_date_range_from | context.date_range.from | Start Date for the summary | Long (Epoch) |
7 | context_date_range_to | context.date_range.to | End Date for the summary | Long (Epoch) |
8 | context_rollup_l1 | context.rollup.l1 | Context level1 rollup | String |
9 | context_rollup_l2 | context.rollup.l2 | Context level2 rollup | String |
10 | context_rollup_l3 | context.rollup.l3 | Context level3 rollup | String |
11 | context_rollup_l4 | context.rollup.l4 | Context level4 rollup | String |
12 | dimension_channel | dimensions.channel | Channel Id as dimension from raw telemetry | String |
13 | dimensions_did | dimensions.did | Device Id as dimension from raw telemetry | String |
14 | dimensions_pdata_id | dimensions.pdata.id | Producer Id as dimension from raw telemetry | String |
15 | dimensions_pdata_pid | dimensions.pdata.pid | Producer Process Id as dimension from raw telemetry | String |
16 | dimensions_pdata_ver | dimensions.pdata.ver | Producer Process Ver as dimension from raw telemetry | String |
17 | dimensions_sid | dimensions.sid | Session Id as dimension | String |
18 | dimensions_type | dimensions.type | Type of summary | String |
19 | dimensions_mode | dimensions.mode | Mode of action in the session | String |
20 | object_id | object.id | Content Id | String |
21 | object_type | object.type | Content Type | String |
22 | object_version | object.ver | Content version | String |
23 | object_rollup_l1 | object.rollup.l1 | Object level1 rollup | String |
24 | object_rollup_l2 | object.rollup.l2 | Object level2 rollup | String |
25 | object_rollup_l3 | object.rollup.l3 | Object level3 rollup | String |
26 | object_rollup_l4 | object.rollup.l4 | Object level4 rollup | String |
27 | tags | tags | Tags attached to a summary event | Array[String] |
28 | edata_time_spent | edata.eks.time_spent | Time spent in the session excluding idle time | Double |
29 | edata_time_difference | edata.eks.time_diff | Total time in a session including idle time | Double |
30 | edata_interaction_count | edata.eks.interact_events_count | Total count of interact events in a session | Long |
31 | edata_env_summary_env | edata.eks.env_summary.env | High level env within the app (content, domain, resources, community) | Array[String] |
32 | edata_env_summary_count | edata.eks.env_summary.count | Count of times the environment has been visited | Array[Integer] |
33 | edata_env_summary_time_spent | edata.eks.env_summary.time_spent | Time spent per env | Array[Double] |
34 | edata_page_summary_id | edata.eks.page_summary.id | Page id | Array[String] |
35 | edata_page_summary_type | edata.eks.page_summary.type | Type of page e.g. view/edit | Array[String] |
36 | edata_page_summary_env | edata.eks.page_summary.env | Env of page | Array[String] |
37 | edata_page_summary_visit_count | edata.eks.page_summary.visit_count | Number of times each page was visited | Array[Integer] |
38 | edata_page_summary_time_spent | edata.eks.page_summary.time_spent | Time taken per page | Array[Double] |
39 | edata_item_responses_item_id | edata.eks.item_responses.itemId | Question Id passed in the ASSESS event | Array[String] |
40 | edata_item_responses_time_spent | edata.eks.item_responses.timeSpent | Time spent in seconds from ASSESS event | Array[Double] |
41 | edata_item_responses_pass | edata.eks.item_responses.pass | Pass response for a question from ASSESS event | Array[String] |
42 | edata_item_responses_score | edata.eks.item_responses.score | Score from ASSESS event | Array[Integer] |
43 | edata_item_responses_max_score | edata.eks.item_responses.maxScore | Max Score from ASSESS event | Array[Integer] |
44 | edata_item_responses_timestamp | edata.eks.item_responses.time_stamp | Timestamp for each response from ASSESS event | Array[Long (Epoch)] |
45 | device_loc_state | devicedata.state | State location information for the device | String |
46 | device_loc_state_code | devicedata.statecode | State ISO code information for the device | String |
47 | device_loc_city | devicedata.city | City location information for the device | String |
48 | device_loc_country_code | devicedata.countrycode | Country ISO code information for the device | String |
49 | device_loc_country | devicedata.country | Country location information for the device | String |
50 | device_os | devicedata.os | Device OS name | String |
51 | device_make | devicedata.make | Device make and model | String |
52 | device_id | devicedata.id | Physical device id if available from OS | String |
53 | device_mem | devicedata.mem | Total memory in mb | Integer |
54 | device_idisk | devicedata.idisk | Total interanl disk | Integer |
55 | device_edisk | devicedata.edisk | Total external disk | Integer |
56 | device_scrn | devicedata.scrn | Screen size in inches | Integer |
57 | device_camera | devicedata.camera | Primary & secondary camera spec | String |
58 | device_cpu | devicedata.cpu | Processor name | String |
59 | device_sims | devicedata.sims | Number of sim cards | Integer |
60 | device_uaspec_agent | devicedata.uaspec.agent | User agent of the browser | String |
61 | device_uaspec_ver | devicedata.uaspec.ver | User agent version of the browser | String |
62 | device_uaspec_system | devicedata.uaspec.system | User agent system identification of the browser | String |
63 | device_uaspec_platform | devicedata.uaspec.platform | User agent client platform of the browser | String |
64 | device_uaspec_raw | devicedata.uaspec.raw | Raw user agent of the browser | String |
65 | device_first_access | devicedata.firstaccess | First access of the device | Long (Epoch) |
66 | content_name | contentdata.name | Name of the content | String |
67 | content_object_type | contentdata.objecttype | Type of the content | String |
68 | content_type | contentdata.contenttype | Type of the resource | String |
69 | content_media_type | contentdata.mediatype | Type of media of the content | String |
70 | content_language | contentdata.language | List of languages | Array[String] |
71 | content_medium | contentdata.medium | Language medium of the board | String |
72 | content_mimetype | contentdata.mimetype | Mimetype of the content | String |
73 | content_framework | contentdata.framework | String | |
74 | content_board | contentdata.board | Board of affiliation | String |
75 | content_status | contentdata.status | Status of the content - Draft, Published etc. | String |
76 | content_version | contentdata.pkgversion | Version of the content | Double |
77 | content_last_submitted_on | contentdata.lastsubmittedon | Last submitted date of the content | Long (Epoch) |
78 | content_last_published_on | contentdata.lastpublishedon | Last published date of the content | Long (Epoch) |
79 | content_last_updated_on | contentdata.lastupdatedon | Last updated date of the content | Long (Epoch) |
80 | user_grade_list | userdata.gradelist | List of grades taught | Array[String] |
81 | user_language_list | userdata.languagelist | List of languages known | Array[String] |
82 | user_subject_list | userdata.subjectlist | List of subjects taught | Array[String] |
83 | user_type | userdata.type | Type of the user | String |
84 | user_loc_state | userdata.state | State info of the user | String |
85 | user_loc_district | userdata.district | District info of the user | String |
86 | user_loc_block | userdata.block | Block info of the user | String |
Aggregates
Granularity → DAY
Druid field name | Druid source field | Aggregate Type |
---|---|---|
total_interactions | interaction_count | SUM |
total_time_spent | time_spent | SUM |
total_sessions | mid | COUNT |
Report JSON Spec
JSON Schema
[{ id: String, // Required. Report ID. label: String, // Required. Report Label (will be shown up as menu) title: String, // Optional. Report title. Defaults to report label description: String, // Optional. Report description. HTML text can be included as description dataSource: String, // Required. Location of the data source to show the report. Can be an expression. For ex: /<report_id>/{{channel}}/report.json charts: [{ // Optional datasets: [{ data: Array[Number], // Required if `dataExpr` is not provided. Array of Number. Data points to show in the chart dataExpr: String, // Required if `data` is not provided. Expression pointing to the data in dataSource. For ex: {{data.noOfDownloads}} label: String // Required. Label to display on the chart }], labels: Array[String], // Required if `labelsExpr` is not provided. Labels to show on the x-axis labelsExpr: String, // Required if `labels` is not provided. Expression pointing to the data in dataSource. For ex: {{data.Date}} chartType: String, // Optional. Defaults to line. Available types - line, bar, radar, pie, polarArea & doughnut colors: [""], // Optional. Color to show for each dataset. Defaults to ["#024F9D"]. options: { // Optional. options for display. Full set of options look at https://valor-software.com/ng2-charts/ responsive: Boolean, // Defaults to true ... }, legend: Boolean // Optional. Whether to show the legend below/above the chart. Defaults to true and position to top. }], table: { // Optional "columns": Array[String], // Required if `columnsExpr` is not provided. Columns to show. "values": Array[Array[String]], // Required if `valuesExpr` is not provided. Column data. "columnsExpr": String, // Required if `columns` is not provided. Expression pointing to the data in dataSource. For ex: {{keys}} "valuesExpr": String // Required if `values` is not provided. Expression pointing to the data in dataSource. For ex: {{tableData}} }, downloadUrl: String // Location to download the data as CSV }]
Following is a example schema to show the general usage report
{ id: "usage", label: "Diksha Usage Report", title: "Diksha Usage Report", description: "The report provides a quick summary of the data analysed by the analytics team to track progess of Diksha across states. This report will be used to consolidate insights using various metrics on which Diksha is currently being mapped and will be shared on a weekly basis. The first section of the report will provide a snapshot of the overall health of the Diksha App. This will be followed by individual state sections that provide state-wise status of Diksha", dataSource: "/usage/$state/report.json", charts: [ { datasets: [{ dataExpr: "data.Number_of_downloads", label: "# of downloads" }], labelsExpr: "data.Date", chartType: "line" }, { datasets: [{ dataExpr: "data.Number_of_succesful_scans", label: "# of successful scans" }], labelsExpr: "data.Date", chartType: "bar" } ], table: { "columnsExpr": "key", "valuesExpr": "tableData" }, downloadUrl: "<report_id>/$state/report.csv" }