定时任务

定时任务是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)