Postgres Broker for Huey 任务队列
项目描述
=====================================
huey-pg -- 为Huey提供Postgres代理
=====================================
huey是一个简单的Python任务队列实现。huey-pg提供了
基于Postgres的huey存储实现。
**该项目尚未实现所有功能**。
功能
========
- 非常简单的部署。
- 消息存储在一个表中。
- 所有数据都包含在专用模式中。
- 使用LISTEN/NOTIFY来保持工作者同步。无需轮询。
- 由于Postgres MVCC而可靠。
- 使用plain psycopg2。不使用ORM。
安装
============
- 从PyPI安装huey-pg包:
pip install huey-pg
- 在您的数据库中应用``huey-pg.sql``文件:
psql -f huey-pg.sql
- 然后使用``PostgresHuey``类
import psycopg2.pool
from huey_pg import PostgresHuey
pool = psycopg2.pool.ThreadedConnectionPool(0, 4, conninfo)
huey = Postgres(connection_pool=pool))
@huey.task
def hello(name)
print(f"Hello {name}!")
路线图
=======
- 在恢复工作者时处理丢失的通知。
- 功能测试。
- 结果存储。
- 延迟和计划任务。
.. _huey:: https://huey.rtfd.io/
huey-pg -- 为Huey提供Postgres代理
=====================================
huey是一个简单的Python任务队列实现。huey-pg提供了
基于Postgres的huey存储实现。
**该项目尚未实现所有功能**。
功能
========
- 非常简单的部署。
- 消息存储在一个表中。
- 所有数据都包含在专用模式中。
- 使用LISTEN/NOTIFY来保持工作者同步。无需轮询。
- 由于Postgres MVCC而可靠。
- 使用plain psycopg2。不使用ORM。
安装
============
- 从PyPI安装huey-pg包:
pip install huey-pg
- 在您的数据库中应用``huey-pg.sql``文件:
psql -f huey-pg.sql
- 然后使用``PostgresHuey``类
import psycopg2.pool
from huey_pg import PostgresHuey
pool = psycopg2.pool.ThreadedConnectionPool(0, 4, conninfo)
huey = Postgres(connection_pool=pool))
@huey.task
def hello(name)
print(f"Hello {name}!")
路线图
=======
- 在恢复工作者时处理丢失的通知。
- 功能测试。
- 结果存储。
- 延迟和计划任务。
.. _huey:: https://huey.rtfd.io/
项目详情
下载文件
下载适用于您平台的应用程序。如果您不确定选择哪个,请了解有关安装包的更多信息。
源分布
huey-pg-0.1.0.tar.gz (3.2 kB 查看哈希值)
构建分发版
huey_pg-0.1.0-py3-none-any.whl (6.0 kB 查看哈希值)
关闭
huey-pg-0.1.0.tar.gz 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | 1e369d0eee319f0465ac06ee58dcd6f745f41ff6dab406dc2330647942184713 |
|
MD5 | 59183d27600343d4a312448576b9de0a |
|
BLAKE2b-256 | fd98b71304c55a1ce8c8ffce2196cbea434eac345954a7edb7887cd19bfe8bca |
关闭
huey_pg-0.1.0-py3-none-any.whl 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | 9a62dd204d920073e131caf836ae45d0458e98e249c28d8e0522b2a3d2f9a337 |
|
MD5 | 7f47857b52d2d4995f06ed35ab2f36c6 |
|
BLAKE2b-256 | e62ca436612500f4e1e4eed7858511fc57274ea3c05de6d615d541e18fdd8df9 |