prisma 集成 pipelinedb测试

prisma init 

version: ‘3‘
services:
  prisma:
    image: prismagraphql/prisma:1.13
    restart: always
    ports:
    - "4466:4466"
    environment:
      PRISMA_CONFIG: |
        port: 4466
        # uncomment the next line and provide the env var PRISMA_MANAGEMENT_API_SECRET=my-secret to activate cluster security
        # managementApiSecret: my-secret
        databases:
          default:
            connector: postgres
            host: pipelinedb
            port: 5432
            user: pipeline
            password: pipeline
            migrations: true
  pipelinedb:
    image: tkanos/pipelinedb_kafka
    ports:
      - "5432:5432"

需要添加prisma 数据库，可以通过pg 客户端进行创建，用户密码 pipeline   pipeline

docker-compose up -d

prisma deploy

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

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;