PipelineDB基于PostgreSQL数据库改造而来,是一款开源的流式计算数据库。它允许我们通过sql的方式,对数据流做操作,并把操作结果持续储存到表中。主要特性:允许只使用 SQL 进行实时数据处理而没有应用代码,兼容 PostgreSQL,无 ETL,高效可持续。
安装从rpm安装
从源码安装
下载代码
安装所需依赖
安装postgis和postgis所需的依赖
安装支持pipelinedb的postgis,在configure的时候需要指定pg_config文件,在这里是pipeline-config
编译
快速上手实例化数据目录
创建数据目录,修改数据目录属主
实例化数据目录
启动pipelinedb
修改配置文件,开启日志,调整监听端口等等,方法与postgresql一样。然后启动它:
连接到pipelinedb
aha,熟悉的终端界面,这里可以很清楚了,我使用的这个版本是基于postgresql的9.5.3开发的,版本还算比较新。:-)
查看版本
查看pipelinedb的版本可以用pipeline_version()函数:
举个栗子创建一个Stream
创建一个CONTINUOUS VIEW
写入测试数据
从外部获取数据实时写入pipelinedb
查询结果
客户端连接(python)
和postgresql一样,需要使用 psycopg2 。
领取专属 10元无门槛券
私享最新 技术干货