2

因此，我按照此处找到的问题的答案中的建议创建了一个类似 cron 的调度程序：

如何在 Python 中获得类似 Cron 的调度程序？

但有时，如果发生事件，我想删除另一个事件....

我将如何创建此功能？....基本上，一旦创建，我怎么能删除一个事件？

另外....我在从事件中制作事件时遇到了麻烦。基本上，我的目标是每小时使用一个事件来解析一个文件，其中包含我想做其他事件的时间......所以我想从这个每小时事件中创建新事件...... .但它们似乎在创建后消失了....

谢谢！

4

1 回答 1

0

这一切都取决于您如何实际实现您的 cronjob 运行。但是，如果您希望事件能够修改其他事件，我可以想到 3 个选项：

1.将cron的引用传递给函数

您的 CronTab 类必须为事件提供一种能够“检查”它的方法。最好的选择是使用“cron”参数扩展关键字参数并将其传递给函数，如下所示：

class CronTab(object):
    def __init__(self, *events):
        self.events = events
        for event in self.events:
             event.kwargs['cron'] = self
# rest of the calss remains unmodified

这样做，从运行的 Crontab 调用的所有函数都将传递一个“cron”参数，其中包含对运行它的 cron 的引用

2.添加“预运行”元帅

您扩展您的 CronTab 类不仅可以执行特定时间表上的事件，还可以在这些事件之前调用其他函数。获取事件实例并且必须返回True才能运行的函数。如果其中任何一个返回其他内容，则相关事件将不会运行。

一个基本的（未经测试的）实现将是：

class CronTab(object):
    def __init__(self, *events, marshalls=None):
        self.events = events
        if marshalls is not None:
            # marshalls must be a list of callables that return True or False
            self.marshalls = marshalls
        else
            self.marshalls = []

    def run(self):
        t=datetime(*datetime.now().timetuple()[:5])
        while 1:
            for e in self.events:
                if all([x(e) for x in self.marshalls]):
                    e.check(t)

            t += timedelta(minutes=1)
            while datetime.now() < t:
                time.sleep((t - datetime.now()).seconds)

显然有更好的方法来实现这一点。例如，通过执行一项reduce操作，从而避免在其中一个事件已经返回 False 之后为所有事件运行所有编组。但这应该为您指明正确的方向。

如果 CronTab 类实际上做了比调用事件实例更多的工作，check或者至少将运行检查与实际运行事件分离，那么实现这一点也可能更容易——但我不想修改原始代码那么多。

3. 提供事件挂钩

这与之前的解决方案基本相同，但更加“细粒度”。您将拥有多个列表，而不是只有一个预运行编组列表。您可以根据自己的需要定制确切的数量和详细信息，但我会根据您的要求来考虑。

除了一般的“运行前编组”之外，您还可以为每个事件名称创建一个这样的列表。在运行事件之前，您不仅要运行所有一般的“运行前编组”，还要运行特定于该事件的那些。

实现它的一种方法是将“预运行编组”列表制作成列表字典，并提供一些方法来管理此类列表。像这样的东西：

class CronTab(object):
    def __init__(self, *events, marshalls=None):
        self.events = events
        self.marshalls = dict()
        if marshalls is not None:
            # marshalls must be a list of callables that return True or False
            self.marshalls['__general'] = marshalls
        else
            self.marshalls['__general'] = []

    # event is a string with the name of the event you want to marshall
    # or None if you want to marshall all of them 
    def register(self, callback, event=None):
        if event = None:
            self.marshalls['__general'].append(callback)
        else:
            self.marshalls.setdefault(event, list()).append(callback)

    def run(self):
        t=datetime(*datetime.now().timetuple()[:5])
        while 1:
            for e in self.events:
                if all([x(e) for x in self.marshalls['__general']]) and
                   all([x(e) for x in self.marshalls[e.name]]):
                    # the above assumes e.name exists (not in reference implementation)
                    e.check(t)

        t += timedelta(minutes=1)
        while datetime.now() < t:
            time.sleep((t - datetime.now()).seconds)

以同样的方式，您可以添加运行后挂钩和其他您认为合适的奇怪东西。

关于您关于事件消失的问题，请向我们展示一些代码以便能够进一步解决问题。

于 2012-07-21T04:02:03.710 回答