จัดการ job scheduling

สิ่งแรกจากการใช้งานตัว Rocketry นั้น คือ

• Code ที่อ่านง่าย
• Code สั้น กระชับ

ตัวอย่าง code ง่าย ๆ เป็นดังนี้

from rocketry import Rocketry
	app = Rocketry()
	@app.task('daily')
	def do_things():
	    ...
	if __name__ == "__main__":
	    app.run()

สิ่งที่ชอบคือ การกำหนด schedule ของแต่ละ function ว่าทำงานตอนไหน

ที่อ่านเข้าใจได้ง่าย ยกตัวอย่างเช่น

• every 10 seconds คือ ทำงานทุก ๆ 10 วินาที
• daily after 10:00 คือ ทำงานทุกวันหลัง 10 โมงเช้า
• (weekly on Monday | weekly on Saturday) & time of day after 10:00 ลองคิดดูว่า จะทำงานวันไหน เวลาอะไรบ้าง
• after task ‘do_first’ คือ ให้ทำการหลังจาก task/function ชื่อว่า do_first ซึ่งใช้ในการกำหนด pipeline ของการทำงานได้แบบง่าย ๆ

รวมทั้งยังสามารถทำงานได้หลากหลายมากขึ้น

แต่ยังคงความง่ายของ code ที่เขียนออกมา ยกตัวอย่างเช่น

• การทำงานแบบ concurrency
• การทำงานแบบ pipeline
• การจัดการ order ของการทำงานของ job ต่าง ๆ
• สามารถเก็บ log ลอง data store ต่าง ๆ ได้ ทั้ง SQL และ NoSQL

ตัวอย่างของการทำงานแยกออกจาก thread/process หลัก

@app.task("daily", execution="main")
	def do_on_main():
	    ...
	@app.task("daily", execution="thread")
	def do_on_thread():
	    ...
	@app.task("daily", execution="process")
	def do_on_process():
	    ...

เป็น project ที่นำมาใช้แล้ว ช่วยให้จัดการ job scheduling ได้สะดวกยิ่งขึ้น น่าสนใจมาก ๆ ลองทดลองใช้กันดูครับ

Rocketry