查找最后 5 分钟的页面浏览量

【问题标题】：finding last 5 minutes page views查找最后 5 分钟的页面浏览量
【发布时间】：2019-03-22 00:23:43
【问题描述】：

我有一个名为 page_views 的 kafka 主题和一个名为 pageviews 的流。现在我想计算最近 5 分钟查看的页面。我正在使用 ksql。尝试过

SELECT after->pageview_id FROM pageviews WHERE after->pageview_id >= NOW() - INTERVAL 10 MINUTE;

和

SELECT AFTER ->pageview_id FROM pageviews WHERE after->pageview_id >= sysdate - 5/(24*60);

但不工作。这是嵌套的 avro 架构。

【问题讨论】：

标签： apache-kafka ksqldb

【解决方案1】：

您可以使用HOPPING window 在 KSQL 中模拟滑动窗口。对于跳跃窗口，您应该指定窗口大小，在这种情况下为 5 minutes 和指示窗口如何移动的提前值，即滑动（例如，每 1 秒）。所以你可以写一个这样的查询：

CREATE STREAM foo AS SELECT after->pageview_id AS pv_id FROM pageviews;

CREATE TABLE bar AS SELECT pv_id, COUNT(pv_id) FROM foo WINDOW HOPPING (SIZE 5 MINUTES, ADVANCE BY 1 SECOND) GROUP BY pv_id;

有关HOPPING WINDOW 的更多信息，请参阅以下页面：

【讨论】：