如何更新Tweepy Streaming Python代码

Question

我为早期版本的Python运行了此代码，但现在想将其升级到最新版本的Python和Tweepy，但我似乎无法使其工作。任何帮助都将不胜感激！我得到的错误是：

ImportError:无法从“tweepy.streaming”中导入名称“StreamListener”(C:\ Users \ mman enica \ anaconda 3 \ lib \ site-packages \ tweepy \ streaming . py)

import sys

from tweepy import OAuthHandler
from tweepy import API
from tweepy import Stream
from tweepy.streaming import StreamListener
import pandas as pd
from time import sleep
from random import randint

CONSUMER_KEY = ""
CONSUMER_SECRET = ""
ACCESS_TOKEN = ""
ACCESS_TOKEN_SECRET = ""

auth = OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET)
auth.set_access_token(ACCESS_TOKEN, ACCESS_TOKEN_SECRET)
api = API(auth, wait_on_rate_limit=True,
          wait_on_rate_limit_notify=True)

tweets = pd.DataFrame(columns=['description', 'location', 'text', 'name', 'user_created', 
                  'followers', 'user_id', 'created', 'retweets', 'analysis', 'sentiment'])

class Listener(StreamListener):
    def __init__(self, output_file=sys.stdout):
        super(Listener,self).__init__()
        self.output_file = output_file
        self.counter = 0
        self.limit = 3
    def on_status(self, status):
        try:
            name = status.user.screen_name  
            sleep(randint(100,190))
            print(name)
            api.create_friendship(name)            
            
            print(status.text, file=self.output_file)
                 
            self.counter += 1
            if self.counter <= self.limit:
                print(self.counter)
                return True
            else:
                print('Limit reached')
        except:
            print("Error in adding friendship")                   
        
    def on_error(self, status_code):
        print('Error ' + str(status_code))
        return False

listener = Listener()

stream = Stream(auth=api.auth, listener=listener)
try:

    stream.filter(track=['NFTs', 'Buying NFT', 'Buy NFT', '-filter:links', '-filter:retweets'])

    print('Start streaming.')
except KeyboardInterrupt:
    print("Stopped.")
finally:
    print('Done.')
    stream.disconnect()

Answer 1

首先，确保您已经安装了最新版本的Tweepy（4.5.0）。您可以通过在终端中键入pip安装--user--升级Tweepy来保证这一点。您可以在没有--user部分的情况下尝试它。它也应该升级。现在，安装了最新版本，您可以开始收集包含以下代码的流（基于https://docs.tweepy.org/en/stable/streaming.html）：

import tweepy 

class StreamCollector(tweepy.Stream):

    def on_data(self, data):
        print(data)


stream = StreamCollector(
  "Consumer Key here", "Consumer Secret here",
  "Access Token here", "Access Token Secret here"
)
stream.filter(track=["Obama"])

请注意，on_data方法直接从 Twitter 接收raw_data。我们只是用上面的代码打印它，但你可以像对待一个python字典一样对待这个数据对象，并提取你想要的关于推文的任何信息。

我建议，不要打印数据对象，而是像下面这样（导入 json 库并将其余代码放在 def on_data 中，而不是 print（data））：

import json

tweet_info = json.loads(data)
print(tweet_info['text'])

请注意，我们已经访问了< code>data对象，并且只提取了tweet的“文本”信息。你可以更深入地从< code>tweet_info字典中获取其他信息，也可以用问题中显示的必需品来补充上面的代码。

希望它有帮助。:)