-
Notifications
You must be signed in to change notification settings - Fork 8
/
rule-based-attribution-modeling_pre_NOV_2023.sql
132 lines (115 loc) · 5.13 KB
/
rule-based-attribution-modeling_pre_NOV_2023.sql
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
WITH conversions AS
(
SELECT
user_pseudo_id,
(SELECT value.int_value FROM unnest(event_params) WHERE key = "ga_session_id") as ga_session_id,
timestamp_micros(min(event_timestamp)) as session_start_timestamp,
sum(ecommerce.purchase_revenue) as revenue,
max(ecommerce.transaction_id) as transaction_id
FROM `analytics_1234.events_*`
WHERE event_name = "purchase" AND _table_suffix BETWEEN "20230710" AND "20230716"
GROUP BY 1,2
),
currentSessions
AS
(SELECT user_pseudo_id, ga_session_id, IF(gclid is not null, "cpc", medium) medium, min(session_start_timestamp) session_start_timestamp FROM
(SELECT user_pseudo_id,
(SELECT value.int_value FROM unnest(event_params) WHERE key = 'ga_session_id') as ga_session_id,
first_value(collected_traffic_source.manual_medium) OVER (PARTITION BY user_pseudo_id, (SELECT value.int_value FROM unnest(event_params) WHERE key = 'ga_session_id') ORDER BY event_timestamp) as medium,
first_value(collected_traffic_source.gclid) OVER (PARTITION BY user_pseudo_id, (SELECT value.int_value FROM unnest(event_params) WHERE key = 'ga_session_id') ORDER BY event_timestamp) as gclid,
timestamp_micros(event_timestamp) as session_start_timestamp
FROM `analytics_1234.events_*` WHERE event_name NOT IN ("session_start", "first_visit") AND _table_suffix BETWEEN "20230610" AND "20230716")
GROUP BY 1,2,3
),
precedingSessions AS
(SELECT DISTINCT user_pseudo_id, old_ga_session_id, IF(gclid is not null, "cpc", old_medium) old_medium FROM
(SELECT user_pseudo_id,
(SELECT value.int_value FROM unnest(event_params) WHERE key = 'ga_session_id') as old_ga_session_id,
first_value(collected_traffic_source.manual_medium) OVER (PARTITION BY user_pseudo_id, (SELECT value.int_value FROM unnest(event_params) WHERE key = 'ga_session_id') ORDER BY event_timestamp) as old_medium,
first_value(collected_traffic_source.gclid) OVER (PARTITION BY user_pseudo_id, (SELECT value.int_value FROM unnest(event_params) WHERE key = 'ga_session_id') ORDER BY event_timestamp) as gclid
FROM `analytics_1234.events_*` WHERE event_name NOT IN ("session_start", "first_visit") AND _table_suffix BETWEEN "20230510" AND "20230723")
),
interactions AS (
SELECT user_pseudo_id, ga_session_id, if(medium is null, (SELECT old_medium FROM unnest(old_sessions) WHERE old_medium is not null ORDER BY old_ga_session_id DESC LIMIT 1 ) ,medium) as medium,session_start_timestamp FROM (
SELECT user_pseudo_id, ga_session_id, medium, session_start_timestamp, ARRAY_AGG(struct(old_ga_session_id, old_medium)) as old_sessions FROM
currentSessions
LEFT OUTER JOIN
precedingSessions
USING(user_pseudo_id)
WHERE old_ga_session_id <= ga_session_id
GROUP BY 1,2,3,4)
),
base AS (
SELECT interactions, conversions.session_start_timestamp as conversion_timestamp, conversions.revenue, conversions.transaction_id,
count(*) OVER (PARTITION BY conversions.transaction_id) as totalInteractions,
ROW_NUMBER() OVER (PARTITION BY conversions.transaction_id ORDER BY interactions.session_start_timestamp) interactionNumber,
ROW_NUMBER() OVER (PARTITION BY conversions.transaction_id ORDER BY interactions.session_start_timestamp DESC) interactionNumber_DESC,
FROM
conversions
LEFT OUTER JOIN
interactions
USING (user_pseudo_id)
WHERE interactions.session_start_timestamp <= conversions.session_start_timestamp AND interactions.session_start_timestamp > TIMESTAMP_SUB(conversions.session_start_timestamp, INTERVAL 30 DAY)
),
decayAttr AS (
SELECT interactions.medium, sum(revenue*decayShare) as revenueDecay, sum(1*decayShare) as conversionsDecay FROM (
SELECT
*, decayShare_PN/sum(decayShare_PN) OVER (PARTITION BY transaction_id) decayShare
FROM
(SELECT *,
POW(0.5, (TIMESTAMP_DIFF(conversion_timestamp, interactions.session_start_timestamp, MINUTE)/(7*24*60))) decayShare_PN
FROM base)
)
GROUP BY 1),
positionBasedAttr AS (
SELECT
interactions.medium, sum(revenue*positionShare) as revenuePosition, sum(1*positionShare) as conversionsPosition
FROM
(SELECT *,
CASE
WHEN totalInteractions = 1 THEN 1
WHEN totalInteractions = 2 THEN 0.5
WHEN interactionNumber = 1 THEN 0.4
WHEN interactionNumber_Desc = 1 THEN 0.4
ELSE
0.2/(totalInteractions-2)
END as positionShare
FROM base)
GROUP BY 1),
linearAttr AS (
SELECT
interactions.medium,
sum(revenue/totalInteractions) as revenueLinear,
sum(1/totalInteractions) as conversionsLinear
FROM
base
GROUP BY 1
),
lastTouchAttr AS (
SELECT
interactions.medium, sum(revenue) as revenueLastTouch, count(distinct transaction_id) as conversionsLastTouch
FROM base
WHERE interactionNumber_DESC=1
GROUP BY 1
),
firstTouchAttr AS (
(SELECT
interactions.medium, sum(revenue) as revenueFirstTouch, count(distinct transaction_id) as conversionsFirstTouch
FROM base
WHERE interactionNumber=1
GROUP BY 1)
)
SELECT * FROM
firstTouchAttr
JOIN
lastTouchAttr
using(medium)
JOIN
linearAttr
using(medium)
JOIN
positionBasedAttr
using(medium)
JOIN
decayAttr
using(medium)