Celery批量任务
项目描述
bulk-task
bulk-task包提供了一个批量调用延迟函数的简单方法。
安装
$ pip install bulk-task
示例
from dataclasses import dataclass
from bulk_task import BulkTask
bulk_task = BulkTask()
# It can be a dataclass or a Pydantic model.
@dataclass
class DataclassModel:
name: str
@bulk_task
def func(args: List[DataclassModel]):
print(arg.name for arg in args)
# Push lazy calls.
func.push('name1')
func.push('name2')
# Bulk consume lazy calls.
bulk_task.consume()
项目详情
下载文件
下载适合您平台的文件。如果您不确定选择哪个,请了解有关 安装包 的更多信息。
源分发
bulk_task-0.0.2.tar.gz (4.0 kB 查看哈希值)
构建分发
bulk_task-0.0.2-py3-none-any.whl (4.8 kB 查看哈希值)
关闭
bulk_task-0.0.2.tar.gz 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | ffd459b458b3010067e871f711a933204d5c0295c26695f5852f25806925c158 |
|
MD5 | d8ea3068b391d817cf57aaa98d3c64b2 |
|
BLAKE2b-256 | 0d109593990d6a7432b6d3f7d93cc9f04a3b37559c2b8b093c67671ef7eae1af |
关闭
bulk_task-0.0.2-py3-none-any.whl 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | 144afc62e159a61bb6148806c6ca5e555a2e20d94ccb1473d4d27b4e2c1ae408 |
|
MD5 | d91b86087b9ead8bee84344a718e6d23 |
|
BLAKE2b-256 | 0afdb2a60b864f60ca5de9f6e1d8a91945960e5fd0d8a5062e4a206e05b9acc7 |