Merge pull request #224 from ddxv/add-user-sessions

Add user sessions

Author: ddxv

apps/analytics-db/create/daily_overview.sql

@@ -12,6 +12,7 @@ CREATE TABLE daily_overview
     clicks SimpleAggregateFunction(Sum, UInt64),
     installs SimpleAggregateFunction(Sum, UInt64),
     revenue Nullable (SimpleAggregateFunction (Sum, Decimal (38, 4))) DEFAULT 0,
+    user_sessions SimpleAggregateFunction(Sum, UInt64),
     dau SimpleAggregateFunction(Sum, UInt64),
     dx_1 SimpleAggregateFunction(Sum, UInt64),
     dx_2 SimpleAggregateFunction(Sum, UInt64),

apps/analytics-db/create/daily_overview_mv.sql

@@ -17,6 +17,7 @@ WITH combined AS (
             0 AS clicks,
             0 AS installs,
             0 AS revenue,
+            0 AS user_sessions,
             0 AS dau,
             0 AS dx_1,
             0 AS dx_2,
@@ -58,6 +59,7 @@ UNION ALL
             count() AS clicks,
             0 AS installs,
             0 AS revenue,
+            0 AS user_sessions,
             0 AS dau,
             0 AS dx_1,
             0 AS dx_2,
@@ -99,6 +101,7 @@ SELECT
             0 AS clicks,
             count() AS installs,
             0 AS revenue,
+            0 AS user_sessions,
             0 AS dau,
             0 AS dx_1,
             0 AS dx_2,
@@ -140,6 +143,7 @@ SELECT
     0 AS clicks,
     0 AS installs,
     0 AS revenue,
+    0 AS user_sessions,
     0 AS dau,
     sum(dx_1) AS dx_1,
     sum(dx_2) AS dx_2,
@@ -181,7 +185,8 @@ SELECT
     0 AS clicks,
     0 AS installs,
     0 AS revenue,
-    sum(event_count) AS dau,
+    sum(event_count) AS user_sessions,
+    sum(unique_users) AS dau,
     0 AS dx_1,
     0 AS dx_2,
     0 AS dx_3,
@@ -222,6 +227,7 @@ SELECT
     sum(clicks) AS clicks,
     sum(installs) AS installs,
     sum(revenue) AS revenue,
+    sum(user_sessions) AS user_sessions,
     sum(dau) AS dau,
     sum(dx_1) AS dx_1,
     sum(dx_2) AS dx_2,

apps/analytics-db/create/user_daily_events_attributed.sql

@@ -12,6 +12,7 @@ CREATE TABLE user_daily_events_attributed
   `state_iso` LowCardinality(String),
   `city_name` String,
   `event_count` Int32,
+  `unique_users` Int32
 )
 ENGINE = AggregatingMergeTree
 ORDER BY (event_date, event_id, store_id, network, campaign_name, campaign_id, ad_name, ad_id, country_iso, state_iso, city_name);

apps/analytics-db/create/user_daily_events_attributed_mv.sql

@@ -14,7 +14,8 @@ SELECT
     ai.country_iso,
     ai.state_iso,
     ai.city_name,
-    sum(uda.event_count) as event_count
+    sum(uda.event_count) as event_count,
+    count(distinct uda.oa_uid) as unique_users
 FROM user_daily_events uda
 LEFT JOIN attributed_installs ai ON uda.oa_uid = ai.oa_uid
 GROUP BY 

apps/dash-backend/dash_api/controllers/analytics.py

@@ -29,6 +29,7 @@
     "clicks",
     "installs",
     "revenue",
+    "user_sessions",
     "dau",
     "dx_1",
     "dx_2",
@@ -61,6 +62,7 @@ def query_campaign_overview(start_date: str, end_date: str) -> pd.DataFrame:
                         sum(clicks) as clicks,
                         sum(installs) as installs,
                         sum(revenue) as revenue,
+                        sum(user_sessions) as user_sessions,
                         sum(dau) as dau,
                         sum(dx_1) as dx_1,
                         sum(dx_2) as dx_2,