基于PostgreSQL的流式计算数据库PipelineDB--一些重要的功能

浏览: 1710

PipelineDB一些重要功能,这里接列一下:

SQL的一些高级应用:

基于PostgreSQL的流式计算数据库PipelineDB

--Output Streams 基于汇总的前后比较

CREATE CONTINUOUS VIEW v_sum AS SELECT sum(x) FROM stream;
CREATE CONTINUOUS VIEW v_deltas AS SELECT abs((new).sum - (old).sum) AS delta
  FROM output_of('v_sum')
  WHERE abs((new).sum - (old).sum) > 10;

  --windows 范围

CREATE CONTINUOUS VIEW v_ttl WITH (ttl = '1 month', ttl_column = 'minute') AS
  SELECT minute(arrival_timestamp), COUNT(*) FROM some_stream GROUP BY minute;

--stream dispatch

CREATE CONTINUOUS TRANSFORM t AS
  SELECT x::int, y::int FROM stream WHERE mod(x, 2) = 0
  THEN EXECUTE PROCEDURE pipeline_stream_insert('even_stream');

数据字典/和执行统计查询

执行情况

pipeline_version ( )
pipeline_views ( )
pipeline_transforms ( )

统计数据

pipeline_query_stats


pipeline_stream_stats


备份/回复

具体见http://docs.pipelinedb.com/backups.html

pipeline-dump > backup.sql
pipeline -f backup.sql

Python连接

Python连接pipelinedb需要安装psycopg2,还是执行SQL语句,具体见http://docs.pipelinedb.com/clients.html

 import psycopg2
conn = psycopg2.connect('dbname=test user=user host=localhost port=5432')
pipeline = conn.cursor()
for x in range(10):
    rows.append({'x': x})

pipeline.executemany('INSERT INTO stream (x) VALUES (%(x)s)', rows)

 PS.

今天把剩下的版本<一切皆有价>看完了,信仰的价格这章很有意思,联想到前几天看的<量子物理史话>最后也变成的一个哲学问题

Matrix是无处不在的,也许这就是现实啊^-^

推荐 1
本文由 seng 创作,采用 知识共享署名-相同方式共享 3.0 中国大陆许可协议 进行许可。
转载、引用前需联系作者,并署名作者且注明文章出处。
本站文章版权归原作者及原出处所有 。内容为作者个人观点, 并不代表本站赞同其观点和对其真实性负责。本站是一个个人学习交流的平台,并不用于任何商业目的,如果有任何问题,请及时联系我们,我们将根据著作权人的要求,立即更正或者删除有关内容。本站拥有对此声明的最终解释权。

0 个评论

要回复文章请先登录注册