This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.

消费者日程安排- kombu.utils.scheduling

计划实用程序。

class kombu.utils.scheduling.FairCycle(fun, resources, predicate=<class 'Exception'>)

在资源之间循环。

从一组资源中消费，其中每个资源都有平等的机会被消费。

论点：

Fun(可回调)：回调以进行调用。资源(顺序 [Any] )：资源清单。谓词(类型)：异常谓词。

close()

关闭循环。

get(callback, **kwargs)

从下一个资源中获取。

class kombu.utils.scheduling.priority_cycle(it=None)

按顺序重复项目的循环。

rotate(last_used)

在此实现中未使用。

class kombu.utils.scheduling.round_robin_cycle(it=None)

循环中在项之间循环的迭代器。

consume(n)

消费n个项目。

rotate(last_used)

将最近使用过的项目移至列表末尾。

update(it)

从Iterable更新项。

class kombu.utils.scheduling.sorted_cycle(it=None)

按排序顺序循环。

consume(n)

消费n个项目。