Python金字塔周期任务

Question

我的问题是关于如何在 Pyramid Python 框架中执行一个简单的任务？

我有一个 table 用户生日，我想每天检查某人的生日是否即将到来，如果是，打印一个简单的问候语。

所以我在 views.py:

中定义了一些东西

def print_greetings():
   tomorrow = datetime.date.today()+datetime.timedelta(days=1)
    users = sess.query(User).filter(func.DATE_FORMAT(User.bday, "%d_%m")==tomorrow.strftime("%d_%m")).all()
    if len(users) > 0:
        for u in users:
            print("Happy Birthday", u.name)

所以问题是：我应该如何以及在哪里写一些东西来每天执行一次这个函数？

UPD：我需要运行来自 Pyramid 应用程序的任务，像 cron 这样的外部工具不是我要找的东西。

也许某种计时器会执行 print_greetings()？执行后会启动一个新的定时器实例吗？

Answer 1

如需 python 解决方案，请查看 Celery Beat。

对于更简单的事情，您可以只创建一个带有时间表 0 0 * * * 的 cron job。这将导致您的脚本在每天午夜运行。

Answer 2

虽然 Celery 是解决此类任务的 "heavy-weight" 解决方案，但我建议使用 APScheduler。您可以像在 cron 中一样设置调度程序，但它会运行在您的应用程序中。在这种情况下，内存中的作业存储工作正常。

import atexit
from apscheduler.schedulers.background import BackgroundScheduler

scheduler = BackgroundScheduler()
scheduler.start()
scheduler.add_job(print_greetings,
    id='greetings', 
    name='Send out birthday greetings', 
    trigger='cron', 
    minute=0, 
    hour=12,
)

atexit.register(lambda: scheduler.shutdown())

Answer 3

您可以创建一个脚本，将您的 Pyramid 功能包装为框架的一部分 (http://docs.pylonsproject.org/projects/pyramid/en/latest/narr/commandline.html#writing-a-script)；这将允许您拥有一个独立的功能，该功能仍然能够访问您的金字塔螺母和螺栓。但是根据您的更新，它仍然是一个独立的脚本，需要通过某种任务调度程序进行调度。

除非我遗漏了一些东西，否则 Pyramid 不会 "always running" 到你可以有一个计时器或排序的地步......你有一个服务器提供由 Pyramid 处理的请求。我想你可以做一些事情，比如有一个金字塔响应，你击中那些会触发计时器或其他东西然后无限地运行s 但这似乎是一种糟糕的处理方式。即使是上面的脚本想法 - 你可以执行一次并启动一个计时器并无限期地运行，但是你会得到一个不断运行的过程。

一个更好的解决方案是按照建议将当前日期的生日写到 table 中，然后在您的视图中查询 table 以供显示。

Python金字塔周期任务

Python Pyramid periodic task

python

scheduled-tasks

pyramid