0 
from tweepy import Stream
from tweepy import OAuthHandler
from tweepy.streaming import StreamListener
import json 
from pprint import pprint

data_file = open('twitter.json')  
data = json.load(data_file)
##Json file with all the ckey, csecret, atoken, and asecret
pprint(data)

#consumer key, consumer secret, access token, access secret.
ckey = data["ckey"]
csecret = data["csecret"]
atoken = data["atoken"]
asecret = data["asecret"]

class listener(StreamListener):

def on_data(self, data):
    all_data = json.loads(data)       
    tweet = all_data["text"]        
    username = all_data["user"]["screen_name"]
    print((username,tweet))
    return True

def on_error(self, status):
    print (status)


auth = OAuthHandler(ckey, csecret)
auth.set_access_token(atoken, asecret)

上記のコードはすべて、Twitter API にアクセスする際の標準です。ただし、twitter から取得したツイートを .txt ファイルに転送する必要があります。以下のコードを使用してみました twitterStream = Stream(auth, listener())

fid = open("cats based tweets.txt","w")
for tweet in twitterStream.filter(track=[cats]):
        fid.write(tweet)
    fid.close()

キーワード「cats」を含むすべての Twitter ツイート/再投稿を検索するつもりです。ただし、すべてのツイートを含む txt ファイルも書き込むことになっていますが、そうではありません。誰でも私がそれを修正する必要があることを教えてもらえますか.

編集:皆さんが書いたコードを使用しましたが、すべてのツイートが返されるわけではありません。5または6のように出力され、エラーが表示されます

RuntimeError: No active exception to reraise

が表示されますが、その理由はわかりません。なぜこれが発生するのでしょうか。

4

3 に答える 3

1

私はプロジェクトでこれを行いましたが、私の方法にはオブジェクトon_data内の方法の変更が含まれStreamListenerます。私のコードは次のようになります。

class Listener(StreamListener):
    def __init__(self, api=None, path=None):
        #I don't remember exactly why I defined this.
        self.api = api
        #We'll need this later.
        self.path = path

    def on_data(self, data):
        all_data = json.loads(data)

        tweet = all_data["text"]        
        username = all_data["user"]["screen_name"]
        print((username,tweet))

        #Open, write and close your file.
        savefile = open(file_path, 'ab')
        savefile.write(tweet)
        savefile.close()

        return True

Listenerまたはを再定義した場所ではなく、実際のコードのいくつかのことon_data。順番に：

  1. 保存するファイルを定義します。その変数をfile_path. ここに.txt拡張子を追加することを忘れないでください。

  2. Stream と Listener を呼び出します。

    twitterStream = Stream(authorization, Listener(path=file_path))

  3. フィルターを使用します。私のコードは座標であり、コードが停止しないことを除いて、フィルターを試してみました。ここでは、あなたに合わせて調整されています：

    try:
    twitterStream.filter(track=[cats])
except Exception, e:
    print 'Failed filter() with this error:', str(e)

これで、ストリームにテキストが表示されるたびに、ツイート内のテキストがファイルに書き込まれます。ファイル サイズを確認すると、ファイル サイズが大きくなっていることがわかります。特に、フィルターが猫に関するものである場合。インターネットは猫が大好きです。

于 2015-04-17T17:13:46.083 に答える
0

以下のリンクを参照すると、ツイートをデータベースとローカル ファイルに保存する方法がわかります。

https://github.com/anandstarz/Scrapee/blob/master/tweets

于 2015-04-13T05:03:25.513 に答える