1

これまでのところ、動作してつぶやきを mongodb に挿入する次のコードがありますが、いくつか質問がありました。

class CustomStreamListener(tweepy.StreamListener):
def __init__(self, api):
    self.api = api
    super(tweepy.StreamListener, self).__init__()

    self.db = pymongo.MongoClient().test

def on_data(self, tweet):
    self.db.tweets.insert(json.loads(tweet))

def on_error(self, status_code):
    return True # Don't kill the stream

def on_timeout(self):
    return True # Don't kill the stream


sapi = tweepy.streaming.Stream(auth, CustomStreamListener(api))
sapi.filter(track=['arsenal'] , languages = ['en'])

  1. データベースに挿入されたツイートの特定の部分のみを取得する方法を誰かが説明できますか? ツイートのテキストと場所だけです。

  2. Twitter ストリーミング API では、@ リプライ ツイートを表示せずにツイートのみを表示できますか?

4

1 に答える 1

1

json.loads(tweet)は単なる でありdictionary、処理する Key-Value の部分を自由に選択できます。

次のいずれかの条件でツイートをフィルタリングできます。

tweet_obj = json.loads(tweet)
if not tweet_obj['in_reply_to_user_id']: # replies has `None` in this field
    pass                                 # add some processing here
于 2013-11-05T16:25:38.823 に答える