尝试使用twitter API Python流式传输数据库中的推文

import tweepy
import json
import pymongo

# Twitter API密钥和令牌
consumer_key = "YOUR_CONSUMER_KEY"
consumer_secret = "YOUR_CONSUMER_SECRET"
access_token = "YOUR_ACCESS_TOKEN"
access_token_secret = "YOUR_ACCESS_TOKEN_SECRET"

# 连接MongoDB数据库
client = pymongo.MongoClient("mongodb://localhost:27017/")
db = client["twitter_db"]
collection = db["tweets"]

# 自定义StreamListener类，用于处理推文流
class MyStreamListener(tweepy.StreamListener):
    def on_status(self, status):
        # 处理推文
        tweet = status._json
        collection.insert_one(tweet)
        print("Tweet saved to database.")

    def on_error(self, status_code):
        if status_code == 420:
            # 返回False表示停止流
            return False

# 认证并创建StreamListener对象
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)
stream_listener = MyStreamListener()

# 创建Stream对象并过滤推文关键词
stream = tweepy.Stream(auth=auth, listener=stream_listener)
stream.filter(track=["keyword1", "keyword2"])

# 关闭数据库连接
client.close()