用于监控设备的 Python 脚本

Question

我被困在一个领域。我在 MySQL 数据库中设置了不同轮询间隔的设备很少。例如，我总共有 4 台设备，其中 2 台用户希望每 5 分钟轮询一次，另外两台每 10 分钟轮询一次，并且应该每 7 分钟轮询一次。

我想在 python 中构建一个解决方案，从数据库中选择这些设备及其轮询间隔，然后开始在它们定义的轮询间隔内连续轮询这些设备。

因为我无法创建多个轮询脚本（每个脚本一个），因为它会过度使用 CPU 资源。如果设备数量达到 1000 台，那么一次轮询所有 1000 台设备将是一个问题。它更像是一个持续运行和监控设备的监控解决方案。

我真的被困在这一点上。我会感谢你在这方面的帮助。

Answer 1

为每个间隔生成一个工作人员将完成这项工作。相同的代码看起来有点像这样：

from time import sleep
from multiprocessing import Process

intervals = [1, 2, 3] # hardcoding it to check, fetching it from db would be better

def generate_poll_worker(interval):
    def poll_devices():
        while True:
            # fetch the devices and poll them
            sleep(interval * 60)

    return poll_devices

def worker_process(interval):
    poll = generate_poll_worker(interval)
    poll()

workers = []

for interval in intervals:
    worker = Process(target=worker_process, args=(interval,))
    worker.start()
    workers.append(worker)

for worker in workers:
    worker.join()