celery-batches 0.9

Celery Batches

Celery Batches提供了一个Task类，允许将多个Celery任务调用一起作为列表处理。任务调用缓冲区在计时器上刷新，并基于队列中的任务数量。

任务调用批处理的一些潜在用例包括

• 去重任务。

• 累积/仅处理具有类似参数的最新任务。

• 批量插入/更新数据。

• 具有昂贵设置的任务，可以在一系列参数上运行。

我需要什么？

celery-batches版本运行在，

• Python (3.8, 3.9, 3.10, 3.11, 3.12)

• PyPy3 (7.6)

并且与Celery ~= 5.0进行了测试。

如果您正在运行较旧的Python版本，则需要运行较旧的celery-batches版本

• Python 2.7：celery-batches 0.3。

• Python 3.4: celery-batches 0.2。

• Python 3.5: celery-batches 0.3。

• Python 3.6: celery-batches 0.5。

• Python 3.7: celery-batches 0.7。

如果您正在运行较旧的 Celery 版本，则需要运行较旧的 celery-batches 版本。

• Celery < 4.0：请使用 celery.contrib.batches。

• Celery 4.0 - 4.3：celery-batches 0.3。

• Celery 4.4：celery-batches 0.7。

历史

Celery Batches 之前作为 Celery 的一部分分发（作为 celery.contrib.batches），直到 Celery 4.0。此项目更新了 Batches 代码以保持与 Celery 更新版本的兼容性以及其他修复。有关详细信息，请参阅变更日志。

此外，此存储库包括从 celery.contrib.batches 的完整代码历史，但已重写为 celery_batches/__init__.py 文件。