活动合约
查询期望的字段
| 字段 | 类型 | 为什么存在 |
|---|---|---|
| timestamp_utc | Timestamp | 计费移动时间。 |
| account_id | Utf8 | 稳定的计费帐户标识符。 |
| movement_type | Utf8 | 新的、扩张、收缩、流失或重新激活。 |
| mrr_change_usd | Float64 | 签署标准化经常性收入变更。 |
DataFusion SQL
复制查询
sql
SELECT
date_trunc('month', timestamp_utc) AS month,
SUM(CASE
WHEN movement_type IN ('new', 'expansion', 'reactivation')
THEN mrr_change_usd ELSE 0.0
END) AS growth_mrr_usd,
-SUM(CASE
WHEN movement_type IN ('contraction', 'churn')
THEN mrr_change_usd ELSE 0.0
END) AS lost_mrr_usd,
SUM(mrr_change_usd) AS net_mrr_change_usd,
COUNT(DISTINCT account_id) AS accounts_changed
FROM billing_events
WHERE timestamp_utc >= now() - INTERVAL '12 months'
GROUP BY date_trunc('month', timestamp_utc)
ORDER BY month;此只读查询是针对空类型表计划和执行的 阿帕奇 DataFusion 45.2.0。确定性样本输出是综合的并单独审查;根据您自己的数据验证字段类型、阈值和业务定义。 阅读测试方法。
查询结果
经常性收入增长和损失
7 月份仍保持积极增长,但收缩和流失消耗了更多的总增长。
2026-05
18,400 USD
7,200 USD
2026-06
22,100 USD
9,800 USD
2026-07
20,700 USD
13,400 USD
| month | growth_mrr_usd | lost_mrr_usd | net_mrr_change_usd | accounts_changed |
|---|---|---|---|---|
| 2026-05 | 18,400 | 7,200 | 11,200 | 93 |
| 2026-06 | 22,100 | 9,800 | 12,300 | 117 |
| 2026-07 | 20,700 | 13,400 | 7,300 | 126 |
综合示例输出。在将其用于操作决策之前,针对您自己的事件架构和阈值运行查询。
SQL 是如何工作的
- 1积极的运动结合了新的、扩展的和重新激活的 MRR。
- 2丢失的 MRR 被否定为可读的正条,而净变化保留签名的总数。
- 3不同的账户计数有助于区分广泛的波动和异常大的合约。
需要决定的边缘情况
- 准确地发出一项计费更改动作或按提供商事件 ID 进行协调。
- 定义年度合同是否在预订或服务时贡献标准化的每月价值。
- 将一次性费用和使用收入与经常性收入分开。
推荐仪表板
- 堆叠条:growth_mrr_usd 和 lost_mrr_usd
- 趋势:net_mrr_change_usd
- 表:最大账户级别变动
让查询示例发挥作用
相关埋点和指南
定义源数据
此分析的事件模式
继续分析
在真实事件中运行它
创建表,调整字段并保存结果
免费开始,发送结构化事件,并将查询结果用作图表、共享仪表板小部件或警报输入。