快速开始

首先，请完成 PipelineDB安装。

维基百科流量统计

在下面的示例中，我们将基于维基百科一天中的 页面浏览数据 做一些基础统计。每条记录包含每个维基百科页面每小时的页面浏览统计，格式如下：

hour | project | page title | view count | bytes served

首先，使用 psql 创建数据流（foreign table）：

psql -c "
CREATE FOREIGN TABLE wiki_stream (
        hour timestamp,
        project text,
        title text,
        view_count bigint,
        size bigint)
SERVER pipelinedb;
CREATE VIEW wiki_stats WITH (action=materialize) AS
SELECT hour, project,
        count(*) AS total_pages,
        sum(view_count) AS total_views,
        min(view_count) AS min_views,
        max(view_count) AS max_views,
        avg(view_count) AS avg_views,
        percentile_cont(0.99) WITHIN GROUP (ORDER BY view_count) AS p99_views,
        sum(size) AS total_bytes_served
FROM wiki_stream
GROUP BY hour, project;"

然后解压数据集，并通过 stdin 以 COPY 的形式写入到数据流（foreign table）中：

curl -sL http://pipelinedb.com/data/wiki-pagecounts | gunzip | \
        psql -c "
        COPY wiki_stream (hour, project, title, view_count, size) FROM STDIN"

由于数据集很大，所以上面的指令会运行比较长的时间（可随时中止写入）。当写入动作执行时，可以从数据流（foreign table）中查询数据：

psql -c "
SELECT * FROM wiki_stats ORDER BY total_views DESC";