使用全文本在MongoDB中进行Tweepy流传输

Question

我需要与Tweepy和MongoDB库一起开发Python代码的帮助。我无法流式传输带有全文的推文。我不知道如何为此目的实现此代码。

请查看此代码：

keywords = ['trump']

language = ['en']

analyzer = SentimentIntensityAnalyzer()

class StdOutListener(StreamListener):


    def on_status(self, status):
        if hasattr(self, status):
            try:
                tweet = status.retweted_status.extended_tweet["full_text"]
            except:
                tweet = status.retweeted_status.text
        else:
            try:
                tweet = status.extended_tweet["full_text"]
            except AttributeError:
                tweet = status.text



    def on_data(self, data):

        t = json.loads(data)

        tweet_id = t['id_str']  
        username = t['user']['screen_name']  
        followers = t['user']['followers_count']  


        tweet = unidecode(t['text'])
        text = t['full_text']            
        hashtags = t['entities']['hashtags']  
        dt = t['created_at']  
        language = t['lang']  


        blob = analyzer.polarity_scores(tweet)
        sentiment = blob['compound']


        created = datetime.datetime.strptime(dt, '%a %b %d %H:%M:%S +0000 %Y')

        tweet = {'id':tweet_id, 'username':username, 'followers':followers, 'text':text, 'hashtags':hashtags, 'language':language, 'created':created, 'sentiment':sentiment}

        print (username + ':' + ' ' + text)
        return True

    def on_error(self, status_code):
        if status_code == 420:
            print (status)
            return False


if __name__ == '__main__':
    l = StdOutListener()
    auth = OAuthHandler(consumer_key, consumer_secret)
    auth.set_access_token(access_token, access_token_secret)

    stream = Stream(auth, l, tweet_mode="extended")



    tweets = stream.filter(track=keywords, languages=language )

我试图用一种不好的方式来做。例如，我用full_text替换了文本，但它不起作用。我希望你能帮帮我..谢谢您的时间！

Answer 1

[if hasattr(self, status):将引发一个TypeError，因为hasattr要求输入属性名称的字符串。

您应该参考hasattr，它的Tweepy's documentation on extended Tweets与我认为您要尝试的非常相似。