89 lines
2.8 KiB
Python
89 lines
2.8 KiB
Python
# -*- coding: utf-8 -*-
|
|
|
|
"""
|
|
twython.streaming.types
|
|
~~~~~~~~~~~~~~~~~~~~~~~
|
|
|
|
This module contains classes and methods for :class:`TwythonStreamer` to use.
|
|
"""
|
|
|
|
|
|
class TwythonStreamerTypes(object):
|
|
"""Class for different stream endpoints
|
|
|
|
Not all streaming endpoints have nested endpoints.
|
|
User Streams and Site Streams are single streams with no nested endpoints
|
|
Status Streams include filter, sample and firehose endpoints
|
|
|
|
"""
|
|
def __init__(self, streamer):
|
|
self.streamer = streamer
|
|
self.statuses = TwythonStreamerTypesStatuses(streamer)
|
|
|
|
def user(self, **params):
|
|
"""Stream user
|
|
|
|
Accepted params found at:
|
|
https://dev.twitter.com/docs/api/1.1/get/user
|
|
"""
|
|
url = 'https://userstream.twitter.com/%s/user.json' \
|
|
% self.streamer.api_version
|
|
return self.streamer._request(url, params=params)
|
|
|
|
def site(self, **params):
|
|
"""Stream site
|
|
|
|
Accepted params found at:
|
|
https://dev.twitter.com/docs/api/1.1/get/site
|
|
"""
|
|
url = 'https://sitestream.twitter.com/%s/site.json' \
|
|
% self.streamer.api_version
|
|
return self.streamer._request(url, params=params)
|
|
|
|
|
|
class TwythonStreamerTypesStatuses(object):
|
|
"""Class for different statuses endpoints
|
|
|
|
Available so TwythonStreamer.statuses.filter() is available.
|
|
Just a bit cleaner than TwythonStreamer.statuses_filter(),
|
|
statuses_sample(), etc. all being single methods in TwythonStreamer
|
|
|
|
"""
|
|
def __init__(self, streamer):
|
|
self.streamer = streamer
|
|
|
|
def filter(self, **params):
|
|
"""Stream statuses/filter
|
|
|
|
:param \*\*params: Parameters to send with your stream request
|
|
|
|
Accepted params found at:
|
|
https://dev.twitter.com/docs/api/1.1/post/statuses/filter
|
|
"""
|
|
url = 'https://stream.twitter.com/%s/statuses/filter.json' \
|
|
% self.streamer.api_version
|
|
return self.streamer._request(url, 'POST', params=params)
|
|
|
|
def sample(self, **params):
|
|
"""Stream statuses/sample
|
|
|
|
:param \*\*params: Parameters to send with your stream request
|
|
|
|
Accepted params found at:
|
|
https://dev.twitter.com/docs/api/1.1/get/statuses/sample
|
|
"""
|
|
url = 'https://stream.twitter.com/%s/statuses/sample.json' \
|
|
% self.streamer.api_version
|
|
return self.streamer._request(url, params=params)
|
|
|
|
def firehose(self, **params):
|
|
"""Stream statuses/firehose
|
|
|
|
:param \*\*params: Parameters to send with your stream request
|
|
|
|
Accepted params found at:
|
|
https://dev.twitter.com/docs/api/1.1/get/statuses/firehose
|
|
"""
|
|
url = 'https://stream.twitter.com/%s/statuses/firehose.json' \
|
|
% self.streamer.api_version
|
|
return self.streamer._request(url, params=params)
|