Keine Beschreibung http://j1x-huginn.herokuapp.com

twitter_search_agent.rb 3.7KB

    module Agents class TwitterSearchAgent < Agent include TwitterConcern cannot_receive_events! description <<-MD The Twitter Search Agent performs and emits the results of a specified Twitter search. #{twitter_dependencies_missing if dependencies_missing?} If you want realtime data from Twitter about frequent terms, you should definitely use the Twitter Stream Agent instead. To be able to use this Agent you need to authenticate with Twitter in the [Services](/services) section first. You must provide the desired `search`. Set `result_type` to specify which [type of search results](https://dev.twitter.com/rest/reference/get/search/tweets) you would prefer to receive. Options are "mixed", "recent", and "popular". (default: `mixed`) Set `max_results` to limit the amount of results to retrieve per run(default: `500`. The API rate limit is ~18,000 per 15 minutes. [Click here to learn more about rate limits](https://dev.twitter.com/rest/public/rate-limiting). Set `expected_update_period_in_days` to the maximum amount of time that you'd expect to pass between Events being created by this Agent. Set `starting_at` to the date/time (eg. `Mon Jun 02 00:38:12 +0000 2014`) you want to start receiving tweets from (default: agent's `created_at`) MD event_description <<-MD Events are the raw JSON provided by the [Twitter API](https://dev.twitter.com/rest/reference/get/search/tweets). Should look something like: { ... every Tweet field, including ... "text": "something", "user": { "name": "Mr. Someone", "screen_name": "Someone", "location": "Vancouver BC Canada", "description": "...", "followers_count": 486, "friends_count": 1983, "created_at": "Mon Aug 29 23:38:14 +0000 2011", "time_zone": "Pacific Time (US & Canada)", "statuses_count": 3807, "lang": "en" }, "retweet_count": 0, "entities": ... "lang": "en" } MD default_schedule "every_1h" def working? event_created_within?(interpolated['expected_update_period_in_days']) && !recent_error_logs? end def default_options { 'search' => 'freebandnames', 'expected_update_period_in_days' => '2' } end def validate_options errors.add(:base, "search is required") unless options['search'].present? errors.add(:base, "expected_update_period_in_days is required") unless options['expected_update_period_in_days'].present? if options[:starting_at].present? Time.parse(interpolated[:starting_at]) rescue errors.add(:base, "Error parsing starting_at") end end def starting_at if interpolated[:starting_at].present? Time.parse(interpolated[:starting_at]) rescue created_at else created_at end end def max_results (interpolated['max_results'].presence || 500).to_i end def check since_id = memory['since_id'] || nil opts = {include_entities: true} opts.merge! result_type: interpolated[:result_type] if interpolated[:result_type].present? opts.merge! since_id: since_id unless since_id.nil? # http://www.rubydoc.info/gems/twitter/Twitter/REST/Search tweets = twitter.search(interpolated['search'], opts).take(max_results) tweets.each do |tweet| if (tweet.created_at >= starting_at) memory['since_id'] = tweet.id if !memory['since_id'] || (tweet.id > memory['since_id']) create_event payload: tweet.attrs end end save! end end end