定时任务
定时任务是Nameko中提供的一个很简单的Entrypoint
,可以根据一个固定的秒数间隔运行被修饰的方法。以下是一个定时任务的示例。
from nameko.events import EventDispatcher
from nameko.timer import timer
class TimedService:
name = 'timed_service'
dispatcher = EventDispatcher()
@timer(interval=30)
def ping(self):
self.dispatcher.dispatch('heart_beat', self.name)