pq是postgresql的事务队列。
pq的Python项目详细描述
开始
所有功能都封装在一个类中。 < Buff行情> 类pq(conn=none,pool=none, table="queue', debug=false)
示例用法:
frompsycopg2importconnectfrompqimportPQconn=connect('dbname=example user=postgres')pq=PQ(conn)
对于多线程操作,请使用连接池,如 psycopg2.pool.threadedconnectionpool
您可能想确保您的数据库是用 编码。
要创建和配置队列表,请调用 create() 方法。
pq.create()
表名默认为 'queue' 。要使用不同的名称,请通过 它作为 pq 类的 表 参数的字符串值 (如上图所示)。