在一行中为存储在 Google BigQuery 中的 Firebase 事件选择多个事件参数

Question

我正在尝试对存储在 Google BigQuery 中的 Firebase 事件执行非常简单的查询，但我无法找到方法。

在 Android 应用中，我正在记录这样的事件：

Bundle params = new Bundle();
params.putInt("productID", productId);
params.putInt(FirebaseAnalytics.Param.VALUE, value);
firebaseAnalytics.logEvent("productEvent", params);

所以，在 BigQuery 中我有这样的东西：

 ___________________ _______________________ _______________
| event_dim.name | event_dim.params.key | event_dim.params.int_value |
|___________________|_______________________|_________________________|
|产品活动 |产品ID | 25 |
| |_______________________|_____________________________|
| |价值 |第1253章
|___________________|_______________________|_________________________| 

当我从这个表中获取数据时，我得到两行：

 ___________________ _______________________ _______________
|event_dim.name | event_dim.params.key | event_dim.params.int_value |
|___________________|_______________________|_________________________|
|产品活动 |产品ID | 25 |
|产品活动 |价值 | 12353 |

但我真正需要的是这个表中的一个 SELECT 子句来获取如下数据：

 ___________________ _____________ _________
|姓名 |产品ID |价值 |
|___________________|_____________|_________|
|产品活动 | 25 | 12353 |

有什么想法或建议吗？

Answer 1

您可以像这样将值转置到列中

SELECT 
  event_dim.name as name,
  MAX(IF(event_dim.params.key = "productID", event_dim.params.int_value, NULL)) WITHIN RECORD productID,
  MAX(IF(event_dim.params.key = "value", event_dim.params.int_value, NULL)) WITHIN RECORD value,
FROM [events] 

如果您想使用 SQL 生成此命令，请参阅此解决方案：Pivot Repeated fields in BigQuery

Answer 2

使用standard SQL（取消选中UI中“显示选项”下的“使用旧版SQL”），您可以将查询表示为：

SELECT 
  event_dim.name as name,
  (SELECT value.int_value FROM UNNEST(event_dim.params)
   WHERE key = "productID") AS productID,
  (SELECT value.int_value FROM UNNEST(event_dim.params)
   WHERE key = "value") AS value
FROM `dataset.mytable` AS t,
  t.event_dim AS event_dim;

编辑：根据下面的评论，更新示例以将 int_value 包含为 value 的一部分。这是一个独立的示例，也演示了该方法：

WITH T AS (
  SELECT ARRAY_AGG(event_dim) AS event_dim
  FROM (
    SELECT STRUCT(
        "foo" AS name,
        ARRAY<STRUCT<key STRING, value STRUCT<int_value INT64, string_value STRING>>>[
          ("productID", (10, NULL)), ("value", (5, NULL))
        ] AS params) AS event_dim
    UNION ALL
    SELECT STRUCT(
        "bar" AS name,
        ARRAY<STRUCT<key STRING, value STRUCT<int_value INT64, string_value STRING>>>[
          ("productID", (13, NULL)), ("value", (42, NULL))
        ] AS params) AS event_dim
  )
)
SELECT 
  event_dim.name as name,
  (SELECT value.int_value FROM UNNEST(event_dim.params)
   WHERE key = "productID") AS productID,
  (SELECT value.int_value FROM UNNEST(event_dim.params)
   WHERE key = "value") AS value
FROM T AS t,
  t.event_dim AS event_dim;