跳出循环并在python中重新启动脚本

2024-09-27 19:20:23 发布

您现在位置:Python中文网/ 问答频道 /正文

这是我的twitterbot脚本。它基于关键字进行搜索,并转发包含关键字的tweet。如果出现错误代码,我需要中断此循环并重新启动脚本:

    for row in retweeted_id:
        try:
            print(row)
            twitter.api.retweet(row)

            time.sleep(180)
        except tweepy.TweepError, e:
            if e == "[{u'message': u'You have already retweeted this tweet.', u'code': 327}]":
                print(e)
                break                    
            elif e == "[{u'message': u'Rate limit exceeded', u'code': 88}]":
                print(e)
                time.sleep(60*5)
            elif e == "[{u'message': u'User is over daily status update limit.', u'code': 185}]":
                 print(e)
                 break


            else:
                print(e)

我试过:

^{pr2}$

我也尝试过把整个脚本放在函数中,但我没有足够的经验在函数中编写类/函数。 在出现错误327的情况下,我想用在顶部重新启动脚本 非常感谢您的帮助!在

整个脚本如下:

import time
retweeted_id = []
tweet_text = []
tweet_text_id = []
from TwitterSearch import TwitterSearchOrder, TwitterUserOrder, TwitterSearchException, TwitterSearch

try:
    tso = TwitterSearchOrder() 
    tso.set_keywords([""]) 

    tso.set_language('nl')
    tso.set_include_entities(False) 
    tso.set_result_type('recent')

    ts = TwitterSearch(
        consumer_key = "aaaa",
        consumer_secret = "bbbb",
        access_token = "cccc",
        access_token_secret = "dddd"
                        )
    for retweeted in ts.search_tweets_iterable(tso):
        tweet_text_id.append({retweeted['id'], retweeted['user']['screen_name'] })
        retweeted_id.append(retweeted['id'])
    print('done')

    import tweepy
    class TwitterAPI:
        def __init__(self):
            consumer_key = "aaaa"
            consumer_secret = "bbbb"
            auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
            access_token = "cccc"
            access_token_secret = "dddd"
            auth.set_access_token(access_token, access_token_secret)
            self.api = tweepy.API(auth)

        def tweet(self, message):
            self.api.update_status(status=message)

    if __name__ == "__main__":
        twitter = TwitterAPI()

        for row in retweeted_id:
            try:
                print(row)
                twitter.api.retweet(row)

                time.sleep(180)
            except tweepy.TweepError, e:
                if e == "[{u'message': u'You have already retweeted this tweet.', u'code': 327}]":
                    print(e)
                    break                    
                elif e == "[{u'message': u'Rate limit exceeded', u'code': 88}]":
                    print(e)
                    time.sleep(60*5)
                elif e == "[{u'message': u'User is over daily status update limit.', u'code': 185}]":
                     print(e)
                     break

except TwitterSearchException as e:
    print(e)

Tags: 脚本tokenidmessagesecretaccesstimeconsumer
1条回答
网友
1楼 · 发布于 2024-09-27 19:20:23

如果我正确地理解了您想要什么,那么以这种方式重组可能是最简单的答案(最好是避免全局变量)。在

<imports>

<globals from init>

def init():
    <your init stuff>

class TwitterAPI:
    <...>

def twit():
    twitter = TwitterAPI()
    for row in retweeted_id:
        <rest of loop>

def main():
    init();
    while (True):
        try:
            twit();
        except TwitterSearchException as e:
            print(e)

if __name__ == "__main__":
    main();

相关问题 更多 >

    热门问题