【文件属性】:
文件名称:celery-dedupe:芹菜任务的重复数据删除
文件大小:8KB
文件格式:ZIP
更新时间:2021-05-10 14:25:29
python redis celery pluggable Python
芹菜
celery-dedupe是一个项目,旨在成为可插拔的解决方案,用于对排队的芹菜任务进行重复数据删除。 目前仅支持将redis作为存储后端。
用法
from celery . task import task
from celery_dedupe import DedupeTask
from celery_dedupe . storage . redis import RedisStorage
from redis import StrictRedis
redis = StrictRedis ()
storage = RedisStorage ( redis , expiry = 60 )
@ task ( base = DedupeTask , storage = storage )
def noop_task ( * a , ** kw ):
return None
注
【文件预览】:
celery-dedupe-master
----setup.py(740B)
----.gitignore(21B)
----.travis.yml(311B)
----LICENCE(1KB)
----README.md(2KB)
----tests()
--------test_storages.py(1KB)
--------__init__.py(0B)
--------settings.py(157B)
--------test_task.py(2KB)
----dev-requirements.txt(56B)
----celery_dedupe()
--------tasks.py(2KB)
--------__init__.py(30B)
--------storage()