每 24 小时调用一次函数而不影响以下代码

Question

from threading import Timer    

def Add():
  ...Some process...
  Timer(86400, Add).start() ## 86400 secs in 24 hours.

if __name__ == '__main__':
  Add()

  "Consuming Kafka Messages and will run continously once started".

一旦代码运行，Add 函数就会被调用，程序开始使用 kafka 消息并持续等待。我想每 24 小时调用一次“添加”功能，而不会干扰 kafka 进程。为此，我尝试了一个 threading.timer，但我不确定它是否有效。

我还有一个问题 - 这个线程是每 24 小时初始化一次，还是只有一个线程每 24 小时调用一次。

请告知我做的是否正确，是否有效，在此先感谢！！

Answer 1

您可以简单地使用调用 add() 的额外函数并为您添加计时器，如下所示：

def task1():
    while True:
        add()
        time.sleep(86400)
if __name__ == "__main__":
    thread = Thread(target=task1)
    thread.start()
    # add kafka code

每 24 小时调用一次函数而不影响以下代码

Calling function after every 24hrs without affecting following code

timer

python-multithreading

python-3.x

apache-kafka