MongoDB
 sql >> डेटाबेस >  >> NoSQL >> 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'])

यह mongodb को ट्वीट लिखेगा test डेटाबेस, tweets संग्रह।

आशा है कि यह मदद करता है।



  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. अपने MongoDB संस्करण की जाँच करने के 7 तरीके

  2. $ और $ मैच के साथ mongodb . का उपयोग करना

  3. MongoDB में एकल फ़ील्ड में सरणी में स्ट्रिंग मानों को संयोजित करें

  4. कर्सर में जारी रखें। प्रत्येक के लिए ()

  5. नेस्टेड सरणियों को अद्यतन करने के लिए स्थितीय `$` ऑपरेटर का एकाधिक उपयोग