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

定时器- kombu.asynchronous.timer

计时器调度Python回调。

class kombu.asynchronous.timer.Entry(fun, args=None, kwargs=None)

时间表条目。

args

cancel()

canceled

property cancelled

fun

kwargs

tref

class kombu.asynchronous.timer.Timer(max_interval=None, on_error=None, **kwargs)

异步计时器实现。

class Entry(fun, args=None, kwargs=None)

时间表条目。

args

cancel()

canceled

property cancelled

fun

kwargs

tref

apply_entry(entry)

call_after(secs, fun, args=(), kwargs=None, priority=0)

call_at(eta, fun, args=(), kwargs=None, priority=0)

call_repeatedly(secs, fun, args=(), kwargs=None, priority=0)

cancel(tref)

clear()

enter_after(secs, entry, priority=0, time=<built-in function monotonic>)

enter_at(entry, eta=None, priority=0, time=<built-in function monotonic>)

在调度器中输入函数。

论点：

Entry(~kombu.aschronous.timer.Entry)：要输入的项。Eta(Datetime.DateTime)：预定时间。优先级(Int)：未使用。

handle_error(exc_info)

on_error = None

property queue

底层数据结构的快照。

property schedule

stop()

kombu.asynchronous.timer.to_timestamp(d, default_timezone=zoneinfo.ZoneInfo(key='UTC'), time=<built-in function monotonic>)

将日期时间转换为时间戳。

如果d‘已经是时间戳，则将使用该时间戳。