simqcore 0.2.1

基于redis的消息队列。

simqcore

基于redis的消息队列。

特性

• 支持消息的队尾插入（FIFO），也可视为普通消息。
• 支持消息的队首插入（FILO），也可视为高优先级消息。
• 支持消息的消费确认。
• 支持超时未确认消息的自动回收。
• 支持消息超时策略的设定。
• 支持多通道。
• 支持未执行消息的取消。
• 支持执行器在获取消息后主动释放消息。
• 消息体使用yaml进行序列化，支持datetime、bytes等类型数值。

安装

pip install simqcore

注意

• 如果使用db（即redis实例）构建的SimQ实例，可能存在非线程安全问题。
• 在多线程中使用，建议使用connection_pool来构建SimQ实例。

版本

0.1.0

• 版本首发。

0.2.0

• 添加asyncio支持。

0.2.1

• 添加使用redis connection pool来实例化SimQ对象。