实际上因为pipelinedb 是原生支持pg的，所以应该不存在太大的问题，以下为测试

使用doker-compose 运行

配置

• docker-compose 文件

version: '3.6'services:  postgres:    image: tkanos/pipelinedb_kafka    ports:    - "5432:5432"  graphql-engine:    image: hasura/graphql-engine:v1.0.0-alpha06    ports:    - "8080:8080"    depends_on:    - "postgres"    environment:    - "POSTGRES_PASSWORD:pipeline"    command: >      /bin/sh -c "      graphql-engine --database-url postgres://pipeline:pipeline@postgres:5432/pipeline serve --enable-console;      "volumes:  db_data:

• 说明
  主要是进行pipelinedb 的添加以及graphql-engine 的连接pg的配置

启动&&运行

• 启动

docker-compose up -d

• 效果
  

添加pipelinedb 数据

stream 操作

• 创建stream

CREATE STREAM stream_test1 (x integer, y integer,z text);

• 创建 CONTINUOUS

CREATE CONTINUOUS VIEW v_sum as select sum( x + y ) FROM stream_test1;CREATE CONTINUOUS VIEW V_GROUP AS SELECT count(*) as coun,x,y,z FROM stream_test1 GROUP BY x,y,z;

• 插入数据

INSERT INTO stream_test1(x,y,z) VALUES(1,2,'A'),(3,4,'B'),(5,6,'C'),(7,8,'D'),(1,2,'A');

• 查询

select * from v_sum;select * from v_group;

添加graphql table

• 查看pipelinedb 系统创建的表
  
• 添加 graphql 支持
  
• 数据查询
  

说明

结合起来使用还是很方便的，即有hasura引擎的简单，同时集成了pipelinedb的stream 特性，很好很强大

参考资料