我正在制作一个使用instabot
自动发布到Instagram的机器人,现在的问题是,如果我超过了请求次数,机器人会在重试几分钟后终止脚本。
我想出的解决方案是将脚本安排为每小时左右运行一次,并确保脚本持续运行。我使用线程在线程失效时重新启动发布功能。
负责发布的函数,在本代码中,如果来自instabot
的bot实例在几分钟内重试发送请求并失败,它将终止整个脚本。
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分钟就会启动一次函数。