HJA*_*A24 3 python twitter streaming tweepy
我想收集包含以下词语的所有推文: 比特币、以太坊、莱特币或 Denarius
但是,我想排除可以归类为转推和包含链接的推文的推文。我从以下网站(https://www.followthehashtag.com/help/hidden-twitter-search-operators-extra-power-followthehashtag)知道我可以添加-filter:links以排除包含链接的推文。通过比较以下搜索词可以清楚地看到这一点;
https://twitter.com/search?f=tweets&vertical=news&q=Bitcoin&src=typd
与https://twitter.com/search?f=tweets&q=Bitcoin%20-filter%3Alinks&src=typd
这同样适用于转推,我可以使用-filter:retweets(参见https://twitter.com/search?f=tweets&q=Bitcoin%20-filter%3Aretweets&src=typd)
我想添加这些标准以确保我减少“噪音”并且不太可能违反任何 API 限制。我编写了以下 Python 脚本:
import sys
import time
import json
import pandas as pd
from tweepy import OAuthHandler
from tweepy import Stream
from tweepy.streaming import StreamListener
USER_KEY = ''
USER_SECRET = ''
ACCESS_TOKEN = ''
ACCESS_SECRET = ''
crypto_tickers = ['bitcoin', 'ethereum', 'litecoin', 'denarius', '-filter:links', '-filter:retweets']
class StdOutListener(StreamListener):
def on_data(self, data):
tweet = json.loads(data)
print(tweet)
def on_error(self, status):
if status == 420:
sys.stderr.write('Enhance Your Calm; The App Is Being Rate Limited For Making Too Many Requests')
return True
else:
sys.stderr.write('Error {}n'.format(status))
return True
if __name__ == "__main__":
listener = StdOutListener()
auth = OAuthHandler(USER_KEY, USER_SECRET)
auth.set_access_token(ACCESS_TOKEN, ACCESS_SECRET)
stream = Stream(auth, listener)
stream.filter(languages=['en'], track=crypto_tickers)
Run Code Online (Sandbox Code Playgroud)
问题 1:如何在脚本中正确包含搜索条件并获得正确的输出?
Q2:根据官方文档,Streaming API 最多允许 400 个轨道关键字(https://developer.twitter.com/en/docs/tweets/filter-realtime/overview/statuses-filter.html)。我的两个过滤条件是否归类为 2 个跟踪关键字?
提前致谢,
| 归档时间: |
|
| 查看次数: |
7598 次 |
| 最近记录: |