Tweepy StreamListener zu CSV

Question

Ich bin ein Neuling auf Python und ich versuche, eine App zu entwickeln, die Daten von Twitter mit Tweepy und den Streaming-APIs abruft und die Daten in eine CSV-Datei konvertiert. Das Problem ist, dass dieser Code keine Ausgabe CSV-Datei erstellt, vielleicht weil ich den Code einstellen sollte, um zu stoppen, wenn es für zB erreicht. 1000 Tweets, aber ich bin mit diesen Haltepunkt nicht in der Lage

einstellen

hier ist der Code

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]) 

Jeder Vorschlag?

Answer 1

Die Funktion, die Sie versuchen, die csv mit zu schreiben, wird nie aufgerufen. Ich nehme an, dass Sie diesen Code in CustomStreamListener.on_status schreiben wollten. Außerdem müssen Sie die Titel einmal in die Datei schreiben (außerhalb des Stream-Listeners). Werfen Sie einen Blick auf diesen Code:

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'])