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小时调用一次。
请建议我做正确的,它会工作或不提前感谢!!
1条答案
按热度按时间3vpjnl9f1#
您只需使用一个额外的函数
add()
为您添加计时器,如下所示: