活动合约
查询期望的字段
| 字段 | 类型 | 为什么存在 |
|---|---|---|
| timestamp_utc | Timestamp | 订阅活动时间。 |
| account_id | Utf8 | 稳定的计费帐户标识符。 |
| event_name | Utf8 | trial_started 或 subscription_started。 |
| acquisition_source | Utf8 | 审判开始时捕获的消息来源。 |
DataFusion SQL
复制查询
sql
WITH trials AS (
SELECT
account_id,
MIN(timestamp_utc) AS trial_started_at,
MIN(acquisition_source) AS acquisition_source
FROM subscription_events
WHERE event_name = 'trial_started'
AND timestamp_utc >= now() - INTERVAL '120 days'
GROUP BY account_id
),
paid AS (
SELECT
account_id,
MIN(timestamp_utc) AS paid_at
FROM subscription_events
WHERE event_name = 'subscription_started'
GROUP BY account_id
)
SELECT
date_trunc('week', trials.trial_started_at) AS trial_week,
trials.acquisition_source,
COUNT(*) AS trial_accounts,
SUM(CASE
WHEN paid.paid_at >= trials.trial_started_at
AND paid.paid_at < trials.trial_started_at + INTERVAL '30 days'
THEN 1 ELSE 0
END) AS paid_accounts,
100.0 * SUM(CASE
WHEN paid.paid_at >= trials.trial_started_at
AND paid.paid_at < trials.trial_started_at + INTERVAL '30 days'
THEN 1 ELSE 0
END) / NULLIF(COUNT(*), 0) AS conversion_rate_pct
FROM trials
LEFT JOIN paid ON paid.account_id = trials.account_id
GROUP BY
date_trunc('week', trials.trial_started_at),
trials.acquisition_source
ORDER BY trial_week, acquisition_source;此只读查询是针对空类型表计划和执行的 阿帕奇 DataFusion 45.2.0。确定性样本输出是综合的并单独审查;根据您自己的数据验证字段类型、阈值和业务定义。 阅读测试方法。
查询结果
按来源进行三十天试用转换
尽管群体规模最小,但产品推荐的转化率却最高。
docs
22.28%
paid_search
11.94%
product_referral
29.17%
| trial_week | acquisition_source | trial_accounts | paid_accounts | conversion_rate_pct |
|---|---|---|---|---|
| 2026-06-29 | docs | 184 | 41 | 22.28 |
| 2026-06-29 | paid_search | 310 | 37 | 11.94 |
| 2026-07-06 | product_referral | 96 | 28 | 29.17 |
综合示例输出。在将其用于操作决策之前,针对您自己的事件架构和阈值运行查询。
SQL 是如何工作的
- 1试验 CTE 为每个账户创建一个群组记录。
- 2付费 CTE 可以防止多个订阅事件对同一帐户进行两次计数。
- 330 天的条件使队列保持可比性,即使最终转变发生得晚得多。
需要决定的边缘情况
- 在比较最终比率之前排除尚未完成完整转化窗口的群组。
- 决定取消并重新启动的试验应如何进入队列。
- 在试用开始时保留获取来源,以便以后的归因更改不会重写历史记录。
推荐仪表板
- 酒吧:conversion_rate_pct by acquisition_source
- 趋势:trial_week 付费转化
- 表:接近转换窗口结束的试验
让查询示例发挥作用
相关埋点和指南
继续分析
在真实事件中运行它
创建表,调整字段并保存结果
免费开始,发送结构化事件,并将查询结果用作图表、共享仪表板小部件或警报输入。