python - Python,使用线程和调度来不断运行一个函数
问题描述
我正在制作一个使用 自动发布到 Instagram 的机器人instabot
,现在的问题是,如果我超过请求的数量,机器人会在重试几分钟后终止脚本。
我想出的解决方案是安排脚本每隔一小时左右运行一次,并确保脚本持续运行,我使用线程在线程死亡时重新启动发布功能。
负责发布的函数,在此代码中,如果机器人实例instabot
重试发送请求几分钟但失败,它将终止整个脚本。
def main():
create_db()
try:
os.mkdir("images")
print("[INFO] Images Directory Created")
except:
print("[INFO] Images Directory Found")
# GET A SUBMISSION FROM HOT
submissions = list(reddit.subreddit('memes').hot(limit=100))
for sub in submissions:
print("*"*68)
url = sub.url
print(f'[INFO] URL : {url}')
if "jpg" in url or "png" in url:
if not sub.stickied:
print("[INFO] Valid Post")
if check_if_exist(sub.id) is None:
id_ = sub.id
name = sub.title
link = sub.url
status = "FALSE"
print(f"""
[INFO] ID = {id_}
[INFO] NAME = {name}
[INFO] LINK = {link}
[INFO] STATUS = {status}
""")
# SAVE THE SUBMISSION TO THE DATABASE
insert_db(id_, name, link, status)
post_instagram(id_)
print(f"[INFO] Picture Uploaded, Next Upload is Scheduled in 60 min")
break
time.sleep(5 * 60)
调度功能:
def func_start():
schedule.every(1).hour.do(main)
while True:
schedule.run_pending()
time.sleep(10 * 60)
最后一段代码:
if __name__ == '__main__':
t = threading.Thread(target=func_start)
while True:
if not t.is_alive():
t.start()
else:
pass
所以基本上我想每隔一小时左右继续运行主要功能,但我没有任何成功。
解决方案
在我看来,对于您的用例来说schedule
,这看起来threading
有点过头了,因为您的脚本只执行一项任务,因此您不需要并发并且可以在主线程中运行整个事情。您主要只需要从main
函数中捕获异常。我会用这样的东西:
if __name__ == '__main__':
while True:
try:
main()
except Exception as e:
# will handle exceptions from `main` so they do not
# terminate the script
# note that it would be better to only catch the exact
# exception you know you want to ignore (rather than
# the very broad `Exception`), and let other ones
# terminate the script
print("Exception:", e)
finally:
# will sleep 10 minutes regardless whether the last
# `main` run succeeded or not, then continue running
# the infinite loop
time.sleep(10 * 60)
...除非您实际上希望每次main
运行以60 分钟的间隔精确开始,在这种情况下,您可能需要threading
或schedule
. 因为,如果运行main
需要 3 到 5 分钟,那么在每次执行后简单地休眠 60 分钟意味着您将每 63 到 65 分钟启动一次函数。
推荐阅读
- reactjs - 授权应用程序调用 API Azure AD 时出现 CORS 错误?
- javascript - 您能否制作一种根据字符串输入更改不同变量的方法
- powershell - 如何从 Ansible 管理 var value off Powershell 中的目录
- python - 如何为多列熊猫应用函数?
- python-3.x - 从随机列表中找到最大或最小的数字
- android-studio - Android Studio 是否支持 Windows 7 32 位?C:\Users\Admin\AppData\Local\Android\Sdk 中缺少 SDK 文件夹
- c++ - 如何从 C++/WinRT 库中导出数据、函数、类
- installation - 不在 root 上时出现 Brew 错误“不要在 root 上运行此程序”
- python - 有没有办法将字符串字符添加到句点列中的值?
- php - 为什么数据库无法获取 post 方法发送的数据?