sqsworkers 1.0

SQS工人

sqs工作器允许使用 多个工作线程。它使用python多线程优化cpu 由于大部分时间用于请求消息和 轮询SQS队列。它可以类似于aws lambda 不能（从现在起）与SQS一起使用。

用法

对SQS员工的基本呼叫如下：

fromsqsworkers.crewimportCrewcrew=Crew(sqs_session=session,queue_name=queue_name,message_processor=lambdamsg:print(f"hello, {msg}"))crew.start()

tests应该是信息型的

安装

将SQS工作线程添加到包依赖项中

requirements.txt

sqsworkers

然后使用pippip install -r requirements.txt

测试

确保测试通过

git clone https://github.com/goodmanship/sqsworkers
cd sqsworkers
python3 -m venv venv
. venv/bin/activate
pip install -e .[dev]
pytest --cov sqsworkers --mypy --black tests/

贡献者

欢迎提出请求、问题和评论。对于拉取请求：

• 为新功能和错误修复添加测试
<遵循现有风格< < > >
• 将不相关的更改分为多个拉取请求

对于更大的更改，请确保首先通过创建 一个问题并解释预期的变化。

Atlassian要求参与者签署参与者许可协议， 被称为cla。这是一个记录，表明贡献者 有权为项目提供代码/文件/翻译 并愿意将其用于分配和衍生工程（或 愿意转让所有权）。

在接受您的贡献之前，我们要求您遵循 下面的链接可以对cla进行数字签名。公司CIA是 为那些作为一个组织的成员和 个人cla是指那些作为个人做出贡献的人。

• CLA for corporate contributors
• CLA for individuals

版本

• 0.2.0-在concurrent.futures之上重写实现；添加测试
• 0.1.13-支持批量消息处理器
• 0.1.12-添加异常处理程序
• 0.1.11-自定义队列轮询
• 0.1.10-增加到轮询的最大等待时间
• 0.1.9-获取消息属性名
• 0.1.8-公共pypi的微调
• 0.1.7-线程命名错误修复
• 0.1.6-修复Emptry Sentry客户端的错误
• 0.1.5-pip安装的错误修复程序
• 0.1.4-支持ElasticMQ
• 0.1.2-初始版本

许可证

版权所有（c）2019 Atlassian和其他。Apache2.0许可，请参阅 LICENSE文件。