Django模型中长时间运行的后台线程

Question

我对Python和Django相当陌生，所以请让我知道是否有更好的方法来做到这一点。我想做的是拥有每个设备（从模型继承。Model）启动一个长时间运行的后台线程，该线程不断检查该设备的运行状况。然而，当我运行代码时，它似乎不像守护进程那样执行，因为服务器缓慢且不断超时。这个后台线程将（在大多数情况下）运行程序的生命周期。

下面是我代码的简化版本：

class Device(models.Model):
    active = models.BooleanField(default=True)
    is_healthy = models.BooleanField(default=True)
    last_heartbeat = models.DateTimeField(null=True, blank=True)

    def __init__(self, *args, **kwargs):
        super(Device, self).__init__(*args, **kwargs)
        # start daemon thread that polls device's health
        thread = Thread(name='device_health_checker', target=self.health_checker())
        thread.daemon = True
        thread.start()


    def health_checker(self):
        while self.active:
            if self.last_heartbeat is not None:
                time_since_last_heartbeat = timezone.now() - self.last_heartbeat
                self.is_healthy = False if time_since_last_heartbeat.total_seconds() >= 60 else True
                self.save()
                time.sleep(10)

这似乎是线程的一个非常简单的用法，但每次我寻找解决方案时，建议的方法是使用芹菜，这对我来说似乎有些过分了。有没有一种方法可以让它在不需要芹菜之类的东西的情况下发挥作用？

Answer 1

当您在开发环境中开始时，设备的数量可能非常少。所以当你测试的时候，线程的数量可能是两位数。

但是，随着设备数量的增加，即使代码能够正常工作，这个线程问题也将很快变得无法解决。所以用芹菜配芹菜酱是更好的方法。

也要考虑到你是新的Django和Python，试图掌握上面的线程会增加更多的复杂度。最后用芹菜做这个会简单得多，也更整洁。

Answer 2

正如@knbk在评论中提到的，“每次查询设备时，都会为返回的每个设备创建一个新线程”。这是我最初忽略的事情。

然而，我能够使用作为Django应用程序启动的单个后台线程来解决我的问题。这是一种比添加第三方库（如芹菜）简单得多的方法。

class DeviceApp(AppConfig):
    name = 'device_app'

    def ready(self):
        # start daemon thread that polls device's health
        thread = Thread(name='device_health_checker', target=self.device_health_check)
        thread.daemon = True
        thread.start()

def device_health_check(self):
    while (true):
        for device in Device.objects.get_queryset():
            if device.last_heartbeat is not None:
                time_since_last_heartbeat = timezone.now() - device.last_heartbeat
                device.is_healthy = False if time_since_last_heartbeat.total_seconds() >= 60 else True
                device.save()
        time.sleep(10)