Tweepy StreamListener to CSV

Question

私はpythonの初心者です。TweepyとStreaming APIを使ってTwitterからデータを取得し、CSVファイルに変換するアプリケーションを開発しようとしています。 問題は、このコードが出力CSVファイルを作成しないことです。たとえば、コードが停止するように設定する必要があります。 1000件のつぶやきが、私はこの停止点に

を設定することはできないんだけど、ここでコード

import sys 
import tweepy 
import csv 

#pass security information to variables 
consumer_key="" 
consumer_secret="" 
access_key = "" 
access_secret = "" 


#use variables to access twitter 
auth = tweepy.OAuthHandler(consumer_key, consumer_secret) 
auth.set_access_token(access_key, access_secret) 
api = tweepy.API(auth) 

#create an object called 'customStreamListener' 

class CustomStreamListener(tweepy.StreamListener): 

    def on_status(self, status): 
     print (status.author.screen_name, status.created_at, status.text) 


    def on_error(self, status_code): 
     print >> sys.stderr, 'Encountered error with status code:', status_code 
     return True # Don't kill the stream 

    def on_timeout(self): 
     print >> sys.stderr, 'Timeout...' 
     return True # Don't kill the stream 


streamingAPI = tweepy.streaming.Stream(auth, CustomStreamListener()) 
streamingAPI.filter(track=['Dallas', 'NewYork']) 

def on_status(self, status): 
    with open('OutputStreaming.txt', 'w') as f: 
     f.write('Author,Date,Text') 
     writer = csv.writer(f) 
     writer.writerow([status.author.screen_name, status.created_at, status.text]) 

は、任意の提案ですか？

Answer 1

csvを書き込もうとしている関数が呼び出されることはありません。 このコードをCustomStreamListener.on_statusに書き込むと仮定します。 また、（ストリームリスナーの外で）一度ファイルにタイトルを書き込む必要があります。 このコードを見てみましょう：

import sys 
import tweepy 
import csv 

#pass security information to variables 
consumer_key="" 
consumer_secret="" 
access_key = "" 
access_secret = "" 


#use variables to access twitter 
auth = tweepy.OAuthHandler(consumer_key, consumer_secret) 
auth.set_access_token(access_key, access_secret) 
api = tweepy.API(auth) 

#create an object called 'customStreamListener' 

class CustomStreamListener(tweepy.StreamListener): 

    def on_status(self, status): 
     print (status.author.screen_name, status.created_at, status.text) 
     # Writing status data 
     with open('OutputStreaming.txt', 'w') as f: 
      writer = csv.writer(f) 
      writer.writerow([status.author.screen_name, status.created_at, status.text]) 


    def on_error(self, status_code): 
     print >> sys.stderr, 'Encountered error with status code:', status_code 
     return True # Don't kill the stream 

    def on_timeout(self): 
     print >> sys.stderr, 'Timeout...' 
     return True # Don't kill the stream 

# Writing csv titles 
with open('OutputStreaming.txt', 'w') as f: 
      writer = csv.writer(f) 
      writer.writerow(['Author', 'Date', 'Text']) 

streamingAPI = tweepy.streaming.Stream(auth, CustomStreamListener()) 
streamingAPI.filter(track=['Dallas', 'NewYork'])