如何将流推文保存在 json 文件中

Question

我想分析推文，并且我直接流式传输推文...我想流式传输并保存 json 格式的推文。

如何在通过 twitter api 流式传输推文期间以 json 格式保存，我编写并获取流式推文，但我在流式传输时没有保存 json 文件。

class TwitteStreamer():

   def stream_tweet(self,hashtag_list):

      stream = tweepy.Stream(
      twitter_key.consumer_key, twitter_key.consumer_secret,
      twitter_key.access_token, twitter_key.access_token_secret
      )

    stream.filter(track=hashtag_list, languages=["en"])

这是自定义监听器

class TweetPrinter(tweepy.Stream):

   file = open('tweets.json', 'a')


   def on_status(self, status):
     print(status.text)
    
   def on_data(self,tweet):
     json_data = json.loads(data)
     file.write(str(json_data))
    
   def on_error(self, status_code):
     print(status_code)
     time.sleep(120)
     return False # To continue listening

   def on_timeout(self):
     time.sleep(120)
     return True # To continue listening



class Printer():

   def print_tweets(self, hashtag_list):

     printer = TweetPrinter(
      twitter_key.consumer_key, twitter_key.consumer_secret,
      twitter_key.access_token, twitter_key.access_token_secret
     )
     #printer.filter(track=hashtag_list)
     printer.filter(track=hashtag_list ,languages=["en"])



hashtag_list = ["btc","bitcoin","Bitcoin","#btc","#Bitcoin","BTC","#BTC"]

fetched_tweets_filename = "tweets.json"

twitter_streamer = TwitteStreamer()
twitter_streamer.stream_tweet(hashtag_list)

printer = Printer()
printer.print_tweets(hashtag_list)