在 Google BigQuery 中获取某个时间范围内的每周订阅明细

Question

如果我有每个订阅处于活动状态的时间段，是否有办法获取有关活动订阅的每周数据？ 我在 BigQuery 中有一个包含订阅列表的表：

+-----------------+---------+---------------+--------------+
| subscription_id | user_id | subscribed_at | cancelled_at |
+-----------------+---------+---------------+--------------+
|               1 |       2 | 2017-01-05    | 2017-06-03   |
|               2 |       3 | 2017-01-07    | 2017-09-15   |
|               3 |       4 | 2017-01-09    | NULL         |
|               4 |       1 | 2017-01-11    | 2017-05-27   |
|               5 |       3 | 2017-01-15    | NULL         |
+-----------------+---------+---------------+--------------+

我需要为每个唯一的 subscription_id + active_week 组合获取记录。像这样的：

+-----------------+---------+---------------+--------------+-------------+
| subscription_id | user_id | subscribed_at | cancelled_at | active_week |
+-----------------+---------+---------------+--------------+-------------+
|               1 |       2 | 2017-01-05    | 2017-06-03   |      201701 |
|               2 |       3 | 2017-01-07    | 2017-09-15   |      201701 |
|               1 |       2 | 2017-01-05    | 2017-06-03   |      201702 |
|               2 |       3 | 2017-01-07    | 2017-09-15   |      201702 |
|               3 |       4 | 2017-01-09    | NULL         |      201702 |
|               4 |       1 | 2017-01-11    | 2017-05-27   |      201702 |
|               1 |       2 | 2017-01-05    | 2017-06-03   |      201703 |
|               2 |       3 | 2017-01-07    | 2017-09-15   |      201703 |
|               3 |       4 | 2017-01-09    | NULL         |      201703 |
|               4 |       1 | 2017-01-11    | 2017-05-27   |      201703 |
|               5 |       3 | 2017-01-15    | NULL         |      201703 |
|             ... |      ...| ...           |...           |         ... |
+-----------------+---------+---------------+--------------+-------------+

我尝试从this 出发，但没有成功。

SELECT
  SPLIT(RPAD('', 1 + DATEDIFF(sub.ended_date, sub.started_date), '.'),'') AS weeks,
  sub.subscription_Id,
  sub.customer_id
FROM (
  SELECT
    subscribed_at AS started_date,
    CASE
      WHEN cancelled_at IS NULL THEN TIMESTAMP(CURRENT_DATE())
      ELSE TIMESTAMP(cancelled_at)
    END AS ended_date,
    subscription_id,
    customer_id
  FROM
    [subscriptions]) AS sub

非常感谢您的帮助！

最好， 拒绝

Answer 1

以下是 BigQuery 标准 SQL

#standardSQL
WITH temp AS (
  SELECT subscription_id, user_id, 
    PARSE_DATE('%Y-%m-%d', subscribed_at) subscribed_at, 
    PARSE_DATE('%Y-%m-%d', cancelled_at) cancelled_at
  FROM `project.dataset.subscriptions`
), weeks AS (
  SELECT 
    wk week_start, 
    DATE_ADD(wk, INTERVAL 6 DAY) week_end
  FROM (
    SELECT GENERATE_DATE_ARRAY(
        DATE_TRUNC(MIN(subscribed_at), WEEK), 
        CURRENT_DATE(), INTERVAL 1 WEEK) weeks
    FROM temp
  ), UNNEST(weeks) wk
)
SELECT subscription_id, user_id, subscribed_at, cancelled_at, week_start, week_end
FROM weeks
JOIN temp
ON subscribed_at <= week_end
AND IFNULL(cancelled_at, CURRENT_DATE()) > week_start

请注意：我假设您的 subscribed_at 和 cancelled_at 字段属于 STRING 数据类型 - 这就是为什么有一个额外的 temp 子查询负责将它们转换为 DATE 字段。如果原始表中的各个字段已经是 DATE 数据类型 - 您应该删除 temp 的使用，而只使用 `project.dataset.subscriptions`。

您可以使用您问题中的虚拟数据测试/玩上述查询，如下所示

#standardSQL
WITH `project.dataset.subscriptions` AS (
  SELECT 1 subscription_id, 2 user_id, '2017-01-05' subscribed_at, '2017-06-03' cancelled_at UNION ALL
  SELECT 2, 3, '2017-01-07', '2017-09-15' UNION ALL
  SELECT 3, 4, '2017-01-09', NULL UNION ALL
  SELECT 4, 1, '2017-01-11', '2017-05-27' UNION ALL
  SELECT 5, 3, '2017-01-15', NULL
), temp AS (
  SELECT subscription_id, user_id, 
    PARSE_DATE('%Y-%m-%d', subscribed_at) subscribed_at, 
    PARSE_DATE('%Y-%m-%d', cancelled_at) cancelled_at
  FROM `project.dataset.subscriptions`
), weeks AS (
  SELECT 
    wk week_start, 
    DATE_ADD(wk, INTERVAL 6 DAY) week_end
  FROM (
    SELECT GENERATE_DATE_ARRAY(
        DATE_TRUNC(MIN(subscribed_at), WEEK), 
        CURRENT_DATE(), INTERVAL 1 WEEK) weeks
    FROM temp
  ), UNNEST(weeks) wk
)
SELECT subscription_id, user_id, subscribed_at, cancelled_at, week_start, week_end
FROM weeks
JOIN temp
ON subscribed_at <= week_end
AND IFNULL(cancelled_at, CURRENT_DATE()) > week_start
ORDER BY week_start, subscription_id

另请注意：在上述查询中 - 星期从星期日开始
如果您想从星期一开始计算周数 - 您应该在 weeks CTE 中调整一点 week_start 和 week_end - 如下所示

    DATE_ADD(wk, INTERVAL 1 DAY) week_start, 
    DATE_ADD(wk, INTERVAL 7 DAY) week_end