Tweepy:如何将数据从def on_data传递到另一个线程？

import tweepy
import threading

# 创建一个自定义的StreamListener类，继承自tweepy.StreamListener
class MyStreamListener(tweepy.StreamListener):
    def on_data(self, data):
        # 在这里处理接收到的数据
        # 可以将数据传递到另一个线程进行处理

        # 创建一个新的线程，将数据传递给该线程进行处理
        data_thread = threading.Thread(target=self.process_data, args=(data,))
        data_thread.start()

    def process_data(self, data):
        # 在这里处理数据的逻辑
        # 可以将数据存储到数据库、进行分析等操作
        print(data)

# 创建一个认证对象
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)

# 创建一个API对象
api = tweepy.API(auth)

# 创建一个Stream对象
my_listener = MyStreamListener()
my_stream = tweepy.Stream(auth=api.auth, listener=my_listener)

# 过滤包含特定关键词的推文
my_stream.filter(track=['keyword1', 'keyword2'])