在 Python 中使用 Twitter 流 API

Question

提前谢谢你！我删除了我的 OAuth 信息，并且此代码适用于 Twitter API 的非流组件。我知道想要一个连续的会话，但我没有这样做。如何创建一个？我正在使用 Python 3.3.2，并且不希望使用像 tweepy 这样的库。

import requests
import json
import time
from requests_oauthlib import OAuth1Session

twitter = OAuth1Session('',client_secret='',resource_owner_key='',resource_owner_secret='')


url = 'https://userstream.twitter.com/1.1/user.json'
r = twitter.get(url)
data = json.loads(r.text)
print(data)

Answer 1

正如您在the OAuth1Session sourcecode 中看到的，该类继承自requests.Session。

您可以使用twitter.get(url, stream=True)，如the official requests streaming example 中所述。

twitter.get(...) 的返回值随后会公开一个生成器接口，因此您可以遍历这些行。但是请注意，您必须手动分离流中的 JSON 记录，并将它们一一传递给 json.loads()。