Ниже приведен код, который я использую в Jupyter Notebbok для сбора и анализа потоковых данных Twitter. Я получаю ошибку 401, хотя объект stream
создается после аутентификации. Учетные данные для аутентификации верны, и я использую tweepy
для авторизации. Есть идеи?
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)
print(auth)
<tweepy.auth.OAuthHandler object at 0x0000022B8450B288>
class MyStreamListener(tweepy.StreamListener):
def __init__(self, api=None):
super(MyStreamListener, self).__init__()
self.num_tweets = 0
self.file = open("tweets.txt", "w")
def on_status(self, status):
tweet = status._json
self.file.write( json.dumps(tweet) + '\n' )
self.num_tweets += 1
if self.num_tweets < 100:
return True
else:
return False
self.file.close()
def on_error(self, status):
print(status)
l = MyStreamListener()
print(l)
<__main__.MyStreamListener object at 0x0000022B844D9E48>
stream = tweepy.Stream(auth, l)
print(stream)
<tweepy.streaming.Stream object at 0x0000022B843A8188>
stream.filter(['clinton', 'trump', 'sanders', 'cruz'])
401