Databases
StackOverflow2013
Postsdbo
POHow to halt, kill, stop or close a PycURL request on a stream example given using Twitter Stream
 

Note that there are some explanatory texts on larger screens.

plurals
  1. POHow to halt, kill, stop or close a PycURL request on a stream example given using Twitter Stream
    primarykey
    data
    text
    <p>Im currently cURLing the twitter API stream (http://stream.twitter.com/1/statuses/sample.json), so am constantly receiving data. I wish to stop cURLing the stream once i have retrieved X number of objects from it (in the example I give 10 as an arbitrary number).</p> <p>You can see how I have attempted to close the connection in the code below. The code below curling.perform() never executes, due to the fact that it is a continuous stream of data. So I attempted to close the stream in the body_callback, however because perform() is currently running i can not invoke close().</p> <p>Any help would be appreciated.</p> <p>Code:</p> <pre><code># Imports import pycurl # Used for doing cURL request import base64 # Used to encode username and API Key import json # Used to break down the json objects # Settings to access stream and API userName = 'twitter_username' # My username password = 'twitter_password' # My API Key apiURL = 'http://stream.twitter.com/1/statuses/sample.json' # the twitter api tweets = [] # An array of Tweets # Methods to do with the tweets array def how_many_tweets(): print 'Collected: ',len(tweets) return len(tweets) class Tweet: def __init__(self): self.raw = '' self.id = '' self.content = '' def decode_json(self): return True def set_id(self): return True def set_content(self): return True def set_raw(self, data): self.raw = data # Class to print out the stream as it comes from the API class Stream: def __init__(self): self.tweetBeingRead ='' def body_callback(self, buf): # This gets whole Tweets, and adds them to an array called tweets if(buf.startswith('{"in_reply_to_status_id_str"')): # This is the start of a tweet # Added Tweet to Global Array Tweets print 'Added:' # Priniting output to console print self.tweetBeingRead # Printing output to console theTweetBeingProcessed = Tweet() # Create a new Tweet Object theTweetBeingProcessed.set_raw(self.tweetBeingRead) # Set its raw value to tweetBeingRead tweets.append(theTweetBeingProcessed) # Add it to the global array of tweets # Start processing a new tweet self.tweet = buf # Start a new tweet from scratch else: self.tweetBeingRead = self.tweetBeingRead+buf if(how_many_tweets()&gt;10): try: curling.close() # This is where the problem lays. I want to close the stream except Exception as CurlError: print ' Tried closing stream: ',CurlError # Used to initiate the cURLing of the Data Sift streams datastream = Stream() curling = pycurl.Curl() curling.setopt(curling.URL, apiURL) curling.setopt(curling.HTTPHEADER, ['Authorization: '+base64.b64encode(userName+":"+password)]) curling.setopt(curling.WRITEFUNCTION, datastream.body_callback) curling.perform() # This is cURLing starts print 'I cant reach here.' curling.close() # This never gets called. :( </code></pre>
    singulars
    1. PO
      singulars
      1. PTAnswer
    1. This table or related slice is empty.
    1. PTQuestion
    1. This table or related slice is empty.
    1. USjonhurlock
    plurals
    1. This table or related slice is empty.
    1. PL
      singulars
      1. LTLinked
    1. This table or related slice is empty.
    1. PO
      singulars
      1. PTAnswer
    1. VO
      singulars
      1. POHow to halt, kill, stop or close a PycURL request on a stream example given using Twitter Stream
      1. This table or related slice is empty.
      1. VTUpMod
    2. VO
      singulars
      1. POHow to halt, kill, stop or close a PycURL request on a stream example given using Twitter Stream
      1. USjonhurlock
      1. VTFavorite
    3. VO
      singulars
      1. POHow to halt, kill, stop or close a PycURL request on a stream example given using Twitter Stream
      1. This table or related slice is empty.
      1. VTUpMod
    1. This table or related slice is empty.
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload