python3.x—在不影响以下代码的情况下,每24小时调用一次函数

disbfnqx  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(412)
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小时调用一次“add”函数,而不干扰kafka进程。为此,我尝试了一个线程。计时器,但我不确定它是否会工作。
我还有一个问题-这个线程是每24小时初始化一次,还是只有一个线程每24小时调用一次。
请建议我做正确的,它会工作或不提前感谢!!

3vpjnl9f

3vpjnl9f1#

您只需使用一个额外的函数 add() 为您添加计时器,如下所示:

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

相关问题