MongoDB
 sql >> база данни >  >> NoSQL >> MongoDB

Как мога да използвам туитове от API за стрийминг на Twitter и да ги съхранявам в mongodb

Ето един пример:

import json
import pymongo
import tweepy

consumer_key = ""
consumer_secret = ""
access_key = ""
access_secret = ""

auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_key, access_secret)
api = tweepy.API(auth)


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=['Gandolfini'])

Това ще напише туитове в test на mongodb база данни, tweets колекция.

Надявам се това да помогне.



  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Как MongoDB избягва бъркотията с инжектиране на SQL?

  2. Moongoose агрегат $match не съвпада с идентификатори

  3. Инсталация на MongoDB

  4. Автоматизиране и управление на MongoDB в облака

  5. MongoDB $size