活動合約
查詢期望的欄位
| 欄位 | 型別 | 為什麼存在 |
|---|---|---|
| timestamp_utc | Timestamp | UTC 里程碑時間。 |
| session_id | Utf8 | 由旅程事件共享的已批准會話識別符號。 |
| step_name | Utf8 | 受控旅程里程碑。 |
| step_order | Int64 | 穩定的基於一的里程碑訂單。 |
| acquisition_source | Utf8 | 有限的獲取源。 |
| environment | Utf8 | 部署環境。 |
DataFusion SQL
複製查詢
sql
WITH step_counts AS (
SELECT
step_order,
step_name,
COUNT(*) AS sessions_reached
FROM product_journey_events
WHERE timestamp_utc >= now() - INTERVAL '30 days'
AND environment = 'production'
GROUP BY step_order, step_name
)
SELECT
step_order,
step_name,
sessions_reached,
100.0 * sessions_reached
/ NULLIF(FIRST_VALUE(sessions_reached) OVER (ORDER BY step_order), 0)
AS journey_completion_pct,
100.0 * sessions_reached
/ NULLIF(COALESCE(LAG(sessions_reached) OVER (ORDER BY step_order), sessions_reached), 0)
AS step_to_step_pct
FROM step_counts
ORDER BY step_order;此只讀查詢是針對空型別資料表計劃和執行的 阿帕奇 DataFusion 45.2.0。確定性樣本輸出是綜合的並單獨審查;根據您自己的資料驗證欄位型別、閾值和業務定義。 閱讀測試方法。
查詢結果
會話旅程完成
五個綜合會話中有兩個達到第一個查詢里程碑。
landing_viewed5
signup_completed4
workspace_created3
first_query_run2
| step_order | step_name | sessions_reached | journey_completion_pct | step_to_step_pct |
|---|---|---|---|---|
| 1 | landing_viewed | 5 | 100 | 100 |
| 2 | signup_completed | 4 | 80 | 80 |
| 3 | workspace_created | 3 | 60 | 75 |
| 4 | first_query_run | 2 | 40 | 66.67 |
綜合範例輸出。在將其用於操作決策之前,針對您自己的事件架構和閾值執行查詢。
SQL 是如何工作的
- 1會話是顯式的計數單位;僅當與決策匹配時才將其替換為使用者或帳戶。
- 2旅程完成將每個步驟與進入進行比較,而逐步轉換則隔離直接轉換。
- 3受控的步驟順序可防止時間戳或標籤默默地重新排列漏斗。
需要決定的邊緣情況
- 在對嘈雜的生產者使用此模式之前,請對每個會話中重複的里程碑事件進行重複資料刪除。
- 選擇步驟是否必須按順序並在一個會話內進行;更嚴格的渠道需要按會話排序。
- 記錄匿名到經過身分驗證的身分拼接並進行隱私審查。
推薦儀表板
- 漏斗:sessions_reached by step_name
- 條形:step_to_step_pct(按採集源)
- 趨勢:first_query_run 按註冊周完成
讓查詢範例發揮作用
相關埋點和指南
繼續分析
在真實事件中執行它
建立資料表,調整欄位並儲存結果
免費開始,傳送結構化事件,並將查詢結果用作圖表、共享儀表板小工具或警示輸入。