的 Postgresql 连接池 - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
dikT
V2EX    分享发现

的 Postgresql 连接池

  •  
  •   dikT 2017 年 3 月 31 日 6563 次点击
    这是一个创建于 3253 天前的主题,其中的信息可能已经有所发展或是发生改变。

    的 Postgresql 连接池

    原文是这么描述的

    class psycopg2.pool.AbstractConnectionPool(minconn, maxconn, *args, **kwargs) Base class implementing generic key-based pooling code. New minconn connections are created automatically. The pool will support a maximum of about maxconn connections. *args and **kwargsare passed to the connect() function. The following methods are expected to be implemented by subclasses: getconn(key=None) Get a free connection and assign it to key if not None. putconn(conn, key=None, close=False) Put away a connection. If close is True, discard the connection from the pool. closeall() Close all the connections handled by the pool. Note that all the connections are closed, including ones eventually in use by the application. 

    大致意思是说在创建这个pool对象时,会自动创建参数minconn个数的连接池.并且最终最多能支持maximum这么多个链接

    然后这个pool提供getconn,putconn,closeall三个方法

    getconn用于获取一个链接, 可选参数key,传入获取对应的链接

    putconn回收一个链接, 可选参数key,与 get 与之相对

    closeall关闭所有链接

    试一试

    普通的 connect, 10000 次查询

    import database from time import time t = time() n = 10000 db = database.PSQL() while n: db.get_conn() data = db.query(table="vshop_order", columns=["id", "order_no", "state"], order_by="-id", limit=1) n -= 1 print(time() - t) $: 138.07099604606628 

    使用连接池

    import database from time import time db = database.PSQL() lst = [str(i) for i in range(20)] t = time() n = 10000 while n: key = lst.pop(0) db.get_conn(key) data = db.query(table="vshop_order", columns=["id", "order_no", "state"], order_by="-id", limit=1) n -= 1 db.put_conn(key) lst.append(key) print(time() - t) $: 8.982805013656616 

    效果还是很明显的, 重复测试多次,倍数范围都在 15 倍左右

    顺便说下环境

    • 数据库是部署在 vmware 上面,所以查询时间跟本机有一定差距
    • 电脑 Miix 5, CPU i5-6500u
    • 性能均衡模式

    源码下载

    >>>原文地址<<<

    10 条回复    2017-04-11 09:20:44 +08:00
    welsmann
        1
    welsmann  
       2017 年 3 月 31 日
    ....连接池不就是干这个的吗....
    dikT
        2
    dikT  
    OP
       2017 年 3 月 31 日
    @welsmann 然而我们公司之前的框架都是实例化一个新对象...
    glasslion
        3
    glasslion  
       2017 年 3 月 31 日   1
    Postgresql 连接池一般用 pgbounce 或 pgpool 之类的中间件
    dikT
        4
    dikT  
    OP
       2017 年 3 月 31 日
    @glasslion tks,我去看看
    stabc
        5
    stabc  
       2017 年 3 月 31 日
    我对这个概念不懂,这是不是一万次查询和一万次连接数据库的性能差别?
    imherer
        6
    imherer  
       2017 年 3 月 31 日
    1069401249
        7
    1069401249  
       2017 年 3 月 31 日   1
    没达到性能瓶颈吧,现在高并发的产品毕竟不多,所以你们还没做优化。。。
    dikT
        8
    dikT  
    OP
       2017 年 3 月 31 日
    @1069401249 是啊,去哪儿找那么多高并发 ( ° °)
    AcmeSa
        9
    AcmeSa  
       2017 年 4 月 11 日
    @welsmann S 的账号好象不能登录了,弱弱问一句,还能带我一起玩吗?
    dikT
        10
    dikT  
    OP
       2017 年 4 月 11 日
    @AcmeSa 你在说啥..
    关于     帮助文档     自助推广系统     博客     API     FAQ     Solana     849 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 33ms UTC 22:22 PVG 06:22 LAX 14:22 JFK 17:22
    Do have faith in what you're doing.
    ubao msn snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86