PostgreSQL流计算案例